我想在 nifi 中将 JSON 文件转换为 CSV。我们可以用 Python 和其他编程语言来实现这一点,并且有多篇文章介绍它。我有多个 JSON 文件,每个文件都有不同的架构(一个特定文件只有一个架构)。我可以看到有一些模板可以将 CSV 转换为 JSON 以及其他转换。但我没有看到任何将 JSON 数据转换为 CSV 的模板。我已经浏览了这篇文章https://community.hortonworks.com/articles/64069/converting-a-large-json-file-into-csv.html https://community.hortonworks.com/articles/64069/converting-a-large-json-file-into-csv.html,但是这里我们对模式进行硬编码。由于我有多个文件,并且每个文件都有不同的架构,因此我无法对架构进行硬编码。有什么建议请。
格式之间的转换通常是通过 ConvertRecord 插入适当的记录读取器和记录写入器(在本例中为 JSON 读取器和 CSV 写入器)来完成。
要使用记录处理器,您需要为数据定义 Avro 模式并将其放入模式注册表中,NiFi 提供了本地模式注册表。
有很多关于记录内容的示例和帖子,此幻灯片展示了 CSV 到 JSON 的示例,但很容易扭转您的场景的情况:
https://www.slideshare.net/BryanBende/apache-nifi-record-processing https://www.slideshare.net/BryanBende/apache-nifi-record-processing
这篇文章还有一些其他信息:https://bryanbende.com/development/2017/06/20/apache-nifi-records-and-schema-registries https://bryanbende.com/development/2017/06/20/apache-nifi-records-and-schema-registries
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)