DebugFlow 2025.5.31.15

Pacote

org.apache.nifi | nifi-standard-nar

Descrição

O processador DebugFlow auxilia nos testes e na depuração da estrutura FlowFile, permitindo que várias respostas sejam explicitamente acionadas em resposta ao recebimento de um evento FlowFile ou de um evento de cronômetro sem um FlowFile se estiver usando cronômetro ou agendamento baseado em cron. Ele pode forçar as respostas necessárias para exercitar ou testar vários modos de falha que possam ocorrer quando um processador é executado.

Tags

FlowFile, depuração, fluxo, processador, teste, utilitário

Requisito de entrada

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

Tempo de pausa @OnScheduled

Especifica por quanto tempo o processador deve ficar em espera no método @OnScheduled, de modo que o processador possa ser forçado a levar um longo tempo para iniciar

Tempo de pausa @OnStopped

Especifica por quanto tempo o processador deve ficar em espera no método @OnStopped, de modo que o processador possa ser forçado a levar muito tempo para ser desligado

Tempo de pausa @OnUnscheduled

Especifica por quanto tempo o processador deve ficar em espera no método @OnUnscheduled, de modo que o processador possa ser forçado a demorar muito tempo para responder quando o usuário clicar em parar

Tamanho do conteúdo

O número de bytes a serem gravados sempre que o FlowFile for gravado

Tempo de pausa CustomValidate

Especifica por quanto tempo o processador deve ficar em espera no método customValidate()

Falhar quando @OnScheduled for chamado

Especifica se o processador deve ou não gerar uma exceção quando os métodos anotados com @OnScheduled forem chamados

Falhar quando @OnStopped for chamado

Especifica se o processador deve ou não gerar uma exceção quando os métodos anotados com @OnStopped forem chamados

Falhar quando @OnUnscheduled for chamado

Especifica se o processador deve ou não gerar uma exceção quando os métodos anotados com @OnUnscheduled forem chamados

Classe de exceção de FlowFile

Classe de exceção a ser gerada (deve estender java.lang.RuntimeException).

Iterações de exceção de FlowFile

Número de FlowFiles para lançar a exceção.

Iterações de falha de FlowFile

Número de FlowFiles para encaminhar ao relacionamento de falha.

Iterações de reversão de FlowFile

Número de FlowFiles para reverter (sem penalidade).

Iterações de penalidade de reversão de FlowFile

Número de FlowFiles para reverter com penalidade.

Iterações de rendimento de reversão de FlowFile

Número de FlowFiles para reverter e adiar.

Iterações de sucesso de FlowFile

Número de FlowFiles para encaminhar à relação de sucesso.

Ignorar interrupções quando em pausa

Se o(s) thread(s) do processador estiver(em) em espera (devido a uma das propriedades de “Tempo de pausa” acima) e o thread for interrompido, isso indica se o processador deve ignorar a interrupção e continuar dormindo ou se deve se permitir ser interrompido.

Classe de exceção sem FlowFile

Classe de exceção a ser gerada se não houver FlowFile (deve estender java.lang.RuntimeException).

Iterações de exceção sem FlowFile

Número de vezes para gerar a exceção NPE se não houver FlowFile.

Iterações ignoradas sem FlowFile

Número de vezes para ignorar o onTrigger se não houver FlowFile.

Iterações de adiamento sem FlowFile

Número de vezes para adiar se não houver FlowFile.

Tempo de pausa OnTrigger

Especifica por quanto tempo o processador deve ficar em espera no método onTrigger(), de modo que o processador possa ser forçado a levar um longo tempo para executar sua tarefa

Iterações de gravação

Número de vezes para gravar no FlowFile

Relações

Nome

Descrição

failure

FlowFiles que não foram processados.

success

FlowFiles processados com sucesso.