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

Question

我无法从ExecuteStreamCommand运行Python脚本。

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

错误消息: Traceback (最近一次调用)：文件"/home/test.py"，第1行，in import nipyapi ModuleNotFoundError:没有名为'nipyapi‘的模块

Answer 1

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