如何使用 Apache Nifi 将 CSV 转换为 JSON？

Question

如何使用 Apache Nifi 将 CSV 转换为 JSON？
我有一个 CSV 文件，我需要转换为 json。如何绘制正常的流程图。请告诉我属性和图形细节。我的理解是 4 块到那里。1.GenerateFlow 2.ConverttoAvro 3.Converttojson 4.Savethefile。我是 Nifi 的新手，我已经安装了 nifi，正在努力配置

"model","speed","mileage"
"audi",4,2
"benz",4,10
"bmw",7,4
"jaguar",7,22

我的杰森

[
  {
    "model": "audi",
    "speed": 4,
    "mileage": 2
  },
  {
    "model": "benz",
    "speed": 4,
    "mileage": 10
  },
  {
    "model": "bmw",
    "speed": 7,
    "mileage": 4
  },
  {
    "model": "jaguar",
    "speed": 7,
    "mileage": 22
  }
]

我经历了使用 Apache NiFi 将 CSV 文件转换为 JSON

Answer 1

您所描述的方法是.old (needs to follow if you are using prior to NiFi-1.2 version)

从NiFi-1.2 开始引入record oriented processors.

• 对于您的情况，使用ConvertRecord处理器并配置/启用Record Reader(CSVReader)/Writer(JsonSetWriter)控制器服务。

• 然后 NiFi ConvertRecord处理器读取传入的CSV数据并以JSON格式写入输出流文件。

请参阅此链接描述如何convertCsvtoJson使用 ConvertRecord 处理器的分步过程。

Starting from NiFi-1.2 Version 流动：

1.GenerateFlowFile 
2.ConvertRecord
3.SaveFile (Using PutFile/PutHDFS)

Prior to NiFi-1.2 Version 流动：

1.GenerateFlowFile
2.InferAvroSchema
3.ConvertCSVToAvro
4.ConvertAvroToJSON