ExecuteSQL 什么都不做
ExecuteSQL does nothing
我正在尝试通过 Nifi 从 oracle 数据库中获取数据。在 canvas 中,我将文件大小为 0 KB 的 "GenerateFlowFile" 处理器安排为每 5 分钟 运行。这只是为了在成功时触发 "ExecuteSQL" 处理器。对于 "ExecuteSQL",我将 DB Connection Pooling Service 设置为 DBCPConnectionPool。我输入 SQL 查询 "SELECT * FROM SOMETABLE"。我的DBCPConnectionPool配置如下:
URL = jdbc:oracle:thin:@hostname:port:sid
Driver = oracle.jdbc.driver.OracleDriver
Jar URL = file:///somelocation/ojdbc6.jar
User = someuser
Password = somepassword
当我尝试 运行 时,没有任何反应。红色框变为绿色,"ExecuteSQL" 处理器右上角有一个数字 1。但是没有任何反应。然后当我停止它时,活动线程仍然是 1.
可以请告诉我,因为我是新手吗?谢谢。
既然原来的post已经回答了,我会在评论中回复这个问题:
您可以将 GenerateFlowFile 处理器设置为 运行 每 30 秒左右,然后启动并立即停止它。这将导致 ExecuteSQL 运行 恰好一次,获取所有行。
或者(在 NiFi 0.6.0+ 中)您可以使用 QueryDbTable 处理器,它将第一次获取所有行,然后(基于最大值列,如增加的主键)仅添加了 return 行。
我正在尝试通过 Nifi 从 oracle 数据库中获取数据。在 canvas 中,我将文件大小为 0 KB 的 "GenerateFlowFile" 处理器安排为每 5 分钟 运行。这只是为了在成功时触发 "ExecuteSQL" 处理器。对于 "ExecuteSQL",我将 DB Connection Pooling Service 设置为 DBCPConnectionPool。我输入 SQL 查询 "SELECT * FROM SOMETABLE"。我的DBCPConnectionPool配置如下:
URL = jdbc:oracle:thin:@hostname:port:sid
Driver = oracle.jdbc.driver.OracleDriver
Jar URL = file:///somelocation/ojdbc6.jar
User = someuser
Password = somepassword
当我尝试 运行 时,没有任何反应。红色框变为绿色,"ExecuteSQL" 处理器右上角有一个数字 1。但是没有任何反应。然后当我停止它时,活动线程仍然是 1.
可以请告诉我,因为我是新手吗?谢谢。
既然原来的post已经回答了,我会在评论中回复这个问题:
您可以将 GenerateFlowFile 处理器设置为 运行 每 30 秒左右,然后启动并立即停止它。这将导致 ExecuteSQL 运行 恰好一次,获取所有行。
或者(在 NiFi 0.6.0+ 中)您可以使用 QueryDbTable 处理器,它将第一次获取所有行,然后(基于最大值列,如增加的主键)仅添加了 return 行。