MQTT Data Receiver

The mqtt data receiver retrieves data by subscribing to topics. Also includes support for sparkplug.

MQTT Example:

{
  "data_receiver_name": "my_mqtt_receiver",
  "protocol": "mqtt",
  "connections": [
    {
      "host": "some-host.local",
      "port": 1883,
      "username": "some_user",
      "password": "some_pass",
      "default_topic": "<insert topic name here. Used if stream topics undefined>"
    }
  ],
  "streams": [
    {
      "asset": "asset",
      "stream_type": "stream_type",
      "topic": "<insert topic name here>"
    }
  ]
}

Configuration:

Required and optional properties that can be configured for an Iot Hub receiver:

• connections: How to connect to the MQTT server. A connection has the following configurable settings:

  • host: MQTT broker hostname (e.g. broker.emqx.io)

  • port: MQTT connection port (Defaults to 1883)

  • client_id: Some unique string identifying the client to the MQTT server. Must be unique across all connections to the MQTT server.

  • username: Username to connect to the server

  • password: Password to connect to the server

  • version: The MQTT protocol version to use (Default is 3.1.1)

  • default_topic: Name of topic(s) to subscribe to. To subscribe to multiple topics, you can also use MQTT wildcards (‘+’, ‘#’)

  • plugin: MQTT provides additional protocols like sparkplug. The only option available here is “sparkplug” for the Sparkplug B format.

• streams: Each input stream has the following configurable settings:

  • asset: Asset identifier

  • stream_type: Type of data stream

  • topic: Name of topic(s) to subscribe to. To subscribe to multiple topics, you can also use MQTT wildcards (‘+’, ‘#’) This option overrides default_topic if it is already configured.