ScriptedValidateRecord 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-scripting-nar
描述¶
该处理器能够使用用户提供的脚本验证 FlowFiles 中的记录。该脚本应以记录作为传入实参，并返回布尔值。根据该结果，处理器将记录归类为“valid”或“invalid”，并将它们批量路由到相应的关系。此外，原始 FlowFile 将路由到“original”关系，如果处理不成功，则路由到“failed”关系。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
模块目录 |
以逗号分隔的文件和/或目录的路径列表，包含脚本所需的模块。 |
记录读取器 |
用于将传入 FlowFile 解析到记录的记录读取器 |
记录写入器 |
记录写入器，用于在记录转换后对其进行序列化 |
脚本正文 |
要执行的脚本正文。只能使用脚本文件或脚本正文中的一个 |
脚本引擎 |
用于脚本的语言 |
脚本文件 |
要执行的脚本文件的路径。只能使用脚本文件或脚本正文中的一个 |
限制¶
所需权限 |
解释 |
|---|---|
执行代码 |
允许操作员执行任意代码，并拥有 NiFi 的所有权限。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果在处理传入的 FlowFile 时出现任何问题，传入的 FlowFile 将路由到此关系。 |
invalid |
包含来自传入 FlowFile 的无效记录的 FlowFile 将路由到此关系。如果没有无效记录，则不会有 FlowFile 路由到此关系。 |
original |
成功处理后，传入的 FlowFile 将传输到此关系。尽管 FlowFiles 可能路由到“valid”和“invalid”关系，都会发生这种情况。 |
valid |
包含来自传入 FlowFile 的有效记录的 FlowFile 将路由到此关系。如果没有有效记录，则不会有 FlowFile 路由到此关系。 |
写入属性¶
名称 |
描述 |
|---|---|
mime.type |
将 mime.type 属性设置为记录写入器指定的 MIME 类型 |
record.count |
FlowFile 中的记录数。 |
record.error.message |
此属性提供失败时读取器或写入器遇到的错误消息。 |