RetryFlowFile 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
FlowFiles 传递给此处理器时，会根据配置的“尝试次数上限”值检查“重试属性”值。如果当前属性值低于配置的最大值，则 FlowFile 会将其传递到“retry”关系。在这种情况下，FlowFile 可能会受到惩罚，也可能不会受到惩罚。如果 FlowFile 的属性值超过配置的最大值，则 FlowFile将传递到“retries_exceeded”关系。WARNING：如果传入 FlowFile 所配置的“重试属性”属性中有非数字值，则该值将重置为“1”。您可以选择使 FlowFile 的操作失败，而不是执行重置操作。可通过动态属性为传递到“retries_exceeded”关系的 FlowFiles 添加任意属性。这些属性支持属性表达式语言。
输入要求¶
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 是哪个处理器 |