update a get request to elastic search in nifi

[#1]

I'm trying to hit a get request on my elastic search index using JSONelastisearchprocessor in NIFI. Now, for each flow file i have some incoming attributes, based on that i need to generate different get request and store the response somewhere.

The list of processors i'm using is as below:

1. Getfile (to read JSON file)
2. Evaluate JSON path (To extract the attributes which i want to use with every get request, PROC_INST_ID_ in this case )
3. JSON queryelastic search (to hit the request with the below )
4. PUTfile to store the response

Request body

{
  "query": {
    "nested": {
      "path": "los",
      "query": {
        "bool": {
          "must": [
            { "match": { "los.${proc_ins_id}":"784525" }},
            { "match": { "los._source.cibilPermission.VALUE_":"1" }}
          ]
        }
      }
    }
  }
}

I can't see the request being genrated and not getting any response instead i'm only getting the value of proc_ins_id as reponse in putfile. Can someone suggest some appropriate way to do this?

Attaching relevant screenshots as well for reference.

[#2]

@Matt Burgess

Can you add something on it

[#3 · Accepted solution]

@Vaibhav Kumar

Please change EvaluateJsonPath processor configs Destination to flowfile-attribute

Now the processor will add the attribute to the flowfile then in JsonQueryElasticSearch processor will gets the attribute value and runs the query on ElasticSearch.

With Destination as flowfile-content will overwrites the existing flowfile content with PROC_INST_ID_ value.

JsonQueryElasticSearch Relationships:

Only feed the required relationships to PutFile processor i.e. hits (or) aggregations

Flow:

[#4]

Thanks @Shu