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

Posted

技术标签:

【中文标题】Nifi:执行脚本错误(无法创建非字节值的pystring)【英文标题】:Nifi : Execute script Error (cannot create pystring with non-byte value) 【发布时间】:2020-01-23 19:37:45 【问题描述】:

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

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

请告诉我我能做些什么来解决这个问题。

【问题讨论】:

你是怎么得到这么大的python代码的?可以展示一下吗? @daggett 主要将流文件(10000 个字符)拆分为不同的字段(1800 个字段)。因此,仅此一项就增加了 1800 行。 尝试使用executestreamcommant。 【参考方案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

并对其进行测试。

【讨论】:

以上是关于Nifi:执行脚本错误(无法创建非字节值的pystring)的主要内容,如果未能解决你的问题,请参考以下文章

NiFi-1.0.0 - 加载 lua 脚本

如何在 Nifi 的虚拟环境中运行具有依赖关系的 python 脚本?

如何在Apache NIFI中应用机器学习来处理流数据?

NiFi之Processor配置

在apache NIFI中将xls文件转换为csv文件

无法使用 apache Nifi 连接到 Clickhouse 数据库