ScriptedPartitionRecord 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-scripting-nar
描述¶
接收面向记录的数据（即，可由配置的记录读取器读取的数据），并根据传入 FlowFile 中的每条记录评估用户提供的脚本。然后，将每条记录与共享同一分区的其他记录分组，并为每组记录创建 FlowFile。如果脚本的评估结果为两条记录都返回相同的值，则这两条记录共享同一分区。这些记录将视为同一分区的一部分。
输入要求¶
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
模块目录 |
以逗号分隔的文件和/或目录的路径列表，包含脚本所需的模块。 |
记录读取器 |
用于将传入 FlowFile 解析到记录的记录读取器 |
记录写入器 |
记录写入器，用于在记录转换后对其进行序列化 |
脚本正文 |
要执行的脚本正文。只能使用脚本文件或脚本正文中的一个 |
脚本引擎 |
用于脚本的语言 |
脚本文件 |
要执行的脚本文件的路径。只能使用脚本文件或脚本正文中的一个 |
限制¶
所需权限 |
解释 |
|---|---|
执行代码 |
允许操作员执行任意代码，并拥有 NiFi 的所有权限。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果 FlowFile 无法从配置的输入格式分区到配置的输出格式，则未更改的 FlowFile 将路由到此关系。 |
original |
对传入 FlowFile 中的所有记录进行分区后，原始 FlowFile 将路由到此关系。 |
success |
成功分区的 FlowFiles 将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
分区 |
传出 FlowFile 的分区。如果脚本指示分区具有 null 值，则该属性将设置为字面量字符串“<null partition>”（不带引号）。否则，该属性将设置为脚本返回的任何值的字符串表示形式。 |
mime.type |
将 mime.type 属性设置为记录写入器指定的 MIME 类型 |
record.count |
FlowFile 中的记录数。 |
record.error.message |
此属性提供失败时读取器或写入器遇到的错误消息。 |
fragment.index |
表示从单个父 FlowFile 创建的分区 FlowFiles 的顺序的递增编号 |
fragment.count |
从父 FlowFiles 生成的分区 FlowFile 数量 |