如何在 Nifi 的 ExecuteStreamCommand 中添加额外的库?

How to add additional libraries in ExecuteStreamCommand in Nifi?

我无法从 ExecuteStreamCommand 运行 Python 脚本。

这些是处理器属性: 命令参数:/home/directory/test.py 命令路径:/bin/python3 工作目录:/home/directory

错误消息:追溯(最近调用最后一次):文件“/home/test.py”,第 1 行,在导入 nipyapi ModuleNotFoundError:没有名为 'nipyapi'

的模块

我能够让 ExecuteStreamCommand 处理器处理带有导入模块的 运行 python 脚本的方法是在实际机器本身上安装导入模块。因此,这意味着 运行ning pip 或 pip3 install {insert module name} 在此处理器正在 运行ning 上的每个系统的命令提示符上。