DebugFlow

包

org.apache.nifi | nifi-standard-nar

描述

DebugFlow处理器有助于测试和调试FlowFile框架，它可以在接收到FlowFile时，或者在使用基于定时器或cron的调度时，在没有FlowFile的定时器事件触发时，显式地触发各种响应。它可以强制产生处理器运行时可能出现的各种故障模式所需的响应，以便进行演练或测试。

标签

FlowFile、调试、流程、处理器、测试、实用工具

输入要求

支持敏感动态属性：否

DebugFlow 2.2.0的其他详细信息

DebugFlow处理器被触发时，会遍历相应的响应列表。在处理器运行期间，每次遍历响应列表时，都会按照配置的次数生成响应。

当由FlowFile触发时，处理器可以产生以下响应：
a. 将FlowFile传输到成功关系。
b. 将FlowFile传输到失败关系。
c. 无惩罚地回滚FlowFile。
d. 回滚FlowFile并让出上下文。
e. 有惩罚地回滚FlowFile。
f. 抛出异常。

当没有FlowFile触发时，处理器可以产生以下响应：
a. 不执行任何操作并返回。
b. 抛出异常。
c. 让出上下文。

属性

• @OnScheduled暂停时间：指定处理器在@OnScheduled方法中应休眠的时长，这样可以强制处理器启动时间变长。

• 显示名称：@OnScheduled暂停时间
• 描述：指定处理器在@OnScheduled方法中应休眠的时长，这样可以强制处理器启动时间变长
• API名称：@OnScheduled暂停时间
• 默认值：0秒
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• @OnStopped暂停时间：指定处理器在@OnStopped方法中应休眠的时长，这样可以强制处理器关闭时间变长。

• 显示名称：@OnStopped暂停时间
• 描述：指定处理器在@OnStopped方法中应休眠的时长，这样可以强制处理器关闭时间变长
• API名称：@OnStopped暂停时间
• 默认值：0秒
• 表达式语言作用域：JVM级别定义的环境变量和系统属性
• 是否敏感：否
• 是否必需：是

• @OnUnscheduled暂停时间：指定处理器在@OnUnscheduled方法中应休眠的时长，这样当用户点击停止时，处理器可以被强制响应时间变长。

• 显示名称：@OnUnscheduled暂停时间
• 描述：指定处理器在@OnUnscheduled方法中应休眠的时长，这样当用户点击停止时，处理器可以被强制响应时间变长
• API名称：@OnUnscheduled暂停时间
• 默认值：0秒
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• 内容大小：每次写入FlowFile时写入的字节数。

• 显示名称：内容大小
• 描述：每次写入FlowFile时写入的字节数
• API名称：内容大小
• 默认值：1KB
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• CustomValidate暂停时间：指定处理器在customValidate()方法中应休眠的时长。

• 显示名称：CustomValidate暂停时间
• 描述：指定处理器在customValidate()方法中应休眠的时长
• API名称：CustomValidate暂停时间
• 默认值：0秒
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• @OnScheduled调用时失败：指定当调用用@OnScheduled注解的方法时，处理器是否应抛出异常。

• 显示名称：@OnScheduled调用时失败
• 描述：指定当调用用@OnScheduled注解的方法时，处理器是否应抛出异常
• API名称：@OnScheduled调用时失败
• 默认值：否
• 允许值：

• 是
• 否

• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• @OnStopped调用时失败：指定当调用用@OnStopped注解的方法时，处理器是否应抛出异常。

• 显示名称：@OnStopped调用时失败
• 描述：指定当调用用@OnStopped注解的方法时，处理器是否应抛出异常
• API名称：@OnStopped调用时失败
• 默认值：否
• 允许值：

• 是
• 否

• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• @OnUnscheduled调用时失败：指定当调用用@OnUnscheduled注解的方法时，处理器是否应抛出异常。

• 显示名称：@OnUnscheduled调用时失败
• 描述：指定当调用用@OnUnscheduled注解的方法时，处理器是否应抛出异常
• API名称：@OnUnscheduled调用时失败
• 默认值：否
• 允许值：

• 是
• 否

• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• FlowFile异常类：要抛出的异常类（必须继承java.lang.RuntimeException）。

• 显示名称：FlowFile异常类
• 描述：要抛出的异常类（必须继承java.lang.RuntimeException）
• API名称：FlowFile异常类
• 默认值：java.lang.RuntimeException
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• FlowFile异常迭代次数：抛出异常的FlowFile数量。

• 显示名称：FlowFile异常迭代次数
• 描述：抛出异常的FlowFile数量
• API名称：FlowFile异常迭代次数
• 默认值：0
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• FlowFile失败迭代次数：转发到失败关系的FlowFile数量。

• 显示名称：FlowFile失败迭代次数
• 描述：转发到失败关系的FlowFile数量
• API名称：FlowFile失败迭代次数
• 默认值：0
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• FlowFile回滚迭代次数：无惩罚回滚的FlowFile数量。

• 显示名称：FlowFile回滚迭代次数
• 描述：无惩罚回滚的FlowFile数量
• API名称：FlowFile回滚迭代次数
• 默认值：0
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• FlowFile惩罚回滚迭代次数：有惩罚回滚的FlowFile数量。

• 显示名称：FlowFile惩罚回滚迭代次数
• 描述：有惩罚回滚的FlowFile数量
• API名称：FlowFile惩罚回滚迭代次数
• 默认值：0
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• FlowFile回滚并让出迭代次数：回滚并让出的FlowFile数量。

• 显示名称：FlowFile回滚并让出迭代次数
• 描述：回滚并让出的FlowFile数量
• API名称：FlowFile回滚并让出迭代次数
• 默认值：0
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• FlowFile成功迭代次数：转发到成功关系的FlowFile数量。

• 显示名称：FlowFile成功迭代次数
• 描述：转发到成功关系的FlowFile数量
• API名称：FlowFile成功迭代次数
• 默认值：1
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• 暂停时忽略中断：如果处理器的线程（由于上述“暂停时间”属性之一）正在休眠，并且线程被中断，这表明处理器是应忽略中断并继续休眠，还是应允许自己被中断。

• 显示名称：暂停时忽略中断
• 描述：如果处理器的线程（由于上述“暂停时间”属性之一）正在休眠，并且线程被中断，这表明处理器是应忽略中断并继续休眠，还是应允许自己被中断
• API名称：暂停时忽略中断
• 默认值：否
• 允许值：

• 是
• 否

• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• 无FlowFile异常类：如果没有FlowFile时要抛出的异常类（必须继承java.lang.RuntimeException）。

• 显示名称：无FlowFile异常类
• 描述：如果没有FlowFile时要抛出的异常类（必须继承java.lang.RuntimeException）
• API名称：无FlowFile异常类
• 默认值：java.lang.RuntimeException
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• 无FlowFile异常迭代次数：如果没有FlowFile，抛出空指针异常的次数。

• 显示名称：无FlowFile异常迭代次数
• 描述：如果没有FlowFile，抛出空指针异常的次数
• API名称：无FlowFile异常迭代次数
• 默认值：0
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• 无FlowFile跳过触发次数：如果没有FlowFile，跳过onTrigger的次数。

• 显示名称：无FlowFile跳过触发次数
• 描述：如果没有FlowFile，跳过onTrigger的次数
• API名称：无FlowFile跳过触发次数
• 默认值：1
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• 无FlowFile让出迭代次数：如果没有FlowFile，让出的次数。

• 显示名称：无FlowFile让出迭代次数
• 描述：如果没有FlowFile，让出的次数
• API名称：无FlowFile让出迭代次数
• 默认值：0
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• OnTrigger暂停时间：指定处理器在onTrigger()方法中应休眠的时长，这样可以强制处理器执行任务的时间变长。

• 显示名称：OnTrigger暂停时间
• 描述：指定处理器在onTrigger()方法中应休眠的时长，这样可以强制处理器执行任务的时间变长
• API名称：OnTrigger暂停时间
• 默认值：0秒
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

• 写入迭代次数：写入FlowFile的次数。

• 显示名称：写入迭代次数
• 描述：写入FlowFile的次数
• API名称：写入迭代次数
• 默认值：0
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必需：是

关系