MQTTSubscriber

Kurzbeschreibung

MQTTSubscriber und TriggeredMQTTSubscriber verbinden sich zu einem MQTT-Broker, abonnieren ein Topic und senden dann alle Messages, die auf dem Topic eingehen als FlowPakete in den Flow. MQTTSubscriber ist ein Inlet Brick und TriggeredMQTTSubscriber ein Process Brick mit einem Trigger-Port, der erlaubt die Ausführung des Bricks mit einem vorangestellten Timer oder Scheduler Brick zu kontrollieren.

../_images/mqttsubscriber.svg

Input

TriggeredMQTTSubscriber besitzt einen Input-Port.

any = variant : doc "value ignored";

Als Input empfängt TriggeredMQTTSubscriber jedes beliebige FlowPaket.

Output

TriggeredMQTTSubscriber, MQTTSubscriber besitzen jeweils einen Output-Port.

Message = string : doc "Eine einzene Message aus dem Topic";

Am Ausgang verschicken sie jede Message aus dem Topic als String.

Parametrisierung

Die Bricks haben folgende Parameter:

  • Host

  • Port

  • Topic

  • Username

  • Password

  • Protocoll

  • Debug

Host

Host-Adresse des MQTT Brokers. Der Standardwert erlaubt, sich mit einem Testbroker von HiveMQ zu verbinden.

  • Standardwert : “broker.mqttdashboard.com”

  • string

  • Pflichtfeld

Port

Port des MQTT Brokers.

  • Standardwert : 1883

  • int

  • Pflichtfeld

Topic

Das Topic, welches abonniert werden soll.

  • Standardwert : “testtopic/1”

  • string

  • Pflichtfeld

Username

Optionaler Username für gesicherte Broker.

  • Standardwert : “”

  • string

Password

Optionales Password für gesicherte Broker.

  • Standardwert : “”

  • Secret

Protocoll

Die MQTT Protokollversion, die verwendet werden soll (MQTTv31, MQTTv311, MQTTv5)

  • Standardwert : MQTTv311

  • string

Debug

Debug Modus (“on” oder “off”) für die Broker-Verbindung. Wenn er angeschaltet ist, wird jede Message und alle vom MQTT-Client erzeugen logs in den logs des Bricks angezeigt. Der Debug-Modus sollte nur zum Testen der Brick-Konfiguration eingeschaltet werden.

  • Standardwert : “off”

  • string

Funktion

Wie oben beschrieben, verbinden sich die Bricks mit einem MQTT Broker, abonnieren ein Topic und senden die Messages in den Flow. Dem TriggeredMQTTSubscriber kann man durch jedes beliebige FlowPaket am Eingang auslösen. Dabei löst nur das erste Paket den Start des Sendens der Messages aus dem Topic aus, weitere eingehende Pakete werden ignoriert.

Python-Modules

  • paho-mqtt