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.
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. |