- last edited on
In my database(postgresql) table, I have following columns.
In my flowfile. I have
Now I want to read from the database and flow file. Map locationID and addressID and add a new column to my flow file as locationName.
So my final flow file should also be like
I have tried to use QueryDatabaseTableRecord processor. But dont know how to map flowfile content and database read.
To clarify, are you trying to 1) do a conditional lookup against the database using the FlowFile content, or are you 2) pulling data based on some other criteria, then wanting to perform the lookup/join/mapping during NiFi processing?
1) do a conditional lookup against the database using the FlowFile content... and then those lookup values are written back to flowfile and other processors use this flowfile.