input:
  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: |
        root = {
          meta("opcua_path"): this,
          "timestamp_ms": (timestamp_unix_nano() / 1000000).floor(),
          "is_machine_status": this.contains("DB_00CommunicationMachineStatus")
        }

output:
  broker:
    pattern: fan_out
    outputs:
      - switch:
          cases:
            - check: 'this.is_machine_status == true'
              output:
                mqtt:
                  urls:
                    - tcp://192.168.2.31:1883
                  topic: 'umh/v1/TLT/Muzzroom/Meulebekestraat/ProductionLine1/SortingUnit1/originID/_historian/machineStatus/${!meta("opcua_tag_group")}/${!meta("opcua_tag_name")}'
                  client_id: 'benthos-umh'

            - check: 'this.is_machine_status == false'
              output:
                mqtt:
                  urls:
                    - tcp://192.168.2.31:1883
                  topic: 'umh/v1/TLT/Muzzroom/Meulebekestraat/ProductionLine1/SortingUnit1/originID/_historian/${!meta("opcua_tag_group")}/${!meta("opcua_tag_name")}'
                  client_id: 'benthos-umh'

yaml
topic: '${! meta("my-cool-meta-variable") }'