ConvertRecord 2025.5.31.15

捆绑包

org.apache.nifi | nifi-standard-nar

描述

使用配置的记录读取器和记录写入控制器服务将记录从一种数据格式转换为另一种数据格式。读取器和写入器必须使用“匹配的”架构进行配置。我们的意思是架构必须具有相同的字段名称。如果可以将字段值从一种类型强制转换为另一种类型,则字段的类型不必相同。例如,如果输入架构具有名为“balance”且类型为双精度的字段,则输出架构可以有一个名为“balance”的字段,其类型可以是字符串、双精度或浮点数。如果输入中存在字段,但输出中不存在该字段,则这些字段将在输出中被省略。如果在输出架构中指定了某字段,但输入数据/架构中不存在该字段,则该字段将不存在于输出中或将为空值,具体取决于写入器。

标签

avro、convert、csv、freeform、generic、json、log、logs、record、schema、text

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

包括零记录 FlowFiles

转换传入的 FlowFile 时,如果转换没有产生任何数据,则此属性指定 FlowFile 是否将发送到相应的关系

记录读取器

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

记录写入器

指定用于写出记录的控制器服务

关系

名称

描述

failure

如果 FlowFile 无法从配置的输入格式转换为配置的输出格式,则未更改的 FlowFile 将路由到此关系

success

成功转换的 FlowFiles 将路由到此关系

写入属性

名称

描述

mime.type

将 mime.type 属性设置为记录写入器指定的 MIME 类型

record.count

FlowFile 中的记录数

record.error.message

此属性提供失败时读取器或写入器遇到的错误消息。

用例

将数据从一种面向记录的格式转换为另一种格式

语言: 中文