GetAzureEventHub 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-azure-nar
Descrição¶
Recebe mensagens dos Hubs de Eventos do Microsoft Azure sem rastreamento confiável de pontos de verificação. No ambiente em cluster, as instâncias do processador GetAzureEventHub funcionam de forma independente e todos os nós do cluster processam todas as mensagens (a menos que o processador esteja sendo executado no modo Somente primário). ConsumeAzureEventHub oferece a abordagem recomendada para receber mensagens dos Hubs de Eventos do Azure. Esse processador cria um pool de threads para conexões com os Hubs de Eventos do Azure.
Requisito de entrada¶
FORBIDDEN
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Grupo de consumidores do Hubs de Eventos |
O nome do grupo de consumidores a ser usado ao extrair eventos |
Tempo de enfileiramento de mensagens do Hub de Eventos |
Um carimbo de data/hora (Instantâneo ISO-8601) formatado como YYYY-MM-DDThhmmss.sssZ (2016-01-01T01:01:01.000Z) a partir do qual as mensagens deveriam ter sido enfileiradas no hub de eventos para iniciar a leitura |
Nome do hub de eventos |
Nome da fonte dos Hubs de Eventos do Azure |
Namespace do hub de eventos |
Namespace dos Hubs de Eventos do Azure com prefixo do domínio do ponto de extremidade do barramento de serviço |
Tempo limite do receptor de partição (milissegundos) |
O tempo, em milissegundos, que um recebedor de partição deve esperar para receber o tamanho de busca antes de retornar. O padrão é 60000 |
Tamanho da busca do recebedor de partição |
O número de eventos que um receptor deve buscar em uma partição de Hubs de Eventos antes de retornar. O padrão é 100 |
Ponto de extremidade do barramento de serviço |
Para oferecer suporte a namespaces que não estejam no domínio padrão do windows.net. |
Nome da política de acesso compartilhado |
O nome da política de acesso compartilhada. Essa política deve ter permissões de escuta. |
Chave primária da política de acesso compartilhado |
A chave da política de acesso compartilhado. A chave primária ou secundária pode ser usada. |
Tipo de transporte |
Tipo de transporte do protocolo avançado de enfileiramento de mensagens avançado para comunicação com os Hubs de Eventos do Azure |
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. |
use-managed-identity |
Escolha se deseja ou não usar a identidade gerenciada do Azure VM/VMSS |
Relações¶
Nome |
Descrição |
|---|---|
success |
Qualquer FlowFile que seja recebido com sucesso do hub de eventos será transferido para essa relação. |
Grava atributos¶
Nome |
Descrição |
|---|---|
eventhub.enqueued.timestamp |
A hora (em milissegundos desde a época, UTC) em que a mensagem foi enfileirada no hub de eventos |
eventhub.offset |
O deslocamento na partição em que a mensagem foi armazenada |
eventhub.sequence |
O número de sequência do Azure associado à mensagem |
eventhub.name |
O nome do hub de eventos do qual a mensagem foi extraída |
eventhub.partition |
O nome da partição do hub de eventos da qual a mensagem foi extraída |
eventhub.property.* |
As propriedades do aplicativo dessa mensagem. IE: “application” seria “eventhub.property.application” |