Member since
08-01-2021
5
Posts
1
Kudos Received
0
Solutions
04-02-2022
01:12 PM
Hi everyone! I'm capturing the processor id from the log file and I want to get the full Path of the processor. If we have: group A (Parent group) group B group c processor (with id e93-181fed5c2-1bd10ecf812) Can I utilize the Nifi rest API using the processor Id and get the path of groups? Thank you all!
... View more
Labels:
- Labels:
-
Apache Airflow
02-22-2022
11:48 PM
1 Kudo
THANK YOU SO MUCH. It makes total sense.
... View more
02-22-2022
03:44 AM
Thank you so much @araujo for the help. Is it possible to have the new flatten array and the original array within one jolt spec? This is the current structure can we change it to this:
... View more
02-18-2022
07:31 AM
Hi everyone! I hope all is well. I have this json { "Data" : { "ID" : "09878666" , "DATE" : "2022-01-01" , "ARRAY_ONE" : [ { "NAME" : "test_1" , "details" : [ { "address" : "123123" } ] }, { "NAME" : "test_2" , "details" : [ { "address" : "123123" }, { "address" : "123123" } ] } ] } } and I transformed the structure to this: [ { "ID" : "09878666" , "DATE" : "2022-01-01" , "NAME" : "test_1" , "details" : [ { "address" : "123123" } ] }, { "ID" : "09878666" , "DATE" : "2022-01-01" , "NAME" : "test_2" , "details" : [ { "address" : "123123" }, { "address" : "123123" } ] } ] Which is perfect except for the inner arrays, I want to flatten the array to be like this [ { "ID" : "09878666" , "DATE" : "2022-01-01" , "NAME" : "test_1" , "details_0_adrress" : "123123" }, { "ID" : "09878666" , "DATE" : "2022-01-01" , "NAME" : "test_2" , "details_0_adrress" : "123123" , "details_1_adrress" : "123123" } ] Here is my spec: [ { "operation" : "shift" , "spec" : { "Data" : { "ARRAY_ONE" : { "*" : { "@(2,ID)" : "[#2].ID" , "@(2,DATE)" : "[#2].DATE" , "NAME" : "[#2].NAME" , "details" : "[#2].details" } } } } } ] I know how to flatten an array but I'm not sure how to do it using the current spec:, What I would normally do is something like this: { "operation" : "shift" , "spec" : { "details" : { "*" : { "address" : "details_&1_address" } } } } But it did not work so well. Thank you!
... View more
Labels:
- Labels:
-
Apache Airflow
08-01-2021
12:20 AM
Hi everyone! Nifi is doing something strange with my data. I'm moving the data from SQL Server to a SQL Server using Nifi. the flow is simple 1. QueryDatabaseRecord 1.1 Record Writer: JsonRecordsSetWriter 2.SplitJson 3.convert json to sql 4. put sql I have a column with this value: 024b2390-fecb-4b23-b057-e4e9cd8e32d3 as nvarchar in sql server and nifi read that value and convert it to: 20210224150351135 strange enough I also have another record having this value: d2278af1-f2ed-4959-849b-bcb1ef7f496a and Nifi were able to read it as is without any issue. I want to move the data without any change. Thank you all in advcance.
... View more
Labels:
- Labels:
-
Apache NiFi
-
Tensorflow