DebugFlow 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Description¶

Le processeur DebugFlow facilite les tests et le débogage du cadre FlowFile en permettant de déclencher explicitement diverses réponses suite à la réception d’un FlowFile ou d’un événement de temporisateur sans FlowFile si vous utilisez une planification basée sur un temporisateur ou sur cron. Il peut forcer les réponses nécessaires à pratiquer ou tester différents modes d’échec susceptibles de se produire lors de l’exécution d’un processeur.

Balises¶

FlowFile, déboguer, flux, processeur, test, utilitaire

Exigences en matière d’entrées¶

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
@OnScheduled Pause Time	Spécifie la durée de sommeil du processeur dans la méthode @OnScheduled, de sorte que le processeur puisse être forcé à mettre beaucoup de temps à démarrer
@OnStopped Pause Time	Spécifie la durée de sommeil du processeur dans la méthode @OnStopped, de sorte que le processeur puisse être forcé à mettre beaucoup de temps à fermer
@OnUnscheduled Pause Time	Spécifie la durée de sommeil du processeur dans la méthode @OnUnscheduled, de sorte que le processeur puisse être forcé à mettre beaucoup de temps à répondre lorsque l’utilisateur clique sur Stop
Content Size	Nombre d’octets à écrire chaque fois qu’une écriture est effectuée dans le FlowFile
CustomValidate Pause Time	Spécifie la durée de sommeil du processeur dans la méthode customValidate()
Fail When @OnScheduled called	Indique si le processeur doit ou non lancer une exception lorsque les méthodes annotées à l’aide de @OnScheduled sont appelées
Fail When @OnStopped called	Indique si le processeur doit ou non lancer une exception lorsque les méthodes annotées à l’aide de @OnStopped sont appelées
Fail When @OnUnscheduled called	Indique si le processeur doit ou non lancer une exception lorsque les méthodes annotées à l’aide de @OnUnscheduled sont appelées
FlowFile Exception Class	Classe d’exception à lancer (doit étendre java.lang.RuntimeException).
FlowFile Exception Iterations	Nombre de FlowFiles pour lancer une exception.
FlowFile Failure Iterations	Nombre de FlowFiles à transmettre à la relation d’échec.
FlowFile Rollback Iterations	Nombre de FlowFiles à restaurer (sans pénalité).
FlowFile Rollback Penalty Iterations	Nombre de FlowFiles à restaurer avec pénalité.
FlowFile Rollback Yield Iterations	Nombre de FlowFiles à restaurer et dont cesser temporairement l’exécution.
FlowFile Success Iterations	Nombre de FlowFiles à transmettre à la relation de réussite.
Ignore Interrupts When Paused	Si le ou les threads du processeur dorment (en raison de l’une des propriétés « Pause Time » ci-dessus) et que le thread est interrompu, ceci indique si le processeur doit ignorer l’interruption et continuer à dormir ou s’il doit s’autoriser à être interrompu.
No FlowFile Exception Class	Classe d’exception à lancer en cas d’absence de FlowFile (doit étendre java.lang.RuntimeException).
No FlowFile Exception Iterations	Nombre de fois où lancer l’exception NPE en l’absence de FlowFile.
No FlowFile Skip Iterations	Nombre de fois où ignorer onTrigger en l’absence de FlowFile.
No FlowFile Yield Iterations	Nombre de fois où cesser temporairement l’exécution en l’absence de FlowFile.
OnTrigger Pause Time	Spécifie la durée de sommeil du processeur dans la méthode onTrigger(), de sorte que le processeur puisse être forcé à mettre beaucoup de temps à effectuer sa tâche
Write Iterations	Nombre de fois où écrire dans le FlowFile

Relations¶

Nom	Description
failure	FlowFiles qui n’ont pas pu être traités.
success	FlowFiles correctement traités.