ScriptedTransformRecord 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-scripting-nar
描述¶
提供对传入 FlowFile 中的每条记录评估一段简单脚本的功能。该脚本可能会以某种方式对记录进行转换、筛选或生成额外的记录。有关更多信息，请参阅处理器的“附加详情”。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
模块目录 |
以逗号分隔的文件和/或目录的路径列表，包含脚本所需的模块。 |
记录读取器 |
用于将传入 FlowFile 解析到记录的记录读取器 |
记录写入器 |
记录写入器，用于在记录转换后对其进行序列化 |
脚本正文 |
要执行的脚本正文。只能使用脚本文件或脚本正文中的一个 |
脚本引擎 |
用于脚本的语言 |
脚本文件 |
要执行的脚本文件的路径。只能使用脚本文件或脚本正文中的一个 |
限制¶
所需权限 |
解释 |
|---|---|
执行代码 |
允许操作员执行任意代码，并拥有 NiFi 的所有权限。 |
关系¶
名称 |
描述 |
|---|---|
failure |
无法成功转换的 FlowFile 将路由至此 |
success |
每个成功转换的 FlowFile 都将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
mime.type |
将 mime.type 属性设置为记录写入器指定的 MIME 类型 |
record.count |
FlowFile 中的记录数 |
record.error.message |
此属性提供失败时读取器或写入器遇到的错误消息。 |