Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]

Support Questions

Find answers, ask questions, and share your expertise
Announcements
Share your experience with Cloudera on G2 and get a $25 Amazon Gift card.
Hi, I'm CLEO! Something exciting is coming to the Community. Stay Tuned!

insert splitted records in database using apache nifi

avatar
Explorer

I want to insert splitted records from splitjson processor in database table using nifi.

For eg: Below is splitjson processor output. I want to push all the flow files in database table having same fragment.identifier.

sahil0915_0-1656614373096.png

table columns are mentioned below:

identity_id|json|person_ref

where identity_id should be auto sequence number 

json would  flow-file content

person_ref is the foreign key having int data type

so  table will have 13 entries and identity_id column will be unique numbers in sequence, json column will have different flow file contents and person_ref column should be same for all 13 entries lets say 111.

 

 

 

1 ACCEPTED SOLUTION

avatar
Super Guru
1 REPLY 1

avatar
Super Guru

Hi,

Similar question was asked before. Can you please check this post:

https://community.cloudera.com/t5/Support-Questions/How-to-load-json-record-to-postgres-as-json-data...