UpdateRecord 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
更新包含面向记录的数据（即可通过 RecordReader 读取并由 RecordWriter 写入的数据）的 FlowFile 的内容。此处理器要求至少添加一个用户定义的属性。该属性的名称应指明决定 RecordPath 应更新的字段。该属性的值要么是替换值（可以选择使用表达式语言），要么本身就是从记录中提取值的 RecordPath。属性值是确定为 RecordPath 或字面量值取决于 <Replacement Value Strategy> 属性的配置。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
记录读取器 |
指定用于读取传入数据的控制器服务 |
记录写入器 |
指定用于写出记录的控制器服务 |
替换值策略 |
指定如何解释配置的替换值 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果 FlowFile 无法从配置的输入格式转换为配置的输出格式，则未更改的 FlowFile 将路由到此关系 |
success |
成功转换的 FlowFiles 将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
record.index |
此属性提供当前行索引，仅在字面量值表达式中可用。 |
record.error.message |
此属性提供失败时读取器或写入器遇到的错误消息。 |
用例¶
将多个字段合并为一个字段。 |
将记录字段的值更改为显式值。 |
将一个记录字段的值复制到另一个记录字段。 |
通过向每条记录注入属性的值来丰富数据。 |
更改记录字段值的格式。 |