mysql - 如何在 nifi 中插入批量记录

Question

我是 nifi 的新手，我正在尝试使用 nifi 在 mysql 中进行批量插入，下面是我的示例流程结构。

FetchFile -> 
ConvertRecord (covert csv to json) -> 
SplitJson -> 
EvaluateJsonPath -> 
routeOnAttribute -> 
JoltTransformJson (adding new key value pair) -> 
MergeContent (merge all flowfiles) -> 
ConvertJsontoSql (converting json to sql) -> 
ExecuteSql

这里executeSql只插入一条记录而不是所有记录

mergeContent 包含以下 JSON 结构

{"batch_id":"123","name":"xyz","age":"26"},
{"batch_id":"123","name":"abc","age":"29"},
{"batch_id":"123","name":"fff","age":"30"}

但是executeSql只插入第一个json，其他的都没有插入。请有人帮忙。

提前致谢

标签： mysqlbulkinsertapache-nifi

Answer 1

您是否尝试更改记录阅读器？

使用 JsonPathReader 您可以添加一条记录，但如果您使用 JsonTreeReader 您可以批量插入。