LookupRecord Processor always routes to unmatched even if matched

[#1]

I have the following json file :

“a”:{

    “after”:{

        “a123”:{

                 “ip”:”1.0.0.0”,

                 “p_id”:”4500”

                   }

           },

“before”:{

        “a123”:{

            “ip”:”1.0.0.0”,

            “p_id”:”4500

                  }

            }

}

I'm trying to create a lookuprecord Processor in NiFi to match with the p_id. If matched then route to something and if unmatched then route to something else. The lookuprecord processor I have is a MongoDBLookUpService.

The user expression I've written for the lookuprecord processor is :

key : /a/after/*['p_id']

Note: [*] because that bit in json keeps changing with every json file.

I've even tried /a/after/*/p_id and nothing seems to work.

They all seem to route to unmatched. Please help me figure out if I'm doing something wrong in the expression.

[#2 · Accepted solution]

Update : I solved this. I had to use a splitjson before the lookup record processor, then it worked all fine.

[#3]

@Olivia_4692  I'm happy to see you resolved your issue. Please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future. 

mark as solution button