PublishMQTT 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-mqtt-nar
Description¶
Publie un message sur un sujet MQTT
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Broker URI |
La ou les URI à utiliser pour se connecter au brocker MQTT (par exemple, tcp://localhost:1883). Les schémas « tcp », « ssl », « ws » et « wss » sont pris en charge. Pour que « ssl » puisse être utilisée, il faut que la propriété SSL Context Service soit définie. Lorsqu’une liste URI séparée par des virgules est spécifiée (par exemple, tcp://localhost:1883,tcp://localhost:1884), le processeur utilise un algorithme round-robin pour se connecter aux brokers en cas d’échec de la connexion. |
ID de client |
L’ID du client MQTT à utiliser. Si cette propriété n’est pas spécifiée, un UUID sera généré. |
Connection Timeout (seconds) |
Intervalle de temps maximum pendant lequel le client attendra l’établissement de la connexion réseau avec le serveur MQTT. Le délai d’expiration par défaut est de 30 secondes. La valeur 0 désactive le traitement du délai d’expiration, ce qui signifie que le client attendra jusqu’à ce que l’établissement de la connexion au réseau ait réussi ou échoué. |
Keep Alive Interval (seconds) |
Définit l’intervalle de temps maximum entre les messages envoyés ou reçus. Il permet au client de détecter si le serveur n’est plus disponible sans avoir à attendre le délai d’expiration TCP/IP. Le client veille à ce qu’au moins un message traverse le réseau au cours de chaque intervalle de maintien en vie. En l’absence de message lié aux données pendant cette période, le client envoie un très petit message « ping », dont le serveur accuse réception. La valeur 0 désactive le traitement Keep Alive dans le client. |
Last Will Message |
Le message à envoyer en tant que dernière volonté du client. |
Last Will QoS Level |
Niveau de QoS à utiliser lors de la publication du message de dernières volontés. |
Last Will Retain |
Précise si les dernières volontés du client doivent être conservées ou non. |
Last Will Topic |
Le sujet auquel envoyer les dernières volontés du client. |
MQTT Specification Version |
La version de la spécification MQTT à utiliser lors de la connexion avec le broker. Voir la description des valeurs autorisées pour plus de détails. |
Mot de passe |
Mot de passe à utiliser lors de la connexion au brocker |
Quality of Service (QoS) |
La qualité de service (QoS) avec laquelle le message doit être envoyé. Accepte trois valeurs “0”, “1” et “2” ; “0” pour “au plus une fois”, “1” pour “at least once”, “2” pour “exactly once”. L’Expression Language est autorisé afin de prendre en charge la publication de messages avec différents QoS, mais la valeur finale de la propriété doit être soit “0”, “1” ou “2”. |
Retain Message |
Indique si le indicateur de rétention doit être défini sur le message MQTT. |
Service contextuel SSL |
Le service de contexte SSL utilisé pour fournir des informations sur les certificats des clients pour les connexions TLS/SSL. |
Session Expiry Interval |
À l’issue de cet intervalle, l’agent de change met fin à la relation avec le client et efface l’état de la session. |
État de la session |
Détermine s’il s’agit d’un nouveau flux ou de la reprise de flux antérieurs. Voir la description des valeurs autorisées pour plus de détails. |
Sujet |
Le sujet sur lequel le message doit être publié. |
NomUtilisateur |
Nom d’utilisateur à utiliser lors de la connexion au broker |
message-demarcator |
Cette propriété vous permet de publier plusieurs messages à partir d’un seul FlowFile. Cette propriété vous permet de fournir une chaîne (interprétée comme UTF-8) à utiliser pour délimiter le contenu du FlowFile. Ceci est une propriété optionnelle ; si elle n’est pas fournie et si aucun Record Reader/Writer n’est défini, chaque FlowFile sera publié comme un message unique. Pour saisir un caractère spécial tel que « nouvelle ligne », utilisez CTRL+Entrée ou Maj+Entrée en fonction de l’OS. |
record-reader |
Le Record Reader à utiliser pour analyser le FlowFile entrant en enregistrements. |
record-writer |
Le Record Writer à utiliser pour sérialiser les enregistrements avant de les publier sous la forme d’un message MQTT. |
Relations¶
Nom |
Description |
|---|---|
failure |
FlowFiles qui n’ont pas été envoyés à la destination sont transférés à cette relation. |
success |
FlowFiles qui sont envoyées avec succès à la destination sont transférées à cette relation. |