PublishAMQP 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-amqp-nar
Descrição¶
Cria uma mensagem AMQP a partir do conteúdo de um FlowFile e envia a mensagem para um AMQP Exchange. Em um modelo típico de AMQP Exchange, a mensagem enviada ao AMQP Exchange será roteada com base na “chave de roteamento” para seu destino final na fila (a vinculação). Se, devido a alguma configuração incorreta, a vinculação entre Exchange, chave de roteamento e fila não for definida, a mensagem não terá destino final e retornará (ou seja, os dados não chegarão à fila). Se isso acontecer, você verá um registro no app-log e no bulletin informando esse fato, e o FlowFile será encaminhado para a relação de “failure”.
Requisito de entrada¶
REQUIRED
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 Exchange |
O nome do AMQP Exchange para o qual as mensagens serão enviadas. Geralmente fornecido pelo administrador do AMQP (por exemplo, “amq.direct”). É uma propriedade opcional. Se for mantida vazia, as mensagens serão enviadas para um AMQP Exchange padrão. |
Padrão de cabeçalhos |
Expressão regular que será avaliada em relação aos atributos do FlowFile para selecionar os atributos correspondentes e colocá-los como cabeçalhos de AMQP. O nome do atributo será usado como chave de cabeçalho. |
Fonte dos cabeçalhos |
A origem dos cabeçalhos que serão aplicados à mensagem publicada. |
Nome do host |
Endereço de rede do corretor AMQP (por exemplo, localhost). Se Corretores estiver definido, essa propriedade será ignorada. |
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. |
Chave de roteamento |
O nome da chave de roteamento que será usada pelo AMQP para rotear mensagens do exchange para uma fila de destino. Normalmente fornecida pelo administrador (por exemplo, “myKey”). Quando as mensagens são enviadas para uma troca padrão, essa propriedade corresponde a um nome de fila de destino; caso contrário, é necessário definir uma vinculação da troca para uma fila por meio da chave de roteamento (normalmente 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. |
header.separator |
O caractere que é usado para dividir o valor-chave dos cabeçalhos. O valor deve ter apenas um caractere. Caso contrário, você receberá uma mensagem de erro |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Todos os FlowFiles que não podem ser roteados para o destino do AMQP são roteados para essa relação |
success |
Todos os FlowFiles que são enviados ao destino do AMQP são roteados para essa relação |