I am trying to use a ExecutesSQL process to check if a file has already been
processed.
Files are flowing into our nifi and we have it set up to move files to
another folder. Once the file is moved, we just log the history into MYSQL.
I want to have it check if the filename is already in the db, thus checking
if we have already processed this file.
SELECT * FROM tbl WHERE ${filename} = File_Name(this is the column header in
our MYSQL.)
I have yet to get anything besides an error being generated saying my sql
statement is incorrect. Am I going about this the wrong way? Does anyone
have a better way of checking this sort of thing? I have added in future
file names(as the file names are predictable) but it still will give me an
error.
Thanks
--
View this message in context:
http://apache-nifi-developer-list.39713.n7.nabble.com/Monitoring-duplicate-file-entries-with-ExecuteSQL-tp9490.html
Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.
