在尽最大努力找到与此问题相关的以前的问题和示例后，仍然没有找到我正在寻找的答案，我想我会自己提交一个问题。ExecuteStreamCommand对我来说似乎是完美的处理器，原因如下:我能够执行任何Python脚本并避免使用Jython(以与ExecuteScript类似的方式)。Jython不适合我。我可以接收FlowFiles。这是必要的，因为我的脚本是用来消耗前一个处理器的输出的。此外，我喜欢将数据置于“NiFi管理”之下的想法。它写了一个“执行状态”，这对路由很有用。简而言之，我试图用ExecuteStreamCommand做的是:摄取前一个处理器的输出(一个Scrapy蜘蛛，

我的最终目标是屏蔽一个特定文件中的数据。我想将文件从一个地方移动到另一个地方。在此传输过程中，我必须使用Python脚本屏蔽数据。所以，我设计了以下流程:GetFile>ExecuteStreamCommmand>PutFile我使用pandas设计了一个Python脚本。我在GoogleCloudPlatform上创建的虚拟机上运行这个NiFi我已经安装了Python-2.7和NiFi-1.9.1。下面是我的Pandas代码:importpandasaspdreadFile=pd.read_csv("/path",sep="",header=None)readFile.columns