PublishMQTT 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-mqtt-nar
Beschreibung¶
Veröffentlict eine Meldung in einem MQTT-Thema.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Broker-URI |
Die URI(s), die Sie für die Verbindung mit dem MQTT-Broker verwenden (z. B. tcp://localhost:1883). Die Schemas „tcp“, „ssl“, „ws“ und „wss“ werden unterstützt. Um „ssl“ zu verwenden, muss die Eigenschaft „SSL Context Service“ eingestellt sein. Wenn eine durch Kommas getrennte URI-Liste festgelegt ist (z. B. tcp://localhost:1883,tcp://localhost:1884), verwendet der Prozessor einen Round-Robin-Algorithmus, um bei einem Verbindungsausfall eine Verbindung zu den Brokern herzustellen. |
Client-ID |
Zu verwendende MQTT-Client-ID. Wenn nicht festgelegt, wird eine UUID generiert. |
Connection Timeout (seconds) |
Maximales Zeitintervall, das der Client auf den Aufbau der Netzwerkverbindung zum MQTT-Server wartet. Das Standard-Timeout beträgt 30 Sekunden. Ein Wert von 0 deaktiviert die Timeout-Verarbeitung, d. h. der Client wartet, bis die Netzwerkverbindung erfolgreich hergestellt wurde oder fehlschlägt. |
Keep Alive Interval (seconds) |
Legt den maximalen Zeitabstand zwischen gesendeten oder empfangenen Meldungen fest. Es ermöglicht es dem Client zu erkennen, wenn der Server nicht mehr verfügbar ist, ohne auf das TCP/IP-Timeout warten zu müssen. Der Client sorgt dafür, dass innerhalb jedes Keep-Alive-Zeitraums mindestens eine Meldung über das Netzwerk übertragen wird. Wenn innerhalb dieses Zeitraums keine datenbezogene Meldung eingeht, sendet der Client eine sehr kleine „Ping“-Meldung, die vom Server bestätigt wird. Ein Wert von 0 deaktiviert die Keep-Alive-Verarbeitung auf dem Client. |
Last Will Message |
Die Meldung, die als „Last Will“ des Clients gesendet werden soll. |
Last Will QoS Level |
QoS-Ebene, die bei der Veröffentlichung der „Last Will“-Meldung verwendet werden soll. |
Last Will Retain |
Ob der „Last Will“ des Clients aufbewahrt werden soll. |
Last Will Topic |
Das Thema, an das der „Last Will“ des Clients gesendet werden soll. |
MQTT Specification Version |
Die Version der MQTT-Spezifikation bei der Verbindung mit dem Broker. Weitere Informationen finden Sie in den Beschreibungen der zulässigen Werte. |
Password |
Kennwort, das bei der Verbindung mit dem Broker verwendet wird |
Quality of Service(QoS) |
Die Dienstgüte (Quality of Service, QoS ), mit der die Meldung gesendet werden soll. Akzeptiert drei Werte „0“, „1“ und „2“; „0“ für „höchstens einmal“, „1“ für „mindestens einmal“, „2“ für „genau einmal“. Ausdruckssprache ist erlaubt, um die Veröffentlichung von Meldungen mit verschiedenen QoS zu unterstützen, aber der Endwert der Eigenschaft muss entweder „0“, „1“ oder „2“ sein. |
Retain Message |
Ob das Beibehaltungsflag für die MQTT-Meldung gesetzt werden soll oder nicht. |
SSL Context Service |
Der SSL Context Service wird verwendet, um Client-Zertifikatsinformationen für TLS/SSL-Verbindungen bereitzustellen. |
Session Expiry Interval |
Nach diesem Intervall beendet der Broker den Client und löscht den Sitzungsstatus. |
Sitzungsstatus |
Ob ein neuer Ablauf gestartet oder ein vorheriger Ablauf fortgesetzt werden soll. Weitere Informationen finden Sie in den Beschreibungen der zulässigen Werte. |
Thema |
Das Thema, in dem die Meldung veröffentlicht werden soll. |
Username |
Benutzername, der bei der Verbindung zum Broker verwendet werden soll |
message-demarcator |
Mit dieser Eigenschaft haben Sie die Möglichkeit, mehrere Meldungen von einem einzigen FlowFile zu veröffentlichen. Mit dieser Eigenschaft können Sie eine Zeichenfolge (interpretiert als UTF-8) angeben, die Sie zur Abgrenzung des Inhalts des FlowFile verwenden. Dies ist eine optionale Eigenschaft. Wenn sie nicht angegeben ist und kein Record Reader/Writer definiert ist, wird jedes FlowFile als einzelne Meldung veröffentlicht. Zur Eingabe von Sonderzeichen wie z. B. einen Zeilenumbruch verwenden Sie je nach OS CTRL+Enter oder Shift+Enter. |
record-reader |
Der Record Reader, der zum Parsen des eingehenden FlowFile in Datensätze verwendet wird. |
record-writer |
Der Record Writer, der für die Serialisierung von Datensätzen verwendet wird, bevor diese als MQTT-Meldung veröffentlicht werden. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
FlowFiles, die nicht an das Ziel gesendet werden konnten, werden an diese Beziehung übertragen. |
success |
FlowFiles, die erfolgreich an das Ziel gesendet wurden, werden an diese Beziehung übertragen. |