Created on 12-01-2022 11:32 PM - edited 12-01-2022 11:40 PM
I have requirement to execute a PostgreSQL procedure in Nifi,
I tried to use Put Sql processor , but ended up getting error.
Could someone let me know what I'm doing wrong.
This is how my entire flow looks like.
-querying from a table and putting the record to another stage table using the first 'PutSql' processor. And afterwards the second putsql processor to call my stored procedure.
Created 12-02-2022 06:28 AM
This looks like a pSQL error to me, not NiFi specific.
Maybe you try to insert into a table that doesn't exist (typo?) or the number of columns doesn't match
I think this will help you
Created 12-02-2022 06:58 AM
Thanks @dominikschauer . I tried ExecuteSQL processor to run the Postgres procedure and it ran succesfully.
But I am getting the error while connecting PutSQL processor to ExecuteSQL processor.
As part of my requirement , I need to execute the procedure(ExecuteSQL) after inserting data into a particular table using PutSQL processor. Is there any other way I can achieve this, that is run a procedure after successful insertion to a table.
Thanks in advance