I’m struggling a lot with this simple workflow and I can’t make it work for me.
I have a csv file where I have two columns. ID and UUID. This is my document.
ID,UUID
0000317416,78f67ee6-293a-4373-8ed2-bdcbb21b3b2a
0004321903,1ce2327e-44b9-4611-b158-47af342ea8ed
So I’m reading csv file with GetFile and process with QueryRecord to get ID’s on one side and UUID’s on another.
The point now is to query to a postgresql database to get all the records from this id.
So I linked flow id to executeSQL,
And added a SQL select Query to get all the records,
SELECT * FROM alert WHERE pid = ${id}
But this query is not working.
This is the data provenance out of the query processor,
.
Maybe, I’m doing something wrong, but I’ve reviewed several times the documentation where in this article is commented a very similar solution, but still I couldn’t make it work for me.
https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.20.0/org.apache.nifi.processors.standard.QueryRecord/additionalDetails.html
Also, reviewed this one, Query Database Table with the values of csv in Apache NiFi
This is the error, since it looks like the id is empty.