Mongo jason query is failing to execute by runMangoAggregation Processor Nifi

[#1]

Hi Friends,

I have mongo query which running perfectly fine from mongo shell.

b.test650.aggregate(
[
{
$group: {
"_id": {
X: "$X",
Y_DT: "$Y_DT",
Z: "$Z"
},
adj: {$sum: "$adj" },
bjc: {$sum: "$bjc" },
jbc: {$sum: "$jbc" },
mnk: {$sum: "$mnk"}
}
}
]
)

The same query when in ran from Nifi , RunMangoAggregation  throwing out error, though the mongo aggregation query changed to json type query ...

{
"$group": {
"_id": {
"X": "$X",
"Y_DT": "$Y_DT",
"Z": "$Z"
},
"adj": {"$sum": "$adj" },
"bjc": {"$sum": "$bjc" },
"jbc": {"$sum": "$jbc" },
"mnk": {"$sum": "$mnk"}
}
}

Getting following error ..

error run mongodb aggregation query.: com.fasterxml.jackson.databind.exc.MismatchedInputException:ca...

Nifi workflow..

Processor(runMangoAggregation) configuration

What is the change I need to do in json query which supposed to executed @ runMongoAggregation  processor?

[#2]

Hi friends,

Help me out get out this situation

[#3 · Accepted solution]

The issue is with the missing of square brackets at starting and @ ending ..

The working query is ..

[{
"$group": {
"_id": {
"X": "$X",
"Y_DT": "$Y_DT",
"Z": "$Z"
},
"adj": {"$sum": "$adj" },
"bjc": {"$sum": "$bjc" },
"jbc": {"$sum": "$jbc" },
"mnk": {"$sum": "$mnk"}
}
}]