python - Nifi：执行脚本错误（无法创建非字节值的pystring）

Question

我正在尝试使用 executeScript 处理器解析流文件。基本上，我正在做的是使用 python 脚本拆分流文件内容并从中制作一个 csv。我的样本数据运行良好。但是每条 prod 消息的长度约为 10000 个字符。

为了将其拆分并将流文件转换为 csv，python 代码变得很大。运行这个让我error1。我尝试将其转换为 pyc 文件，然后出现错误 2。

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

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

并对其进行测试。