无法导入StreamCallback，NiFi中ExecuteStreamCommand处理器中的ioUtils

Question

我尝试在executestreamcommand处理器中执行python代码，并尝试在代码中读/写流文件，为此，我必须使用某些库

• 从org.apache.commons网站.io导入IOUtils
• 从java.nio.charset导入标准字符集
• 从org.apache.nifi.处理器.io导入StreamCallback

例如在图书馆 但是我在executeStreamCommand中发现了一个错误，没有找到任何模块。有人知道原因吗？在

Answer 1

ExecuteStreamCommand用于在命令行（也称为终端）上执行shell命令（脚本、实用程序等）。NiFi内部库对于在该上下文中运行的脚本不可用，除非您显式地在这些脚本中绑定并导入它们。在这种情况下，与NiFi的交互仅限于通过STDIN和STDOUT流式传输的流文件内容。有关详细信息，请参见this answer。在

如果要使用Python脚本直接读取nififlowfile属性和内容并实现自定义StreamCallback，那么应该使用ExecuteScript或{}。这允许与NiFi概念进行更紧密的耦合集成，但是对于Python来说，这意味着本机编译的模块（用C编写的Python模块）不可用，因为NiFi使用Jython（JSR-223兼容）。在