GetAzureQueueStorage_v12 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-azure-nar
Descrição¶
Recupera as mensagens de um Armazenamento de Filas do Azure. As mensagens recuperadas serão excluídas da fila por padrão. Se o requisito for consumir mensagens sem excluí-las, defina “Auto Delete Messages” (Exclusão automática de mensagens) como “falso”. Observação: pode haver chances de recebimento de mensagens duplicadas em situações como quando uma mensagem é recebida, mas não pôde ser excluída da fila devido a circunstâncias inesperadas.
Requisito de entrada¶
FORBIDDEN
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Exclusão automática de mensagens |
Especifica se a mensagem recebida deve ser excluída automaticamente da fila. |
Serviço de credenciais |
Controller Service usado para obter credenciais de armazenamento do Azure. |
Tamanho do lote de mensagens |
O número de mensagens a serem recuperadas da fila. |
Nome da fila |
Nome da fila de armazenamento do Azure |
Tempo limite da solicitação |
O tempo limite para solicitações de leitura ou gravação no Armazenamento de Filas do Azure. O padrão é 1 segundo. |
Tempo limite de visibilidade |
A duração durante a qual a mensagem recuperada deve ficar invisível para outros consumidores. |
proxy-configuration-service |
Especifica o serviço de Controller Service de configuração de proxy para a realização de proxy de solicitações de rede. No caso de SOCKS, não é garantido que a versão de SOCKS selecionada será usada pelo processador. |
storage-endpoint-suffix |
As contas de armazenamento no Azure público sempre usam um sufixo FQDN comum. Substitua esse sufixo do ponto de extremidade por um sufixo diferente em determinadas circunstâncias (como o Azure Stack ou regiões não públicas do Azure). |
Relações¶
Nome |
Descrição |
|---|---|
success |
Todos os FlowFiles processados com sucesso são encaminhados para essa relação |
Grava atributos¶
Nome |
Descrição |
|---|---|
azure.queue.uri |
O URI absoluto do Armazenamento de Filas do Azure configurado |
azure.queue.insertionTime |
A hora em que a mensagem foi inserida no armazenamento da fila |
azure.queue.expirationTime |
A hora em que a mensagem expirará do armazenamento da fila |
azure.queue.messageId |
O ID da mensagem recuperada |
azure.queue.popReceipt |
O recebimento pop da mensagem recuperada |