ERRO Connection lost due to: EOF benthos stream

62 Views Asked by At

I am going to stream static Benthos but when I stream a single file it works fine. but when try to stream 2 files it gives EOF error.

Here is the error screenshot. enter image description here

below are the files.

bar.yaml

input:
  opcuatrigger:
    endpoint: "opc.tcp://localhost:46010"
    nodeIDs: ["ns=2;s=Humidity", "ns=2;s=Air Quality"]
    subscribeEnabled: true
    insecure: true
pipeline:
  processors:
    - bloblang: |
        root = meta("Message").parse_json()
        root.value = this
        root.timestamp_ms = (timestamp_unix_nano() / 1000000).floor()
output:
  mqtt:
    urls:
      - 'localhost:1883'
    topic: 'ia/raw/opcuatrigger${! meta("opcua_path") }'
    client_id: benthos-umh

foo.yaml

input:
  opcua:
    endpoint: "opc.tcp://localhost:46010"
    nodeIDs: ["ns=2;s=Humidity", "ns=2;s=Air Quality"]
    subscribeEnabled: true
    insecure: true
pipeline:
  processors:
    - bloblang: |
        root.value = this
        root.timestamp_ms = (timestamp_unix_nano() / 1000000).floor()
output:
  mqtt:
    urls:
      - 'localhost:1883'
    topic: 'ia/raw/opcua/'
    client_id: benthos-umh

use below command for it.

benthos streams ./streams/*.yaml

using benthos-umh for plugin

0

There are 0 best solutions below