如何在 apache nifi 的 ExecuteScript 处理器中编写 pythoncode？

Question

嗨，我必须在 apache nifi 中执行下面的 python 代码，我的 nifi 流程如下 我的python代码如下（我在本地毁了它工作正常）`

import pandas as pd
 cdr = pd.read_csv("cdr.csv")
 labels = pd.read_csv("result.csv")
 cdr.rename(mapper={str(value[0]):n for n,value in labels.to_dict(orient='list').items()},  axis=1, inplace=True)

还有我的 nifi 流程：-

这里cdr来自GETSFTP，labels来自get文件处理器，这里cdr数据会不断地来

谁能帮我在 nifi 的 ExecuteScript 处理器中编写上面的 python 代码

Answer 1

ExecuteScript 处理器 cannot use native Python modules，只有 Jython code。尝试使用 ExecuteStreamCommand 运行任意 Python 代码。