ConsumeAMQP 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-amqp-nar
Descrição¶
Consome mensagens AMQP de um corretor AMQP usando o protocolo AMQP 0.9.1. Cada mensagem recebida do corretor AMQP será emitida como seu próprio FlowFile para a relação “success”.
Requisito de entrada¶
FORBIDDEN
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Versão do AMQP |
Versão do AMQP. Atualmente, é compatível apenas com o AMQP v0.9.1. |
Corretores |
Uma lista separada por vírgulas de corretores AMQP conhecidos no formato <host>:<port> (por exemplo, localhost:5672). Se isso for definido, o nome do host e a porta serão ignorados. Inclua apenas hosts do mesmo cluster AMQP. |
Autenticação de certificado de cliente ativada |
Faça a autenticação usando o certificado SSL em vez de nome de usuário/senha. |
Nome do host |
Endereço de rede do corretor AMQP (por exemplo, localhost). Se Corretores estiver definido, essa propriedade será ignorada. |
Tamanho máximo do corpo da mensagem de entrada |
Tamanho máximo do corpo das mensagens de entrada (recebidas). |
Senha |
Senha usada para autenticação e autorização. |
Porta |
Valor numérico que identifica a porta do corretor AMQP (por exemplo, 5671). Se Corretores estiver definido, essa propriedade será ignorada. |
Fila |
O nome da fila AMQP existente da qual as mensagens serão consumidas. Geralmente pré-definido pelo administrador do AMQP. |
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. |
Nome de usuário |
Nome de usuário usado para autenticação e autorização. |
Host virtual |
Nome de host virtual que segrega o sistema AMQP para aumentar a segurança. |
auto.acknowledge |
Se for falso (sem reconhecimento automático), as mensagens serão reconhecidas pelo processador após transferir os FlowFiles para success e confirmar a sessão NiFi. O modo sem reconhecimento automático fornece a semântica de entrega “pelo menos uma vez”. Se for verdadeiro (reconhecimento automático), as mensagens entregues ao cliente AMQP serão reconhecidas automaticamente pelo agente AMQP logo após o envio. Em geral, isso proporcionará uma melhor taxa de transferência, mas também resultará na perda de mensagens quando o corretor AMQP, o NiFi ou o processador for reiniciado ou falhar. O modo de reconhecimento automático fornece a semântica de entrega “no máximo uma vez” e é recomendado somente se a perda de mensagens for aceitável. |
batch.size |
O número máximo de mensagens que devem ser processadas em uma única sessão. Quando esse número de mensagens tiver sido recebido (ou quando não houver mais mensagens disponíveis), as mensagens recebidas serão transferidas à relação “success” e as mensagens serão confirmadas ao corretor AMQP. A configuração desse valor como um número maior pode resultar em melhor desempenho, especialmente para mensagens muito pequenas, mas também pode resultar na duplicação de mais mensagens após a reinicialização repentina do NiFi. |
header.format |
Define como emitir os cabeçalhos da mensagem recebida |
header.key.prefix |
Texto a ser prefixado nas chaves de cabeçalho à medida que são adicionadas aos atributos FlowFile. O processador acrescentará “.” ao valor dessa propriedade |
header.separator |
O caractere usado para separar valor e chave no cabeçalho da cadeia de caracteres. O valor deve ter apenas um caractere. |
prefetch.count |
O número máximo de mensagens não reconhecidas para o consumidor. Se o consumidor tiver esse número de mensagens não reconhecidas, o corretor AMQP não enviará mais novas mensagens até que o consumidor reconheça algumas das mensagens já entregues a ele. Valores permitidos: de 0 a 65535. 0 significa que não há limite. |
remove.curly.braces |
Se verdadeiro, Remover chaves removerá as chaves automaticamente do cabeçalho. |
Relações¶
Nome |
Descrição |
|---|---|
success |
Todos os FlowFiles recebidos da fila AMQP são encaminhados para essa relação |
Grava atributos¶
Nome |
Descrição |
|---|---|
amqp$appId |
O campo ID de aplicativo da mensagem AMQP |
amqp$contentEncoding |
A codificação de conteúdo informada pela mensagem AMQP |
amqp$contentType |
O tipo de conteúdo informado pela mensagem AMQP |
amqp$headers |
Os cabeçalhos presentes na mensagem AMQP. Adicionado somente se o processador estiver configurado para emitir esse atributo. |
<Prefixo da chave de cabeçalho>.<atributo> |
Cada cabeçalho de mensagem será inserido com esse nome de atributo, se o processador estiver configurado para emitir cabeçalhos como atributo |
amqp$deliveryMode |
O indicador numérico do modo de entrega da mensagem |
amqp$priority |
A prioridade da mensagem |
amqp$correlationId |
O ID da correlação de mensagem |
amqp$replyTo |
O valor do campo Reply-To da mensagem |
amqp$expiration |
A expiração da mensagem |
amqp$messageId |
O ID exclusivo da mensagem |
amqp$timestamp |
O carimbo de data/hora da mensagem, como o número de milissegundos desde a época |
amqp$type |
O tipo de mensagem |
amqp$userId |
O ID do usuário |
amqp$clusterId |
O ID do cluster AMQP |
amqp$routingKey |
A routingKey da mensagem AMQP |
amqp$exchange |
A exchange da qual a mensagem AMQP foi recebida |