I have a flowfile that contains a list of JSON objects. For each JSON object in the list, I need to generate a single call to PutMongo to place that object into Mongo. The key will be the evt_data.targetDataId. The call to PutMongo will insert or update the record for that targetDataId.
I'm looking for the most efficient way to process such an array. Do I need to first need to use an intermediate processor (e.g. SplitJSON) to reduce it to a list of flowfiles, one per object in the array, before sending to PutMongo? If so, what processor should I use for that?
For example, if I have a flowfile that looks like the following. This would result in 2 inserts (or updates) using PutMongo. It would be really nice if PutMongo supported this conversion of an array of documents, to an array of "inserted/updated" documents, out of the box.