ScriptedTransformRecord
描述:
提供针对传入FlowFile中的每个记录计算简单脚本的能力。脚本可以以某种方式转换记录、过滤记录或分叉其他记录。
标签:
record, jolt, transform, script, groovy, jython, python, update, modify, filter
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 记录读取者 | 控制器服务API: RecordReaderFactory 实现: ParquetReader GrokReader SyslogReader Syslog5424Reader CSVReader AvroReader JsonPathReader JsonTreeReader ScriptedReader XMLReader | 指定用于读取输入数据的控制器服务。 | |
| 记录写入者 | 控制器服务API: RecordSetWriterFactory 实现: CSVRecordSetWriter FreeFormTextRecordSetWriter AvroRecordSetWriter JsonRecordSetWriter XMLRecordSetWriter ParquetRecordSetWriter ScriptedRecordSetWriter | 指定用于写入记录的控制器服务。 | |
| 脚本引擎 | Groovy | - Clojure - ECMAScript - Groovy - Lua - Python - Ruby | 用于执行脚本的引擎 |
| 脚本内容 | 指定用于执行的脚本内容。与<脚本文件>参数互斥，只能使用一个 | ||
| 脚本文件 | 指定用于执行的脚本文件路径。与<脚本内容>参数互斥，只能使用一个 支持表达式语言 (仅支持变量) | ||
| 依赖库 | 用逗号分隔的多个包含脚本依赖的文件或文件夹路径 支持表达式语言 (仅支持变量) |
连线:
| 名字 | 描述 |
|---|---|
| success | 成功转换Record数据后，新的Record数据输出到该成功连线 |
| failure | 如果由于任何原因导致转换失败，比如非Record数据，将原始数据输出到该失败连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| mime.type | 设置记录写入器处理的MIME类型。 |
| record.count | 流出的FlowFile中的记录数 |
| record.error.message | 此属性在失败时提供Reader或Writer遇到的错误消息。 |
状态管理:
该组件不保存状态。
限制:
| 要求权限 | 说明 |
|---|---|
| execute code | Provides operator the ability to execute arbitrary code assuming all permissions that NiFi has. |
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。
参考:
JoltTransformRecord, ExecuteScript, LookupRecord, QueryRecord, UpdateRecord