在 ExecuteSQL 处理器的连接池服务中使用动态属性 [英] Using dynamic property in connection pooling service for ExecuteSQL processor

问题描述

我正在使用 ExecuteSQL 从一个或多个数据库中获取表，但我想动态地向 dbcpconnectionPool 服务提供 URL、用户名和密码，这样我就不需要超过一个 ExecuteSQL 处理器来从不同的数据库中检索数据.发现控制器服务不接受来自传入流文件的属性.那么如果可能的话，如何实现它.有人指出它只能通过使用rest api来实现，如果是这种情况，请提供一个工作示例和屏幕截图.这将是一个很大的帮助.提前致谢.

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.

推荐答案

这是 NiFi 1.6.0 之前的限制.NIFI-5121 和 NIFI-5229 解决了这个问题.即将推出的 Apache NiFi 1.7.0 有望在未来几天内发布，其中包含此功能.

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.

这篇关于在 ExecuteSQL 处理器的连接池服务中使用动态属性的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！