JoltTransformRecord

JoltTransformRecord Processor

类型全限定名：cn.org.acal.lynxus.processors.jolt.JoltTransformRecord

所属 Bundle：cn.org.acal.lynxus:lynxus-jolt-nar:2.11.8

描述

将 JOLT 规范应用于 FlowFile 负载中的每条记录。使用转换后的内容创建一个新的 FlowFile，并将其路由到“成功”关系。如果转换失败，原始 FlowFile 将路由到“失败”关系。

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称	默认值	可选值	描述
Jolt Transform	`jolt-transform-chain`	Shift — 移位（Shift）输入 JSON/数据以创建输出 JSON。 Chain — 执行 Jolt 转换列表。 Default — 对输出 JSON 应用默认值。 Remove — 从输入数据中移除值以创建输出 JSON。 Cardinality — 更改输入元素的基数（cardinality）以创建输出 JSON。 Sort — 按字母顺序对输入 json 键值排序。忽略任何已设置的规范。 Custom — 自定义转换。需要自定义转换类名（Custom Transformation Class Name） Modify - Default — 当键缺失或值为 null 时写入 Modify - Overwrite — 始终覆盖值 Modify - Define — 当键缺失时写入	指定应与所提供的规范一起使用的摇动变换。
Jolt Specification			用于 JSON 数据转换的 Jolt 规范。此属性的值可以是 Jolt 规范的文本或包含 Jolt 规范的文件路径。必须设置 'Jolt 规范'，否则如果选择了 Jolt Sort 转换，则忽略该值。支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Custom Transformation Class Name			用于自定义转换的完全限定类名称支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Custom Module Directory			以逗号分隔的文件和/或目录路径列表，其中包含包含自定义转换的模块（不包含在 Lynxus 的类路径中）。支持表达式语言：是（仅使用环境/系统变量求值）
Transform Cache Size	`1`		编译 Jolt 转换可能相当昂贵。理想情况下，这应该只执行一次。但是，如果转换中使用了 Expression Language，我们可能需要为每个 FlowFile 使用新的转换。此值控制我们在内存中缓存多少个这样的转换，以避免每次都必须编译转换。
Record Reader		控制器服务 API： `RecordReaderFactory` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	指定用于解析传入数据并确定数据模式的 Controller Service。
Record Writer		控制器服务 API： `RecordSetWriterFactory` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	指定用于写出记录的 Controller Service

关系 (Relationships)

名称	描述	自动终止
`failure`	如果 FlowFile 由于任何原因处理失败（例如，无法解析 FlowFile 记录），它将被路由到此关系	否
`original`	转换后的原始 FlowFile。如果 FlowFile 处理失败，则不会向此关系发送任何内容	否
`success`	具有转换内容的 FlowFile 将被路由到此关系	否

写入的 FlowFile 属性

名称	描述
`record.count`	传出 FlowFile 中的记录数
`mime.type`	配置的Record Writer指示的 MIME 类型是适当的

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。