Diederik
09/28/2024, 5:45 PMDiederik
09/28/2024, 5:50 PMDiederik
09/28/2024, 5:50 PMinput:
opcua:
endpoint: 'opc.tcp://192.168.2.101:4840'
nodeIDs:
- 'ns=3;s="DB_00CommunicationDayResults"'
- 'ns=3;s="DB_00CommunicationMachineStatus"'
subscribeEnabled: true
pipeline:
processors:
- bloblang: |
meta folder = if meta("opcua_path").contains("DB_00CommunicationDayResults") {
"DayResults"
} else if meta("opcua_path").contains("DB_00CommunicationMachineStatus") {
"MachineStatus"
} else {
"unknown"
}
root = {
meta("opcua_path"): this,
"timestamp_ms": (timestamp_unix_nano() / 1000000).floor(),
}
output:
mqtt:
urls:
- tcp://192.168.2.31:1883
topic: 'umh/v1/TLT/Muzzroom/Meulebekestraat/ProductionLine1/SortingUnit1/originID/_historian/${!meta("folder")}/${!meta("opcua_tag_group")}/${!meta("opcua_tag_name")}'
client_id: 'benthos-umh'Diederik
09/28/2024, 5:53 PMDiederik
09/28/2024, 5:53 PMJermuk
09/30/2024, 6:44 AMFerdinand
09/30/2024, 7:25 AMFerdinand
09/30/2024, 7:27 AMDiederik
09/30/2024, 7:59 AMDiederik
09/30/2024, 7:59 AMFerdinand
09/30/2024, 9:39 AMlet tag_group = "/" + meta("opcua_tag_group").or("")
let tag_group = $tag_group.trim.trim_suffix("/") # This will make the string empty if opcua_tag_group is not set
meta "tag_group" = $tag_group
And then use
${!meta("tag_group")} instead of /${!meta("opcua_tag_group")}Ferdinand
09/30/2024, 9:39 AMDanielH
09/30/2024, 3:37 PMDiederik
09/30/2024, 3:53 PMDiederik
09/30/2024, 3:54 PMDanielH
09/30/2024, 5:28 PM