DebugFlow 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-standard-nar

描述¶

DebugFlow 处理器可以帮助测试和调试 FlowFile 框架：它允许在收到 FlowFile 时，或者在使用计时器或基于 cron 的调度的情况下收到计时器事件（无需 FlowFile）时，明确触发各种响应。该处理器可强制触发响应，用于模拟或测试处理器运行时可能出现的各种故障模式。

标签¶

FlowFile、debug、flow、processor、test、utility

输入要求¶

支持敏感的动态属性¶

false

属性¶

属性	描述
@OnScheduled 暂停时间	在 @OnScheduled 方法中指定处理器应休眠多长时间，以强制延长处理器的启动时间
@OnStopped 暂停时间	在 @OnStopped 方法中指定处理器应休眠多长时间，以强制延长处理器的关闭时间
@OnUnscheduled 暂停时间	在 @OnUnscheduled 方法中指定处理器应休眠多长时间，以便当用户点击“Stop”时，强制延长处理器的响应时间
内容大小	每次写入 FlowFile 时要写入的字节数
CustomValidate 暂停时间	在 customValidate () 方法中指定处理器应休眠多长时间
调用 @OnScheduled 时失败	指定在调用带有 @OnScheduled 注解的方法时处理器是否应抛出异常
调用 @OnStopped 时失败	指定在调用带有 @OnStopped 注解的方法时处理器是否应抛出异常
调用 @OnUnscheduled 时失败	指定在调用带有 @OnUnscheduled 注解的方法时处理器是否应抛出异常
FlowFile 异常类	要抛出的异常类（必须继承 java.lang.RuntimeException）。
FlowFile 异常迭代	抛出异常的 FlowFiles 数量。
FlowFile 失败迭代	要转发到 failure 关系的 FlowFiles 数量。
FlowFile 回滚迭代	要回滚的 FlowFiles 数量（无惩罚）。
FlowFile 回滚惩罚迭代	要带惩罚回滚的 FlowFiles 数量。
FlowFile 回滚释放迭代	要回滚并释放的 FlowFiles 数量。
FlowFile 成功迭代	要转发到 success 关系的 FlowFiles 数量。
暂停时忽略中断	当处理器的线程因上述“暂停时间”属性之一而处于休眠状态时，如果线程被中断，此参数决定处理器是应忽略中断继续休眠，还是接受中断终止休眠。
没有 FlowFile 异常类	在没有 FlowFile 的情况下抛出的异常类（必须继承 java.lang.RuntimeException）。
没有 FlowFile 异常迭代	在没有 FlowFile 的情况下抛出 NPE 异常的次数。
没有 FlowFile 跳过迭代	在没有 FlowFile 的情况下跳过 onTrigger 的次数。
没有 FlowFile 释放迭代	在没有 FlowFile 的情况下释放的次数。
OnTrigger 暂停时间	在 onTrigger() 方法中，指定处理器应休眠多长时间，以强制延长处理器执行其任务的时间
写入迭代	写入 FlowFile 的次数

关系¶

名称	描述
failure	处理失败的 FlowFiles。
success	处理成功的 FlowFiles。