RetryFlowFile 2025.10.2.19

捆绑包

org.apache.nifi | nifi-standard-nar

描述

FlowFiles passed to this Processor have a 'Retry Attribute' value checked against a configured 'Maximum Retries' value. If the current attribute value is below the configured maximum, the FlowFile is passed to a retry relationship. The FlowFile may or may not be penalized in that condition. If the FlowFile 's attribute value exceeds the configured maximum, the FlowFile will be passed to a' retries_exceeded 'relationship. WARNING: If the incoming FlowFile has a non-numeric value in the configured'Retry Attribute 'attribute, it will be reset to'1 '. You may choose to fail the FlowFile instead of performing the reset. Additional dynamic properties can be defined for any attributes you wish to add to the FlowFiles transferred to' retries_exceeded'. These attributes support attribute expression language.

标签

FlowFile, Retry

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

非数字覆盖失败

如果 FlowFile 已经在“重试属性”中定义了 *非* 数字的属性,请使 FlowFile 失败而不是将该值重置为“1”

maximum-retries

在传递到“retries_exceeded”关系之前,FlowFile 可以重试的最大次数

penalize-retries

如果设置为“true”,处理器会在将 FlowFiles 传递到“retry”关系前对其进行惩罚这不适用于“retries_exceeded”关系。

retry-attribute

包含 FlowFile 当前重试次数的属性的名称。WARNING:如果该名称与 FlowFile 上已有的不包含数值的属性相匹配,则处理器要么使用“1”覆盖该属性,要么根据配置失败。

reuse-mode

定义当重试 FlowFile 的重试 UUID 不同于接收 FlowFile 的实例时,处理器的行为方式。这通常意味着该处理器的先前实例成功重试该属性后未重置。

关系

名称

描述

failure

处理器已配置为:当“重试属性”值为非数值时直接判定失败,而非将其重置为“1”。这将立即终止有限的反馈循环。也可能因“重试次数上限”包含无法解析为整数的属性表达式语言时触发。

retries_exceeded

输入 FlowFile 已超过配置的最大重试次数,请勿将此关系传回输入处理器以终止有限的反馈循环。

retry

输入 FlowFile 未超过配置的最大重试次数,将此关系传回输入处理器以创建有限的反馈循环。

写入属性

名称

描述

Retry Attribute

使用当前重试次数更新用户定义的重试属性

Retry Attribute .uuid

用户使用 .uuid 定义的重试属性,用于确定上次重试的 FlowFile 是哪个处理器

语言: 中文