Issue in benthos plugin

[mittal-jatin]

I'm referring https://www.benthos.dev/blog/2019/08/20/write-a-benthos-plugin/ to create a custom processor and run locally.

pipeline:
  processors:
    - json:
        operator: copy
        path: x
        value: y
    - process_field:
        path: y
        result_type: int
        processors:
          - type: fnv_hash
    - bloblang: |
        root = this
        root.x = this.x.trim()
        root.y = "task" + ((this.y % 64) % 3).string()
    - log:
        level: INFO
        message: 'test'

When I'm just having above part, its running fine and giving results as expected but when I'm adding input as

input:
  label: "bq_input_benthos"
  gcp_bigquery_select:
    project: test-project
    table: test-dataset.test-table
    columns:
      - col1
      - col2
      - col3
    where: time BETWEEN DATETIME("2024-01-15") AND DATETIME("2024-01-25")

I'm getting below error -
line 5: unable to infer input type, candidates were: [gcp_bigquery_select]

[Jeffail]

Hey @mittal-jatin, that post is pretty old and outdated, ideally you want to follow the example plugin repo: https://github.com/benthosdev/benthos-plugin-example and the examples from https://pkg.go.dev/github.com/benthosdev/benthos/[email protected]/public/service, specifically you need to import the specific plugins from the main project that you want as they aren't all included in your build by default. Take a look at the imports here: https://github.com/benthosdev/benthos-plugin-example/blob/master/main.go#L14

Closing as per #2026

[mittal-jatin]

Thanks, this was helpful.