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

Tags

IOT, MQTT, consumo, ouvir, assinar

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.

Consulte também