Hi community, I would like to leverage nifi to ingest a file from sftp and insert its data into mysql database.I currently have been unsuccessful in doing so and will require all assistance in the right direction.Much appreciated for the help in advance and below are the specifics (1)I should be able to list the files on sftp (2) select a particular file or files (3)Fetch the "desired file" (4) Ingest "desired file" into database. Below is more detail. (i)Sample content of sftp file to ingest into via nifi via sftp processors later to insert into MYSQL (ii)Current designed nifi workflow (iii)Error am getting with this workflow ConvertJSONToSQL ERROR: failed to parse standardflowfilerecord due to processor exception as JSON unexpected character (''' (code39)) expected a valid value (number,string,array,object,'true','false' or 'null') PutSQL ERROR: failed to update a database due to a failed batch update.There were a total of 1 flow file that failed, 0 that succeeded and 0 that were not excuted and will be rerouted to retry. (iv)Processor Configs 1. ReplaceTxext sql statement: INSERT INTO NiFiUsecase001 (Column1, Column2, Column3, Column4, Column5)
VALUES ('${Column1}', '${Column2}','${Column3}','${Column4}','${Column5}') 2. ConvertJSONToSQL 3.PutSQL
... View more
