Search code examples
connection-poolingapache-nifiapache-commons-dbcp

Using dynamic property in connection pooling service for ExecuteSQL processor

I am using ExecuteSQL to get the table from one or more database but i want to provide URL, Username, and password dynamically to the dbcpconnectionPool service so that i won't need more than one ExecuteSQL processor to retrieve data from different DB. It is found that controller service doesn't accept attribute from incoming flow file. So how to achieve it if it is possible. Someone pointed out that it can be achieved only by using rest api, if that is the case please provide a working example along with screenshots. It will be a great help. Thanks in advance.

Solution

  • This is a limitation till NiFi 1.6.0. NIFI-5121 and NIFI-5229 addressed this. The upcoming Apache NiFi 1.7.0 which would hopefully see a release in the next couple of days comes with this feature included.