apache-nifi - 在 Nifi ExecuteScript 中导入模块

Question

我是 Nifi 和 python 的新手

我想执行我的 python 脚本。因此使用 ExecuteScript 并尝试导入某些模块。我是这样导入的:

import json, sftp, paramiko

虽然我安装了 sftp，但当我将其导入到 Executescript 中时，它显示“无法处理 session 。第 1 行没有名为 sftp 的模块”

which -a sftp
/usr/bin/sftp

在导入 paramiko 时，也出现了同样的错误。

Answer 1

ExecuteScript 和 InvokeScriptedProcessor 使用的“python”引擎实际上是 Jython，而不是纯 Python。这意味着它无法加载 native 模块(.so 文件、编译的 C 文件等)。根据this SO post ，paramiko 使用具有 native 库的 Crypto，因此不能在 Jython 中使用(请参阅 this post 的底部以获取我对此的评论)。我的猜测是 sftp 库也会做同样的事情。

Jython可以使用纯Python模块，有a discussion on the NiFi mailing list关于如何指向(并包含)这些类型的模块。