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.
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
