I have input with more than 1000 keys in input and there are few objects in my input as well with key value pairs. I need to transform all the key values to string inside each object as well as…
Actual message read from Kafka: { "body": { "metadata": { "id": "bce16e11" }, "eventDetails": { "eventID": "c5f615f1", "customerId": "123456789", "Name": "NEW" } } } want to add Kafka offset and partition to the message as follows. Please note that Kafka…
I am using NiFi to load data from database A in json record format and want to insert json record into a json column of a table in database B. A => ExecuteSQLRecord => [jsonRow,...] => [?] => B.table(data json)…
I'm trying convert JSON by NiFi JOLTTransformRecord processor to tree with nested array. But I am having some trouble with converting the flat JSON to Nested JSON. I have looked at examples and didn't get any closer as to what…
I have this JSON input: { "input": { "a": "valueA", "b": "valueB", "c": "valueC" }, "fieldsToFilterBy": [ "a", "c" ] } and i want to have this output: { "input": { "a": "valueA", "b": "valueB", "c": "valueC" }, "filteredValues": […
This is a continuation of question asked in Grouping Json with same value of a key with Jolt I want to do following changes in output JSON with JOLT. Could you please help on getting the desired JSON output. Thank…
Does anyone how to write a JOLT Transform with this situation: Input : [ { "id": "65cf06b62fadc0122dc30f29", "code": "H34.23.9-240216-0003", "applicant": { "eformId": "60d990f88e6893001e5a7b42", "userId": "6186433deee4513fe0d86efc", "data": { "birthday": "", "address": "Thôn Kon Năng Treang", "gender": 2, "nation": { "label": "Việt…
Is it possible to do more than one condition on a JOLT transformation to create or's or and's? I found some documentation on If Else but haven't been able to apply it to what I'm trying for. This is an…
So I have geo Coordinates and I want to create polygon string that i can insert into Postgres as geometry type. I am using apache Nifi. Input: [ [ 13, 52 ], [ 13, 55 ], [ 14, 15 ]…
I have an attribute "TEST" storing a JSON object, I tried this JOLT but I'm getting "Unable to marshal json to an object" error TEST: [ { "ORDER_DATE": "2022-04-11", "TIME_STAMP": "1667543037000" }, { "ORDER_DATE": "2022-05-05", "TIME_STAMP": "1651741666000" } ] JOLT…