Support Questions

Find answers, ask questions, and share your expertise

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...