PutRecord 2025.5.31.15

捆绑包

org.apache.nifi | nifi-standard-nar

描述

PutRecord 处理器使用指定的 RecordReader 从传入 FlowFile 中输入(可能包含多条)记录,并将其发送到 Record Destination Service(即记录接收器)指定的目标位置。

标签

put、record、sink

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

put-record-include-zero-record-results

如果从传入的 FlowFile 中未读取到任何记录,此属性指定是否传输空记录集。原始 FlowFile 仍会路由到 success 关系,但如果未发生传输,则不会生成溯源 SEND 事件。

put-record-reader

指定用于读取传入数据的控制器服务

put-record-sink

指定用于将查询结果记录写入某个目标位置的控制器服务。

关系

名称

描述

failure

如果无法传输记录,则将 FlowFile 路由到此关系,重试该操作也会失败

retry

如果无法传输记录,则将原始 FlowFile 路由到此关系,但再次尝试操作可能会成功

success

如果成功传输记录,原始 FlowFile 将路由到此关系

语言: 中文