MQTT Writer¶
Class: MQTTWriterSinkBlockV1
Source: inference.enterprise.workflows.enterprise_blocks.sinks.mqtt_writer.v1.MQTTWriterSinkBlockV1
MQTT Writer block for publishing messages to an MQTT broker.
This block is blocking on connect and publish operations.
Outputs: - error_status (bool): Indicates if an error occurred during the MQTT publishing process. True if there was an error, False if successful. - message (str): Status message describing the result of the operation. Contains error details if error_status is True, or success confirmation if error_status is False.
Type identifier¶
Use the following identifier in step "type" field: mqtt_writer_sink@v1to add the block as
as step in your workflow.
Properties¶
| Name | Type | Description | Refs |
|---|---|---|---|
name |
str |
Enter a unique identifier for this step.. | ❌ |
host |
str |
Host of the MQTT broker.. | ✅ |
port |
int |
Port of the MQTT broker.. | ✅ |
topic |
str |
MQTT topic to publish the message to.. | ✅ |
message |
str |
Message to be published.. | ✅ |
qos |
int |
Quality of Service level for the message.. | ✅ |
retain |
bool |
Whether the message should be retained by the broker.. | ✅ |
timeout |
float |
Timeout for connecting to the MQTT broker and for sending MQTT messages.. | ✅ |
username |
str |
Username for MQTT broker authentication.. | ✅ |
password |
str |
Password for MQTT broker authentication.. | ✅ |
The Refs column marks possibility to parametrise the property with dynamic values available
in workflow runtime. See Bindings for more info.
Available Connections¶
Compatible Blocks
Check what blocks you can connect to MQTT Writer in version v1.
- inputs:
Email Notification,VLM As Classifier,Object Detection Model,Pixel Color Count,Template Matching,Model Monitoring Inference Aggregator,Keypoint Detection Model,Qwen-VL,OpenAI,CogVLM,Cosine Similarity,Google Vision OCR,Florence-2 Model,Roboflow Dataset Upload,Qwen3.5-VL,Roboflow Vision Events,SIFT Comparison,S3 Sink,Twilio SMS/MMS Notification,SIFT Comparison,Stitch OCR Detections,Dynamic Zone,OCR Model,Roboflow Dataset Upload,Gaze Detection,Roboflow Custom Metadata,LMM For Classification,OpenAI-Compatible LLM,Current Time,Perspective Correction,Anthropic Claude,MQTT Writer,MoonshotAI Kimi,Google Gemini,Identify Changes,Detections Consensus,Google Gemma API,Slack Notification,Identify Outliers,Image Stack,Google Gemini,Stitch OCR Detections,Camera Focus,CSV Formatter,OpenAI,Anthropic Claude,Roboflow Asset Library Attributes,Florence-2 Model,EasyOCR,Twilio SMS Notification,Local File Sink,VLM As Classifier,Qwen 3.5 API,JSON Parser,OpenRouter,Distance Measurement,OpenAI,MoonshotAI Kimi,Google Gemini,Single-Label Classification Model,Line Counter,Webhook Sink,Detection Event Log,VLM As Detector,Anthropic Claude,Clip Comparison,Multi-Label Classification Model,OpenAI,Llama 3.2 Vision,Motion Detection,PTZ Tracking (ONVIF),Google Gemma,OPC UA Writer Sink,Line Counter,Email Notification,LMM,Event Writer,Instance Segmentation Model,Camera Focus,GLM-OCR,Qwen 3.6 API,Image Contours,VLM As Detector,Llama 3.2 Vision,Microsoft SQL Server Sink - outputs:
Detections Classes Replacement,Morphological Transformation,Image Preprocessing,Email Notification,Halo Visualization,Morphological Transformation,Object Detection Model,Time in Zone,BoT-SORT Tracker,Text Display,Template Matching,Pixel Color Count,Image Threshold,Model Monitoring Inference Aggregator,Pixelate Visualization,Keypoint Detection Model,Time in Zone,Qwen-VL,OpenAI,CogVLM,Crop Visualization,SAM 3,Dot Visualization,Google Vision OCR,Florence-2 Model,Roboflow Dataset Upload,Qwen3.5-VL,Roboflow Vision Events,Polygon Zone Visualization,Polygon Visualization,S3 Sink,Twilio SMS/MMS Notification,QR Code Generator,SIFT Comparison,Single-Label Classification Model,Cache Get,Stitch OCR Detections,Dynamic Zone,Color Visualization,Roboflow Dataset Upload,Gaze Detection,Roboflow Custom Metadata,LMM For Classification,OpenAI-Compatible LLM,Line Counter Visualization,Stability AI Inpainting,Image Blur,Object Detection Model,Blur Visualization,Path Deviation,Current Time,SAM 3,Perspective Correction,Keypoint Visualization,Anthropic Claude,MQTT Writer,MoonshotAI Kimi,Google Gemini,SAM 3,Depth Estimation,Detections Consensus,Ellipse Visualization,Detections Stitch,Google Gemma API,Object Detection Model,Slack Notification,Time in Zone,Image Stack,Google Gemini,Cache Set,Bounding Box Visualization,Label Visualization,Keypoint Detection Model,Stitch OCR Detections,Size Measurement,Keypoint Detection Model,Multi-Label Classification Model,OpenAI,Perception Encoder Embedding Model,Anthropic Claude,Roboflow Asset Library Attributes,Moondream2,CLIP Embedding Model,Florence-2 Model,Seg Preview,YOLO-World Model,Multi-Label Classification Model,Segment Anything 2 Model,Twilio SMS Notification,Local File Sink,Single-Label Classification Model,Triangle Visualization,Icon Visualization,Qwen 3.5 API,Path Deviation,OpenRouter,Instance Segmentation Model,Distance Measurement,Instance Segmentation Model,OpenAI,Background Color Visualization,MoonshotAI Kimi,Google Gemini,Corner Visualization,Reference Path Visualization,Single-Label Classification Model,Line Counter,Halo Visualization,Webhook Sink,Dynamic Crop,Instance Segmentation Model,Stability AI Outpainting,Anthropic Claude,Multi-Label Classification Model,Clip Comparison,OpenAI,Llama 3.2 Vision,Motion Detection,PTZ Tracking (ONVIF),Camera Calibration,Model Comparison Visualization,Trace Visualization,Google Gemma,OPC UA Writer Sink,Line Counter,Circle Visualization,Email Notification,LMM,Event Writer,Instance Segmentation Model,Heatmap Visualization,Contrast Equalization,GLM-OCR,Qwen 3.6 API,Classification Label Visualization,Llama 3.2 Vision,Mask Visualization,Microsoft SQL Server Sink,Stability AI Image Generation,Semantic Segmentation Model,Polygon Visualization
Input and Output Bindings¶
The available connections depend on its binding kinds. Check what binding kinds
MQTT Writer in version v1 has.
Bindings
-
input
host(string): Host of the MQTT broker..port(integer): Port of the MQTT broker..topic(string): MQTT topic to publish the message to..message(string): Message to be published..qos(integer): Quality of Service level for the message..retain(boolean): Whether the message should be retained by the broker..timeout(float): Timeout for connecting to the MQTT broker and for sending MQTT messages..username(string): Username for MQTT broker authentication..password(string): Password for MQTT broker authentication..
-
output
Example JSON definition of step MQTT Writer in version v1
{
"name": "<your_step_name_here>",
"type": "mqtt_writer_sink@v1",
"host": "localhost",
"port": 1883,
"topic": "sensors/temperature",
"message": "Hello, MQTT!",
"qos": 0,
"retain": true,
"timeout": 0.5,
"username": "$inputs.mqtt_username",
"password": "$inputs.mqtt_password"
}