如何在 NIfi 中配置 ExecuteScript 处理器以使用 JyNI 包启用使用 numpy 的库？

Question

我正在使用 Apache Nifi 和 Python 的 executeScript 处理器。我从其他条目中了解到，该处理器在 Jython 上运行，它无法使用 CPython 导入库，例如麻木的。 我想使用的库使用 pandas 和 numpy。 我找到了 JyNI 库并试图让它在 executeScript 处理器中运行。但是没有成功。将库添加到 nifi 类路径时，出现无法加载 jython 的异常。 我还发现 Jython.jar 在处理器 nar 文件中。

JyNI 在这种情况下是否有成功的机会？ 关于如何为该处理器正确设置 JyNI 的任何想法？

更新：Nifi 1.8 版， ExecuteScript 处理器 1.8.0， Java 1.8 版， JyNI 版本 2.7 alpha-5

Answer 1

您可以为要执行的逻辑编写一个简单的 Python 包装器，并使用 ExecuteStreamCommand 运行 python my_script.py <args...>，这将在命令行上调用包装器脚本，并使用本机 Python。 This answer 有更多关于ESC 处理器如何通过STDIN 和STDOUT 和示例配置将流文件内容传递到脚本/从脚本传递的详细信息。