RetryFlowFile Processor
描述
传递到该处理器的FlowFile具有根据配置的“最大重试次数”值检查的“重试属性”值。 如果当前属性值低于配置的最大值,则 FlowFile 将传递到重试关系。 在这种情况下,FlowFile 可能会或可能不会受到惩罚。 如果 FlowFile 的属性值超过配置的最大值,则 FlowFile 将被传递到“retries_exceeded”关系。 警告:如果传入的 FlowFile 在配置的“重试属性”属性中具有非数字值,则会将其重置为“1”。 您可以选择使 FlowFile 失败而不是执行重置。 可以为您希望添加到传输到“retries_exceeded”的 FlowFiles 的任何属性定义其他动态属性。 这些属性支持属性表达语言。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Retry Attribute | flowfile.retries | 指定包含 FlowFile 当前重试计数的属性名称。警告:如果名称与 FlowFile 上已存在的属性匹配,且该属性不包含数值,则处理器将根据配置用 '1' 覆盖该属性或使处理失败。 支持表达式语言:是(仅使用环境/系统变量求值) | |
| Maximum Retries | 3 | FlowFile 在被传递到 'retries_exceeded' 关系之前可以重试的最大次数 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Penalize Retries | true |
| 如果设置为 'true',此处理器在将输入 FlowFile 传递到 'retry' 关系之前会对其进行惩罚。这不适用于 'retries_exceeded' 关系。 |
| Fail on Nonnumerical Overwrite | false |
| 如果 FlowFile 已经具有'重试属性'中定义的属性且该属性*不是*数字,则使 FlowFile 失败,而不是将该值重置为 '1' |
| Reuse Mode | fail |
| 定义当重试 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)
该组件不受限。
输入要求
该组件要求有传入连接。