Nifi :执行脚本错误(无法创建具有非字节值的pystring )

Question

我正在尝试使用executeScript处理器解析流文件。基本上，我所做的是使用python脚本拆分流文件内容，并从中生成一个csv。对于我的样本数据，它运行得很好。但是每条prod消息大约有10000个字符。

为了拆分它并将流文件转换为csv，python代码变得很大。运行这个让我得到了error1。我试着把它转换成pyc文件，然后我得到了error2。

请让我知道我能做些什么来解决这个问题。

​

​

​

​

Answer 1

为了在Nifi上部署脚本，我通常使用这个项目：https://github.com/mattyb149/nifi-script-tester

您可以在资源中放置python文件，例如：https://github.com/mattyb149/nifi-script-tester/blob/master/src/test/resources/test_json2json.py

并进行测试。