Notify 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Armazena em cache um identificador de sinal de liberação no cache distribuído, opcionalmente junto com os atributos do FlowFile. Todos os FlowFiles mantidos em um processador de espera correspondente serão liberados assim que esse sinal no cache for descoberto.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
attribute-cache-regex |
Quaisquer atributos cujos nomes correspondam a essa regex serão armazenados no cache distribuído para serem copiados para quaisquer FlowFiles liberados de um processador de espera correspondente. Observe que o atributo uuid não será armazenado em cache independentemente desse valor. Se estiver em branco, nenhum atributo será armazenado em cache. |
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. |