ConsumeMQTT 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-mqtt-nar
Descrição¶
Assina um tópico e recebe mensagens de um corretor MQTT
Requisito de entrada¶
FORBIDDEN
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. |
ID do grupo |
ID do grupo de consumidores MQTT a ser usado. Se o ID do grupo não estiver definido, o cliente se conectará como consumidor individual. |
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. |
Tamanho máximo da fila |
As mensagens MQTT estão sempre sendo enviadas aos assinantes de um tópico, independentemente da frequência com que o processador é programado para ser executado. Se o cronograma de execução estiver significativamente atrasado em relação à taxa de chegada das mensagens a esse processador, poderá ocorrer um acúmulo na fila interna desse processador. Essa propriedade especifica o número máximo de mensagens que esse processador manterá na memória de uma só vez na fila interna. Esses dados seriam perdidos no caso de uma reinicialização do NiFi. |
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 deseja receber a mensagem. Aceita valores “0”, “1” ou “2”; “0” para “no máximo uma vez”, “1” para “pelo menos uma vez”, “2” para “exatamente uma vez”. |
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. |
Filtro de tópicos |
O filtro de tópicos MQTT para designar os tópicos a serem assinados. |
Nome de usuário |
Nome de usuário a ser usado na conexão com o corretor |
add-attributes-as-fields |
Se essa propriedade for definida como verdadeiro, os campos padrão serão adicionados em cada registro: _topic, _qos, _isDuplicate, _isRetained. |
message-demarcator |
Com essa propriedade, você tem a opção de emitir FlowFiles que contém várias mensagens. Essa propriedade permite que você forneça uma cadeia de caracteres (interpretada como UTF-8) a ser usada para demarcar várias mensagens. Essa é uma propriedade opcional; se não for fornecida, e um Record Reader/Writer não estiver definindo, cada mensagem recebida resultará em um único FlowFile. 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 as mensagens MQTT recebidas em registros. |
record-writer |
O Record Writer a ser usado para serializar registros antes de gravá-los em um FlowFile. |
Relações¶
Nome |
Descrição |
|---|---|
Mensagem |
A saída da mensagem MQTT |
parse.failure |
Se uma mensagem não puder ser analisada usando o Record Reader configurado, o conteúdo da mensagem será encaminhado para essa relação como seu próprio FlowFile. |
Grava atributos¶
Nome |
Descrição |
|---|---|
record.count |
O número de registros recebidos |
mqtt.broker |
Corretor MQTT que era a fonte da mensagem |
mqtt.topic |
Tópico MQTT no qual a mensagem foi recebida |
mqtt.qos |
A qualidade de serviço para essa mensagem. |
mqtt.isDuplicate |
Se essa mensagem pode ou não ser uma duplicata de outra que já foi recebida. |
mqtt.isRetained |
Se essa mensagem era ou não de um editor atual ou se foi “retida” pelo servidor como a última mensagem publicada sobre o tópico. |