我想在 nifi 中将 JSON 文件转换为 CSV。我们可以在 Python 和其他编程语言中实现这一点，并且有很多关于它的文章。我有多个 JSON 文件，每个文件都有不同的架构（一个特定的文件只有一个架构）。我可以看到有模板可以将 CSV 转换为 JSON 和其他转换。但我没有看到任何将 JSON 数据转换为 CSV 的模板。我已经阅读了文章https://community.hortonworks.com/articles/64069/converting-a-large-json-file-into-csv.html，但是在这里我们对架构进行了硬编码。由于我有多个文件并且每个文件都有不同的架构，因此我无法对架构进行硬编码。请有任何建议。
问问题
6015 次
1 回答
4
格式之间的转换通常通过 ConvertRecord 完成，方法是插入适当的记录读取器和记录写入器，在本例中为 JSON 读取器和 CSV 写入器。
要使用记录处理器，您需要为数据定义 Avro 模式并将它们放入模式注册表中，NiFi 提供了一个本地模式。
有很多关于记录内容的示例和帖子，这个幻灯片显示了一个 CSV 到 JSON 的示例，但是很容易扭转您的场景的情况：
https://www.slideshare.net/BryanBende/apache-nifi-record-processing
这篇文章还有一些其他信息： https ://bryanbende.com/development/2017/06/20/apache-nifi-records-and-schema-registries
于 2018-03-07T15:00:35.040 回答