Bots From Extension: mqtt
MQTT - Publish and Subscribe to a topic in MQTT stream
This extension provides 4 bots.
Bot @mqtt:publish-as-json
Bot Position In Pipeline: Sink
Publish each input row as JSON encoded message to a specified topic
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
| Parameter Name | Type | Default Value | Description |
|---|---|---|---|
| topic* | Text | Topic name |
Bot @mqtt:publish-messages
Bot Position In Pipeline: Sink
Publish each row as a message with 'topic' column and 'payload' column. If payload column is a dict, it will be encoded as JSON.
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
| Parameter Name | Type | Default Value | Description |
|---|---|---|---|
| topic_column | Text | topic | Column name with topic to be published |
| payload_column | Text | payload | Column name with payload to be published |
Bot @mqtt:simulate-iot-sensors
Bot Position In Pipeline: Sink
Simulate IoT Sensor telemetry data publication to the MQTT broker. Input template describes sensors and locations involved in the simulation.
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
| Parameter Name | Type | Default Value | Description |
|---|---|---|---|
| template_column | Text | content | IoT Simulator specification column, typically loaded from a JSON template |
| duration | Text | 300 | Number of seconds to do the IoT Simulation. |
Bot @mqtt:subscribe-stream
Bot Position In Pipeline: Source
Subscribe to a topic or topics and read messages as a stream
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
| Parameter Name | Type | Default Value | Description |
|---|---|---|---|
| topic* | Text | Topic name to be subscribed and receive data. Multiple topics can be specified with comma separator | |
| format* | Text | Format must be one of 'json', 'text' or 'binary' | |
| batch_size | Text | 100 | Approximate number of messages to be retrieved in each batch |
| batch_wait | Text | 1.0 | Number of seconds to wait for each batch. |