Notify 2025.10.2.19

Pacote

org.apache.nifi | nifi-standard-nar

Descrição

Caches a release signal identifier in the distributed cache, optionally along with the FlowFile’s attributes. Any flow files held at a corresponding Wait processor will be released once this signal in the cache is discovered.

Tags

cache, distributed, map, notify, release, signal

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

attribute-cache-regex

Any attributes whose names match this regex will be stored in the distributed cache to be copied to any FlowFiles released from a corresponding Wait processor. Note that the uuid attribute will not be cached regardless of this value. If blank, no attributes will be cached.

distributed-cache-service

O Controller Service usado para armazenar em cache os sinais de liberação a fim de liberar arquivos enfileirados em um processador de espera correspondente

release-signal-id

Um valor ou os resultados de uma instrução de linguagem de expressão de atributos que será avaliado em relação a um FlowFile para determinar a chave de cache do sinal de liberação

signal-buffer-count

Especifique o número máximo de FlowFiles de entrada que podem ser armazenados em buffer até que os sinais sejam notificados ao serviço de cache. Quanto maior o buffer, melhor o desempenho, pois ele reduz o número de interações com o serviço de cache agrupando os sinais por identificador de sinal quando vários FlowFiles de entrada compartilham o mesmo identificador de sinal.

signal-counter-delta

Um valor, ou os resultados de uma instrução de linguagem de expressão de atributo, que será avaliado em relação a um FlowFile para determinar o delta do contador de sinais. Especifique o quanto o contador deve aumentar. Por exemplo, se vários eventos de sinal forem processados no fluxo upstream de forma orientada por lote, o número de eventos processados poderá ser notificado com essa propriedade de uma só vez. Zero (0) tem um significado especial, pois limpa a contagem de destino de volta para 0, o que é especialmente útil quando usado com o modo Aguardar contagem de FlowFile liberáveis = zero (0), para fornecer controle de fluxo do tipo “open-close-gate”. Um (1) pode abrir um processador de espera correspondente e zero (0) pode negá-lo, como se estivesse fechando um portão.

signal-counter-name

Um valor ou os resultados de uma instrução de linguagem de expressão de atributo que será avaliado em relação a um FlowFile para determinar o nome do contador de sinais. O nome do contador de sinais é útil quando um processador de espera correspondente precisa saber o número de ocorrências de diferentes tipos de eventos, como sucesso ou falha, ou nomes de fontes de dados de destino etc.

Relações

Nome

Descrição

failure

Quando não for possível acessar o cache ou se o Identificador de sinal de liberação (Release Signal Identifier) for avaliado como nulo ou vazio, os FlowFiles serão encaminhados para essa relação

success

Todos os FlowFiles em que o sinal de liberação foi inserido com sucesso no cache serão encaminhados para essa relação

Grava atributos

Nome

Descrição

notified

Todos os FlowFiles terão um atributo “notified”. O valor desse atributo é verdadeiro se o FlowFile for notificado; caso contrário, é falso.

Consulte também