PublishMQTT 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-mqtt-nar
Descrição¶
Publica uma mensagem em um tópico MQTT
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
URI do corretor |
O(s) URI(s) a ser(em) usado(s) para se conectar ao corretor MQTT (por exemplo, tcp://localhost:1883). Os esquemas “tcp”, “ssl”, “ws” e “wss” são compatíveis. Para usar “ssl”, a propriedade de serviço de contexto SSL deve ser definida. Quando uma lista de URIs separadas por vírgulas for definida (por exemplo, tcp://localhost:1883,tcp://localhost:1884), o processador usará um algoritmo round-robin para se conectar aos corretores em caso de falha de conexão. |
ID do cliente |
ID do cliente MQTT a ser usado. Se não for definido, será gerado um UUID. |
Tempo limite de conexão (segundos) |
Intervalo máximo de tempo que o cliente aguardará para estabelecer a conexão de rede com o servidor MQTT. O tempo limite padrão é 30 segundos. Um valor 0 desativa o processamento de tempo limite, o que significa que o cliente aguardará até que a conexão de rede seja estabelecida com êxito ou falha. |
Intervalo de manutenção (segundos) |
Define o intervalo de tempo máximo entre as mensagens enviadas ou recebidas. Ele permite que o cliente detecte se o servidor não está mais disponível, sem precisar aguardar o tempo limite de TCP/IP. O cliente garantirá que pelo menos uma mensagem trafegue pela rede em cada período de keep alive. Na ausência de uma mensagem relacionada a dados durante o período de tempo, o cliente envia uma mensagem “ping” muito pequena, que o servidor reconhece. Um valor de 0 desativa o processamento de keepalive no cliente. |
Mensagem de última vontade |
A mensagem de última vontade do cliente a ser enviada. |
Nível QoS de última vontade |
O nível QoS a ser usado ao publicar a mensagem de última vontade. |
Retenção da última vontade |
Se você deve manter a última vontade do cliente. |
Tópico da última vontade |
O tópico para o qual enviar a última vontade do cliente. |
Versão de especificação MQTT |
A versão de especificação MQTT ao se conectar com o corretor. Consulte as descrições de valores permitidos para obter mais detalhes. |
Senha |
Senha a ser usada na conexão com o corretor |
Qualidade de serviço (QoS) |
A qualidade de serviço (QoS) com a qual você deseja enviar a mensagem. Aceita três valores “0”, “1” e “2”; “0” para “no máximo uma vez”, “1” para “pelo menos uma vez”, “2” para “exatamente uma vez”. A linguagem de expressão é permitida para oferecer suporte à publicação de mensagens com diferentes QoS, mas o valor final da propriedade deve ser “0”, “1” ou “2”. |
Reter mensagem |
Se o sinalizador de retenção deve ou não ser definido na mensagem MQTT. |
Serviço de contexto SSL |
O serviço de contexto SSL usado para fornecer informações de certificado de cliente para conexões TLS/SSL. |
Intervalo de expiração da sessão |
Após esse intervalo, o corretor irá expirar o cliente e limpar o estado da sessão. |
Estado da sessão |
Se você deseja iniciar um novo fluxo ou retomar fluxos anteriores. Consulte as descrições de valores permitidos para obter mais detalhes. |
Tópico |
O tópico no qual a mensagem será publicada. |
Nome de usuário |
Nome de usuário a ser usado na conexão com o corretor |
message-demarcator |
Com essa propriedade, você tem a opção de publicar várias mensagens em um único FlowFile. Essa propriedade permite que você forneça uma cadeia de caracteres (interpretada como UTF-8) a ser usada para demarcar o conteúdo do FlowFile. Essa é uma propriedade opcional; se não for fornecida, e se não for definido um Record Reader/Writer, cada FlowFile será publicado como uma única mensagem. Para inserir um caractere especial, como “nova linha”, use CTRL + Enter ou Shift + Enter, dependendo do OS. |
record-reader |
O Record Reader a ser usado para analisar o FlowFile de entrada em registros. |
record-writer |
O Record Writer a ser usado para serializar registros antes de publicá-los como uma mensagem MQTT. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
FlowFiles que não foram enviados ao destino são transferidos para essa relação. |
success |
FlowFiles enviados com sucesso para o destino são transferidos para essa relação. |