RetryFlowFile

文档中心 › 组件索引 › RetryFlowFile

RetryFlowFile Processor

类型全限定名:cn.org.acal.lynxus.processors.standard.RetryFlowFile

所属 Bundle:cn.org.acal.lynxus:lynxus-standard-nar:2.11.8

描述

传递到该处理器的FlowFile具有根据配置的“最大重试次数”值检查的“重试属性”值。 如果当前属性值低于配置的最大值,则 FlowFile 将传递到重试关系。 在这种情况下,FlowFile 可能会或可能不会受到惩罚。 如果 FlowFile 的属性值超过配置的最大值,则 FlowFile 将被传递到“retries_exceeded”关系。 警告:如果传入的 FlowFile 在配置的“重试属性”属性中具有非数字值,则会将其重置为“1”。 您可以选择使 FlowFile 失败而不是执行重置。 可以为您希望添加到传输到“retries_exceeded”的 FlowFiles 的任何属性定义其他动态属性。 这些属性支持属性表达语言。

标签

RetryFlowFile

属性

下表中,加粗的属性为必填项;其余为可选项。表格同时标注默认值、是否支持表达式语言,以及是否为敏感属性(值会被加密)。

名称默认值可选值描述
Retry Attributeflowfile.retries指定包含 FlowFile 当前重试计数的属性名称。警告:如果名称与 FlowFile 上已存在的属性匹配,且该属性不包含数值,则处理器将根据配置用 '1' 覆盖该属性或使处理失败。
支持表达式语言:是(仅使用环境/系统变量求值)
Maximum Retries3FlowFile 在被传递到 'retries_exceeded' 关系之前可以重试的最大次数
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Penalize Retriestrue
  • true
  • false
如果设置为 'true',此处理器在将输入 FlowFile 传递到 'retry' 关系之前会对其进行惩罚。这不适用于 'retries_exceeded' 关系。
Fail on Nonnumerical Overwritefalse
  • true
  • false
如果 FlowFile 已经具有'重试属性'中定义的属性且该属性*不是*数字,则使 FlowFile 失败,而不是将该值重置为 '1'
Reuse Modefail
  • Fail on Reuse — 如果 RetryFlowFile 的 UUID 与 FlowFile 的重试 UUID 不匹配,则使 FlowFile 失败,无论当前重试次数如何
  • Warn on Reuse — 如果 RetryFlowFile 的 UUID 与 FlowFile 的重试 UUID 不匹配,则在为此实例重置重试属性和 UUID 之前记录一条警告消息
  • Reset Reuse — 如果 RetryFlowFile 的 UUID 与 FlowFile 的重试 UUID 不匹配,则在为此实例重置重试属性和 UUID 之前记录一条调试消息
定义当重试 FlowFile 具有与接收该 FlowFile 的实例不同的重试 UUID 时处理器的行为。这通常意味着该属性在之前的处理器实例成功重试后未被重置。

动态属性

动态属性允许用户自定义属性的名称与值。

名称值描述
超出重试次数时的 FlowFile 属性键添加到 FlowFile 的属性的值一个或多个动态属性可用于向传递到 'retries_exceeded' 关系的 FlowFile 添加属性

关系 (Relationships)

名称描述自动终止
failure处理器配置为当 'Retry Attribute' 上的值为非数字时导致失败而不是将该值重置为 '1'。这将立即终止有限的反馈循环。也可能包括当 'Maximum Retries' 包含无法解析为整数的属性表达式语言时。是
retries_exceeded当输入 FlowFile 已超过配置的最大重试次数时,不通过此关系将 FlowFile 传递回输入处理器以终止有限的反馈循环。否
retry当输入 FlowFile 未超过配置的最大重试次数时,通过此关系将 FlowFile 传递回输入处理器以创建有限的反馈循环。否

读取的 FlowFile 属性

名称描述
Retry Attribute将读取 'Retry Attribute' 中定义的属性或属性表达式语言结果

写入的 FlowFile 属性

名称描述
Retry Attribute用户定义的重试属性将更新为当前重试次数
Retry Attribute .uuid用户定义的重试属性(带 .uuid),确定哪个处理器最后重试了 FlowFile

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。