mongodb - 如何使用 PutMongo 将 json 数组插入 Apache Nifi 中的 mongodb 集合？

Question

我正在尝试使用 Apache nifi 中的 Putmongo 处理器将 json 数组插入 mongodb。但我收到一个错误：

error: current bson type is an array and not a document

这是我的json：

[{"Name":"computer","TotalRevenue":15000},
{"Name":"music","TotalRevenue":1500},
{"Name":"space","TotalRevenue":5000}][{"Name":"a rehman","company":"music","revenue":500},
{"Name":"bill gates","company":"computer","revenue":6000},
{"Name":"elon must","company":"space","revenue":5000},
{"Name":"john lenin","company":"music","revenue":1000},
{"Name":"steve jobs","company":"computer","revenue":9000}]

另外，我正在附加 Putmongo 配置

这是我的完整 Apache 流程：

GetFile CSV -> ConvertRecord to Json -> QueryRecord -> MergeContent -> PutMongo

Answer 1

PutMongo 不接受 JSON 对象数组。因此，我使用 SplitJson 处理器将数组拆分为单独的 JSON 对象。后来使用 MergeContent 处理器将其合并以获得所需的结果。