I need to use Jolt to transform a flat JSON object into an array of JSON objects, where each row in the array corresponds to a unique index number from the original object. The output should have as many rows…
I am attempting to write a Jolt transformation specification to convert nested JSON to flat JSON with rows. The goal is to create a single spec that can handle both Input Data 1 and Input Data 2. Input Data 1…
I need to transform my JSON value [ { "fornecedor_frete": "EMPRESA BRAS. CORREIOS E TELEGRAFOS - OR SAO PAULO", "nfe_composicao": "40814-1" }, { "fornecedor_frete": "EMPRESA BRAS. CORREIOS E TELEGRAFOS - OR SAO PAULO", "nfe_composicao": "40817-1" } ] To: { "documentos":…
I have two Data formats and need to compare them. But the prbolem is in 2nd format the Day(Mon, Tue) is in value and in 1st format it is in Variable side, So how I can compare the day. I…
we want to group the data by deviceid and get the json record count for that device using jolt spec in Apache nifi. Input : [ { "altitude": 19.1, "analog1": 0.016, "analog2": 0.004, "batchprocessgroupid": 0, "batterylevel": 1.598, "bleid": "", "command":…
I have this input JSON: { "people": [ { "foo_name": "jack", "id": 123, "some_attr1": "val1" }, { "foo_name": "bob", "id": 456, "some_other_attr1": "val2" }, { "foo_name": "jack", "cool_attr1": "val3", "not_cool_attr1": "val4", "some_attr1": "vvaaalllllll" } ] } The desired output is:…
I'm wondering if there is any way to rename the field by concatenating the values of JSON attributes into existing attribute names using JOLT transformation. Suppose we have input here: { "auth_id": "0000-0000-0000", "read_time": "2022-01-10T00:00:00.0", "src_name": "REQ-A001", "reading_a": "150.18", "reading_b":…
I have been trying to set key names for json array using the fields provided. I need to fetch a separate list of managers and colleagues. Input: { "employeelist": [ { "employee": "test", "firstName": "ABC", "lastName": "DEF" }, { "employee":…
I have a need to get data out of a NiFi flow file with somewhat complex JSON content. I'm planning to use a NiFi ExecuteScript processor because I don't think it can be done with EvaluateJSONPath. The content looks like…
I have a use case, where i need to drop a whole set of record if condition satisfied. Input { "Location": "IND", "Environment": "", "Climate": "Summer", "category": "City", "status": "De-Active" } Condition : If "status" is equals to "De-Active", the…