Hello ,   If your input json is coming below format    { "TOT_NET_AMT" : "55.00", "H_OBJECT" : "File", "H_GROSS_AMNT" : ["55.00","58.00"], "TOT_TAX_AMT" : "9.55" } If the value of H gross amount is in List of String ["55.00","58.00"]  instead of String "55.00,58.00" , then you can use Jolt transformation JSON NiFi processor to define jolt spec to convert into the required output.   { "TOT_NET_AMT" : "55.00", "H_OBJECT" : "File", "H_GROSS_AMNT" : "58.00", "TOT_TAX_AMT" : "9.55" }   Jolt transformation JSON configuration.     Jolt specification :  [ { "operation": "modify-overwrite-beta", "spec": { "H_GROSS_AMNT": "=lastElement(@(1,H_GROSS_AMNT))" } } ]   If the input is not list of String for H Gross amount and only string with comma speparated, then please follow the below steps in order.   you will have to extract whole json into single attribute using extracttext processor and the attribute will hold entire json content , Next you can use EvaluateJsonPath which extracts each json element into each attributes , once you have all 4 attributes with value after EvaluateJsonPath , then you construct the json in Replace text processor ,H_GROSS_AMNT will still hold the string comma separated and u can use H_GROSS_AMNT:substringAfterLast(,) which extracts last element from the string value .   Examples of EvaluateJsonPath  https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html#jsonpath ... View more

Hi alexmarco,   If your final json format is fixed and input json also coming in same format always with values different then you extract keyword value (foo or new value) into flowfile attribute and you can use attribute in following replacetext processor to pass the value .   ExtractText processor --> UpdateAttributeProcessor --> ReplaceText Processor 1. Add a new property(keyword_value) in ExtractText and value/expression should be below  ("keyword":.*) 2. Remove space,double quotes from the extracted keyword_value attribute in UpdateAttributeProcessor. (You can add the updateattribute logic directly in Replacetext processor itself for retrieving the keyword_value also as ReplaceText processor supports NiFi expression language. Its optional and you avoid Updateattribute processor in this flow then if you chose ) 3. Append the keyword_value in ReplaceText processor (keep the final json ) as in sample . 4. Connect the success flow into Invokehttp processor.   * CreateKeywordvalueAttribute (Extract processor) expression below  : ("keyword":.*) * Updateattributeprocessor  ${keyword_value:substringAfter(':'):trim():replace('"', '')}   * FinalReplaceText processor : Place the below JSON into Replacement Value section of the processor    { "requests": [ { "source": "blablabla", "params": { "keywords": [ "${keyword_value}" ], "sub-field1": "1" } } ], "field1": "1", "field2": "2", "field3": false }   I have attached the sample tested flow(.xml) for your reference .    Please accept the solution if it works as expected.   Thanks Adhi     ... View more

We have solved this with help of wait and notify processor as we routed .hql file to puthql which interns routes success/failure to Notify . The Wait processor wait signal will release the .csv file to put into HDFS once Notify signal comes from Notify processor. ... View more

Hi ,   The InvokeHTTP processor provides couple of the write attributes with value for example invokehttp.status.code 401 invokehttp.status.message Unauthorized   when you have this attributes  in Failure or No Retry relationship ,you can use Replace text processor as below to overwrite the original flow into new flow file so that you send that in email .   ReplaceText processor properties    If you are looking for lot more message of the response body , please check whether you can configure in any attribute in InvokeHTTP processor so that you can use it ReplaceText processor to overwrite the original flow file   ... View more