pycsamt.iot.protocols.mqtt#

MQTT telemetry transport (optional dependency: paho-mqtt).

MQTTTelemetryClient publishes packets to their topic and can subscribe/listen for downlink messages. paho-mqtt is imported lazily inside _connect(), so the subpackage — and dry-run simulations — work without it installed.

Classes

MQTTTelemetryClient([endpoint, dry_run, ...])

Publish/subscribe telemetry over MQTT.

class pycsamt.iot.protocols.mqtt.MQTTTelemetryClient(endpoint=None, *, dry_run=False, host=None, port=1883, username=None, password=None, tls=False, keepalive=60, client_id=None, **options)[source]#

Bases: BaseTelemetryClient

Publish/subscribe telemetry over MQTT.

Parameters:

endpoint (str | None)
dry_run (bool)
host (str | None)
port (int)
username (str | None)
password (str | None)
tls (bool)
keepalive (int)
client_id (str | None)
options (dict[str, Any])

protocol: IoTProtocol = 'mqtt'#