used yaml:
input:
opcua:
endpoint: 'opc.tcp://192.168.73.1:4840'
nodeIDs: [ns=3;s="DB_00CommunicationDayResults"]
subscribeEnabled: true
pipeline:
processors:
- bloblang: |
root = {
meta("opcua_path"): this,
"timestamp_ms": (timestamp_unix_nano() / 1000000).floor()
}
output:
mqtt:
urls:
- '192.168.2.30:1883'
topic: 'umh/v1/TLT/Muzzroom/Meulebekestraat/ProductionLine3/SortingUnit2/originID/_historian/${! meta("opcua_tag_path") }'
client_id: 'benthos-umh'