Hi @rafy , I dont think the QueryRecord is suppose to work this way but I could be wrong. The query record basically filters from the root array and not the nested array. Since your input is not an array json object on the root this is not going to work. and if the filter " RPATH_STRING(data, '/room')='A'" is suppose to work (not sure why its not) it will return the entire record from the root and not just the subset. I think the question has been asked before but there was no answer: https://community.cloudera.com/t5/Support-Questions/Select-a-subset-of-data-using-NiFi-QueryRecord/td-p/348002 Now to resolve your problem, you have two options of processors : Option 1:  EvaluateJsonPath->QueryRecord->JsonJoltTransformation where processors are configured as follows: EvaluateJsonPath : to get the data array into root array   QueryRecord : To Query the required record based on the ${ip} attribute:   JsonJoltTransformation: To convert back to the required schema with data array spec: [ { "operation": "shift", "spec": { "*":"data[#].&" } } ]   Option 2: Just one JoltTransformationJson with the following spec:   [ { "operation": "shift", "spec": { "data": { "*": { "room": { "${ipAttr}": { "@2": "data[0]" } } } } } } ] Note: I had to change the ip attribute name to ipAttr since ip is reserved Expression Language function.   ... View more

I think you had it right but you need to convert the division value into string before applying split on it. Here are the steps:     "decImporto": "=divide(@(1,Importo),@(3,Quantita))", "strImporto": "=toString(@(1,decImporto))", "array_importo": "=split('[.]',@(1,strImporto))", "pad_importo": "=rightPad(@(1,array_importo[1]), 8, '0')", "Importo": "=concat(@(1,array_importo[0]),'.',@(1,pad_importo))"   ... View more

Hi, Please see the modified spec below. The comments indicate what I had to do to make your modify-overwrite-beta spec works based on the input json. I hope it works.   [{ "operation": "modify-overwrite-beta", "spec": { "FatturaElettronicaBody": { // The DatiGenerali level is not found in the input JSON // "DatiGenerali": { "DatiBeniServizi": { "DettaglioLinee": { "*": { //level3 "ScontoMaggiorazione": { // level2 "*": { // Quantita is located level 3 and not level 1 "Importo": "=divide(@(1,Importo),@(3,Quantita))" } } } } } //} } } }]     ... View more

Hi, I believe this spec would help with setting the date as default date in each array element:   [ { "operation": "modify-overwrite-beta", "spec": { "FatturaElettronicaBody": { "DatiGenerali": { "DatiDDT": { "NumeroDDT": "=split('[,]',@(1,NumeroDDT))" } } } } }, { "operation": "shift", "spec": { "FatturaElettronicaBody": { "DatiGenerali": { "DatiGeneraliDocumento": "FatturaElettronicaBody.DatiGenerali.&", "DatiDDT": { "NumeroDDT": { "*": { "@": "FatturaElettronicaBody.DatiGenerali.DatiDDT[&1].NumeroDDT", "@(3,DatiGeneraliDocumento.Data)": "FatturaElettronicaBody.DatiGenerali.DatiDDT[&1].Date" } } } } } } } ] If that helps please accept solution. ... View more