Tendrl

Docs / Strand / connectors/mqtt

MQTT Publish

Direction: Write Only | Type: mqtt

Publish messages to MQTT message brokers with support for TLS/SSL, authentication, and Quality of Service levels.

Operations#

Operation Direction Description
publish Write Publish a message to an MQTT topic

Connector Configuration#

Field Required Default Description
Broker URL Yes - MQTT broker address (mqtt:// or mqtts://)
Client ID No Auto MQTT client identifier
Username No - Broker username (encrypted)
Password No - Broker password (encrypted)
Keepalive No 60 Keepalive interval in seconds
Clean Session No true Start with a clean session
TLS No - TLS/SSL configuration (see below)
Topic No - Default topic (can be overridden at node level)
QoS No 0 Default Quality of Service (0, 1, or 2)
Timeout No 30 Connection timeout in seconds
Retain No false Retain messages on broker

TLS/SSL Configuration#

json

{
  "tls": {
    "enabled": true,
    "ca_certs": "/path/to/ca-cert.pem",
    "certfile": "/path/to/client-cert.pem",
    "keyfile": "/path/to/client-key.pem",
    "cert_reqs": "required",
    "tls_version": "tlsv1.2"
  }
}
Field Default Options
enabled false Enable TLS/SSL
ca_certs - CA certificate file for server validation
certfile - Client certificate for mutual TLS
keyfile - Client private key for mutual TLS
cert_reqs required none, optional, required
tls_version tlsv1.2 tlsv1, tlsv1.1, tlsv1.2, tlsv1.3

Quality of Service (QoS)#

Level Delivery Description
0 At most once Fire and forget (fastest)
1 At least once Acknowledged delivery
2 Exactly once Guaranteed delivery (slowest)

Node Configuration#

Field Required Description
Topic Yes MQTT topic to publish to (supports Jinja2)
QoS No Override connector default QoS
Retain No Override connector default retain
Payload No Message payload (string/object, defaults to event payload as JSON)
Timeout No Override connector default timeout

Output#

json

{
  "success": true,
  "status": "sent",
  "data": {
    "topic": "sensors/temperature",
    "message_id": 1,
    "qos": 1
  },
  "service": "mqtt",
  "operation": "publish"
}

Example#

Connector Setup:

json

{
  "broker_url": "mqtts://broker.example.com:8883",
  "username": "mqtt_user",
  "password": "mqtt_password",
  "tls": { "enabled": true, "cert_reqs": "required" },
  "qos": 1
}

Node Configuration:

← Back to Strand docs