ExecuteGroovyScript 2025.10.9.21

捆绑包

org.apache.nifi | nifi-groovyx-nar

描述

实验性扩展 Groovy 脚本处理器。该脚本负责处理传入的 FlowFile(例如传输到 SUCCESS 或移除)以及脚本创建的所有 FlowFile。如果处理不完整或不正确,会话将被回滚。

标签

groovy、groovyx、script

输入要求

ALLOWED

支持敏感的动态属性

true

属性

属性

描述

groovyx-additional-classpath

用分号或逗号分隔的类路径列表。您可以在文件名中使用 **.jar 等掩码。

groovyx-failure-strategy

如何处理未处理的异常。如果您想通过代码管理异常,请保留默认值 rollback。如果选择了 传输至“failure” 且出现了未处理的异常,则从该会话中的传入队列接收到的所有 FlowFile 都将传输至 failure 关系中,并设置了其他属性:ERROR_MESSAGE 和 ERROR_STACKTRACE。如果选择了 回滚 且出现未处理的异常,则从传入队列收到的所有 FlowFile 都将受到惩罚并返回。如果处理器无传入连接,则此参数无效。

groovyx-script-body

要执行的脚本正文。只能使用脚本文件或脚本正文中的一个

groovyx-script-file

要执行的脚本文件的路径。只能使用脚本文件或脚本正文中的一个

状态管理

范围

描述

LOCAL

脚本可以使用状态管理 APIs 存储和检索状态。有关更多详细信息,请参阅开发者指南的“状态管理器”部分。

CLUSTER

脚本可以使用状态管理 APIs 存储和检索状态。有关更多详细信息,请参阅开发者指南的“状态管理器”部分。

限制

所需权限

解释

执行代码

允许操作员执行任意代码,并拥有 NiFi 的所有权限。

关系

名称

描述

failure

处理失败的 FlowFiles

success

处理成功的 FlowFiles

另请参阅