ExecuteStreamCommand 2025.5.31.15

捆绑包

org.apache.nifi | nifi-standard-nar

描述

ExecuteStreamCommand 处理器提供了一种灵活的方式,可将外部命令和脚本集成到 NiFi 数据流中。ExecuteStreamCommand 可以将传入 FlowFile 的内容传递给它执行的命令,其工作方式类似于管道机制。

标签

command、command execution、execute、stream

输入要求

REQUIRED

支持敏感的动态属性

true

属性

属性

描述

实参分隔符

用于分隔命令实参的分隔符 [默认值:;]。必须是单个字符

命令实参

提供给可执行文件的实参,以“;”字符分隔。

命令路径

指定要执行的命令;如果仅提供可执行文件的名称,则必须位于用户的环境 PATH 中。

忽略 STDIN

如果为 true,则不会将传入 FlowFile 的内容传递给执行的命令

最大属性长度

如果将流命令的输出路由到某个属性,则放入该属性值的字符数最多为此数量。这很重要,因为属性保存在内存中,大型属性会很快导致内存不足问题。如果输出长于该值,则会将其截断以适配。如果可以的话,建议酌情缩小此值。

输出目标属性

如果设置,则流命令的输出将放入原始 FlowFile(而非单独的 FlowFile)的属性中。此时将不再存在“output stream”或“nonzero status”关系。此属性的值将是输出属性的键。

输出 MIME 类型

指定要为“mime.type”属性设置的值。如果设置了“输出目标属性”,则忽略此属性。

工作目录

执行命令时用作当前工作目录的目录

实参策略

用于配置要提供给命令的实参的策略。

限制

所需权限

解释

执行代码

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

关系

名称

描述

nonzero status

返回的状态代码非零时,根据命令的输出创建的 FlowFile 的目标路径。所有路由到此关系的 FlowFile 都将被惩罚。

original

将会路由原始 FlowFile。它将具有详细说明脚本执行结果的新属性。

output stream

返回的状态代码为零时,根据命令的输出创建的 FlowFile 的目标路径。

写入属性

名称

描述

execution.command

所执行命令的名称

execution.command.args

以分号分隔的实参列表。敏感属性将被掩码

execution.status

执行命令后返回的退出状态代码

execution.error

执行命令后返回的所有错误消息

mime.type

如果设置了“输出 MIME 类型”属性且未设置“输出目标属性”,则设置输出的 MIME 类型

语言: 中文