NIFI : Json 到 NIFI 中的 CSv 转换器

Question

我是 NIFI 的新手，这是我的第一个任务。我正在尝试将 JSON 转换为 CSV，但没有生成任何 CSV 文件。附件是我遵循的方法。请让我知道我在哪里缺少逻辑。我的样本 Json ： {"creation_Date": "2018-08-19", "Hour_of_day": 7, "log_count": 2136}

Answer 1

您使用的是正确的处理器，您的模式定义是错误的。

convertrecord proc 应该有一个 JsonTreeReader（具有架构访问策略：推断架构 - 其余是默认的）和一个 CSVRecordSetWriter（继承记录架构）。

使用 CSVRecordSetWriter 中的参数使您的 csv 看起来像您想要的那样。

输入

{"creation_Date": "2018-08-19", "Hour_of_day": 7, "log_count": 2136}

输出

creation_Date,Hour_of_day,log_count 2018-08-19,7,2136

这是 JsonTreeReader 的 conf 这是您的 CSVRecordSetWriter

的配置

如果您不想使用架构，则必须混合使用：

EvaluateJson >> AttributestoCSV

NIFI : Json 到 NIFI 中的 CSv 转换器

Nifi : Json to CSv converter in NIFI

apache-nifi