如何在“ExecuteGroovyScript"处理器中使用“DBCPConnectionPoolLookup"? [英] How to use 'DBCPConnectionPoolLookup' in 'ExecuteGroovyScript' processor?
本文介绍了如何在“ExecuteGroovyScript"处理器中使用“DBCPConnectionPoolLookup"?的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我想在ExecuteGroovyScript"处理器中使用DBCPConnectionPoolLookup"控制器服务.我设置了 'database.name' 但我收到这个错误:
这是ExecuteGroovyScript"配置:
我发现有人遇到了
这是我的配置:
请告诉我是什么问题?
更新:我从代码中删除了 try/catch 并收到以下错误:
使用SQL.db:
使用CTL.sql:
完整日志:
2019-10-17 22:27:12,685 错误 [Timer-Driven Process Thread-10] oanpgroovyx.ExecuteGroovyScript ExecuteGroovyScript[id=bb9d644c-016d-1000-5485-c9fbfni]processor.exception.ProcessException:java.sql.SQLException:无法获得连接，池错误等待空闲对象超时:org.apache.nifi.processor.exception.ProcessException:java.sql.SQLException:无法获得连接，池错误等待空闲对象超时org.apache.nifi.processor.exception.ProcessException:java.sql.SQLException:无法获得连接，池错误超时等待空闲对象在 org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:474)在 org.apache.nifi.dbcp.DBCPService.getConnection(DBCPService.java:49)在 sun.reflect.GeneratedMethodAccessor1514.invoke(未知来源)在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)在 java.lang.reflect.Method.invoke(Method.java:498)在 org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)在 com.sun.proxy.$Proxy100.getConnection(来源不明)在 org.apache.nifi.dbcp.DBCPService$getConnection.call(来源不明)在 Scriptffffffffa8c699bc.run(Scriptffffffffa8c699bc.groovy:8)在 org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onTrigger(ExecuteGroovyScript.java:449)在 org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)在 org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)在 org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209)在 org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)在 org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)在 java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)在 java.lang.Thread.run(Thread.java:748)引起:java.sql.SQLException:无法获得连接，池错误超时等待空闲对象在 org.apache.commons.dbcp2.PoolingDataSource.getConnection(PoolingDataSource.java:142)在 org.apache.commons.dbcp2.BasicDataSource.getConnection(BasicDataSource.java:1563)在 org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:470)...省略了21个常用帧引起:java.util.NoSuchElementException:等待空闲对象超时在 org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:451)在 org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:365)在 org.apache.commons.dbcp2.PoolingDataSource.getConnection(PoolingDataSource.java:134)...省略了23个常用帧2019-10-17 22:27:13,194 错误 [Timer-Driven Process Thread-10] oanpgroovyx.ExecuteGroovyScript ExecuteGroovyScript[id=bb9d644c-016d-1000-5485-c915da52.bbfion]exceptProcess.bbfion.Exceptionnijava.sql.SQLException:无法获得连接，池错误超时等待空闲对象:org.apache.nifi.processor.exception.ProcessException:java.sql.SQLException:无法获得连接，池错误超时等待空闲对象org.apache.nifi.processor.exception.ProcessException:java.sql.SQLException:无法获得连接，池错误超时等待空闲对象在 org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:474)在 org.apache.nifi.dbcp.DBCPService.getConnection(DBCPService.java:49)在 sun.reflect.GeneratedMethodAccessor1514.invoke(未知来源)在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)在 java.lang.reflect.Method.invoke(Method.java:498)在 org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)在 com.sun.proxy.$Proxy100.getConnection(来源不明)在 org.apache.nifi.dbcp.DBCPService$getConnection.call(来源不明)在 Scriptffffffffa8c699bc.run(Scriptffffffffa8c699bc.groovy:8)在 org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onTrigger(ExecuteGroovyScript.java:449)在 org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)在 org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)在 org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209)在 org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)在 org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)在 java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)在 java.lang.Thread.run(Thread.java:748)引起:java.sql.SQLException:无法获得连接，池错误超时等待空闲对象在 org.apache.commons.dbcp2.PoolingDataSource.getConnection(PoolingDataSource.java:142)在 org.apache.commons.dbcp2.BasicDataSource.getConnection(BasicDataSource.java:1563)在 org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:470)...省略了21个常用帧引起:java.util.NoSuchElementException:等待空闲对象超时在 org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:451)在 org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:365)在 org.apache.commons.dbcp2.PoolingDataSource.getConnection(PoolingDataSource.java:134)...省略了23个常用帧2019 年 10 月 17 日 22:31:58,045 警告 [计时器驱动的进程线程 4] oancontroller.tasks.ConnectableTask 行政上产生 ExecuteGroovyScript[id=bb9d644c-016d-1000-5485-c915da52d.Exception].ClassCastException: com.sun.proxy.$Proxy128 不能转换为 org.apache.nifi.processors.groovyx.sql.OSqljava.lang.ClassCastException: com.sun.proxy.$Proxy128 不能转换为 org.apache.nifi.processors.groovyx.sql.OSql在 org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onFinitSQL(ExecuteGroovyScript.java:371)在 org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onTrigger(ExecuteGroovyScript.java:464)在 org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)在 org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)在 org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209)在 org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)在 org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)在 java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)在 java.lang.Thread.run(Thread.java:748)2019-10-17 22:31:59,045 错误 [Timer-Driven Process Thread-2] oanpgroovyx.ExecuteGroovyScript ExecuteGroovyScript[id=bb9d644c-016d-1000-5485-c915daProcessorg.apacheorfion.exception]属性必须包含属性名称database.name":org.apache.nifi.processor.exception.ProcessException:属性必须包含属性名称database.name"org.apache.nifi.processor.exception.ProcessException:属性必须包含属性名称database.name"在 org.apache.nifi.dbcp.DBCPConnectionPoolLookup.getConnection(DBCPConnectionPoolLookup.java:124)在 sun.reflect.GeneratedMethodAccessor1514.invoke(未知来源)在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)在 java.lang.reflect.Method.invoke(Method.java:498)在 org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)在 com.sun.proxy.$Proxy128.getConnection(来源不明)在 org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onInitSQL(ExecuteGroovyScript.java:339)在 org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onTrigger(ExecuteGroovyScript.java:439)在 org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)在 org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)在 org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209)在 org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)在 org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)在 java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)在 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)在 java.lang.Thread.run(Thread.java:748)SQL.db 的脚本代码:
flowFile = session.get()if(!flowFile) 返回def RawData =flowFile.read().getText("UTF-8")def JobId = flowFile.ExtractJobIddef params = [RawData,JobId]def result = SQL.db.executeInsert("INSERT INTO ExtractFiles (RawData,JobId,CreateTimestamp,UpdateTimestamp) VALUES (?,?,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP)",params)flowFile.'ExtractFileId' = 结果[0][0]REL_SUCCESS <<流文件CTL.sql 的脚本代码:
导入groovy.sql.SqlflowFile = session.get()if(!flowFile) 返回def RawData =flowFile.read().getText("UTF-8")def JobId = flowFile.ExtractJobIddef params = [RawData,JobId]def myDbConnection = CTL.sql.getConnection(flowFile.getAttributes())def myClientDb = new Sql(myDbConnection)def result = myClientDb.executeInsert("INSERT INTO ExtractFiles (RawData,JobId,CreateTimestamp,UpdateTimestamp) VALUES (?,?,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP)",params)flowFile.'ExtractFileId' = 结果[0][0]REL_SUCCESS <<流文件解决方案
我使用CTL对象并编辑代码解决问题:
导入groovy.sql.SqlflowFile = session.get()if(!flowFile) 返回def dbConnection = CTL.db.getConnection(flowFile.getAttributes())def clientDb = 新的 Sql(dbConnection)尝试 {def RawData =flowFile.read().getText("UTF-8")def JobId = flowFile.ExtractJobIddef params = [RawData,JobId]def result = clientDb.executeInsert("INSERT INTO ExtractFiles (RawData,JobId,CreateTimestamp,UpdateTimestamp) VALUES (?,?,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP)",params)flowFile.'ExtractFileId' = 结果[0][0]REL_SUCCESS <<流文件} 捕获(异常 e){扔e;} 最后 {clientDb.close();}我添加了 clientDb.close()，正如
I want to use 'DBCPConnectionPoolLookup' controller service in 'ExecuteGroovyScript' processor. I set 'database.name' But I get this Error:
This is 'ExecuteGroovyScript' configs:
I found someone who had same problem and solved it here, but his approach to solve the problem is not complete.
I think I should use CTL as described in answer part of this question but I got this Error:
This is my config:
Please let me know what is the problem?
update: I removed try/catch from code and got these errors:
Using SQL.db:
Using CTL.sql:
Full log:
2019-10-17 22:27:12,685 ERROR [Timer-Driven Process Thread-10] o.a.n.p.groovyx.ExecuteGroovyScript ExecuteGroovyScript[id=bb9d644c-016d-1000-5485-c915da52bbfb] org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot get a connection, pool error Timeout waiting for idle object: org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot get a connection, pool error Timeout waiting for idle object
org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot get a connection, pool error Timeout waiting for idle object
at org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:474)
at org.apache.nifi.dbcp.DBCPService.getConnection(DBCPService.java:49)
at sun.reflect.GeneratedMethodAccessor1514.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)
at com.sun.proxy.$Proxy100.getConnection(Unknown Source)
at org.apache.nifi.dbcp.DBCPService$getConnection.call(Unknown Source)
at Scriptffffffffa8c699bc.run(Scriptffffffffa8c699bc.groovy:8)
at org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onTrigger(ExecuteGroovyScript.java:449)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.sql.SQLException: Cannot get a connection, pool error Timeout waiting for idle object
at org.apache.commons.dbcp2.PoolingDataSource.getConnection(PoolingDataSource.java:142)
at org.apache.commons.dbcp2.BasicDataSource.getConnection(BasicDataSource.java:1563)
at org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:470)
... 21 common frames omitted
Caused by: java.util.NoSuchElementException: Timeout waiting for idle object
at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:451)
at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:365)
at org.apache.commons.dbcp2.PoolingDataSource.getConnection(PoolingDataSource.java:134)
... 23 common frames omitted
2019-10-17 22:27:13,194 ERROR [Timer-Driven Process Thread-10] o.a.n.p.groovyx.ExecuteGroovyScript ExecuteGroovyScript[id=bb9d644c-016d-1000-5485-c915da52bbfb] org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot get a connection, pool error Timeout waiting for idle object: org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot get a connection, pool error Timeout waiting for idle object
org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot get a connection, pool error Timeout waiting for idle object
at org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:474)
at org.apache.nifi.dbcp.DBCPService.getConnection(DBCPService.java:49)
at sun.reflect.GeneratedMethodAccessor1514.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)
at com.sun.proxy.$Proxy100.getConnection(Unknown Source)
at org.apache.nifi.dbcp.DBCPService$getConnection.call(Unknown Source)
at Scriptffffffffa8c699bc.run(Scriptffffffffa8c699bc.groovy:8)
at org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onTrigger(ExecuteGroovyScript.java:449)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.sql.SQLException: Cannot get a connection, pool error Timeout waiting for idle object
at org.apache.commons.dbcp2.PoolingDataSource.getConnection(PoolingDataSource.java:142)
at org.apache.commons.dbcp2.BasicDataSource.getConnection(BasicDataSource.java:1563)
at org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:470)
... 21 common frames omitted
Caused by: java.util.NoSuchElementException: Timeout waiting for idle object
at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:451)
at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:365)
at org.apache.commons.dbcp2.PoolingDataSource.getConnection(PoolingDataSource.java:134)
... 23 common frames omitted
2019-10-17 22:31:58,045 WARN [Timer-Driven Process Thread-4] o.a.n.controller.tasks.ConnectableTask Administratively Yielding ExecuteGroovyScript[id=bb9d644c-016d-1000-5485-c915da52bbfb] due to uncaught Exception: java.lang.ClassCastException: com.sun.proxy.$Proxy128 cannot be cast to org.apache.nifi.processors.groovyx.sql.OSql
java.lang.ClassCastException: com.sun.proxy.$Proxy128 cannot be cast to org.apache.nifi.processors.groovyx.sql.OSql
at org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onFinitSQL(ExecuteGroovyScript.java:371)
at org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onTrigger(ExecuteGroovyScript.java:464)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2019-10-17 22:31:59,045 ERROR [Timer-Driven Process Thread-2] o.a.n.p.groovyx.ExecuteGroovyScript ExecuteGroovyScript[id=bb9d644c-016d-1000-5485-c915da52bbfb] org.apache.nifi.processor.exception.ProcessException: Attributes must contain an attribute name 'database.name': org.apache.nifi.processor.exception.ProcessException: Attributes must contain an attribute name 'database.name'
org.apache.nifi.processor.exception.ProcessException: Attributes must contain an attribute name 'database.name'
at org.apache.nifi.dbcp.DBCPConnectionPoolLookup.getConnection(DBCPConnectionPoolLookup.java:124)
at sun.reflect.GeneratedMethodAccessor1514.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)
at com.sun.proxy.$Proxy128.getConnection(Unknown Source)
at org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onInitSQL(ExecuteGroovyScript.java:339)
at org.apache.nifi.processors.groovyx.ExecuteGroovyScript.onTrigger(ExecuteGroovyScript.java:439)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:209)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Script Code for SQL.db:
flowFile = session.get()
if(!flowFile) return
def RawData =flowFile.read().getText("UTF-8")
def JobId = flowFile.ExtractJobId
def params = [RawData,JobId]
def result = SQL.db.executeInsert("INSERT INTO ExtractFiles (RawData,JobId,CreateTimestamp,UpdateTimestamp) VALUES (?,?,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP)",params)
flowFile.'ExtractFileId' = result[0][0]
REL_SUCCESS << flowFile
Script code for CTL.sql:
import groovy.sql.Sql
flowFile = session.get()
if(!flowFile) return
def RawData =flowFile.read().getText("UTF-8")
def JobId = flowFile.ExtractJobId
def params = [RawData,JobId]
def myDbConnection = CTL.sql.getConnection(flowFile.getAttributes())
def myClientDb = new Sql(myDbConnection)
def result = myClientDb.executeInsert("INSERT INTO ExtractFiles (RawData,JobId,CreateTimestamp,UpdateTimestamp) VALUES (?,?,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP)",params)
flowFile.'ExtractFileId' = result[0][0]
REL_SUCCESS << flowFile
解决方案
I used CTL object and edited the code to solve the problem:
import groovy.sql.Sql
flowFile = session.get()
if(!flowFile) return
def dbConnection = CTL.db.getConnection(flowFile.getAttributes())
def clientDb = new Sql(dbConnection)
try {
def RawData =flowFile.read().getText("UTF-8")
def JobId = flowFile.ExtractJobId
def params = [RawData,JobId]
def result = clientDb.executeInsert("INSERT INTO ExtractFiles (RawData,JobId,CreateTimestamp,UpdateTimestamp) VALUES (?,?,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP)",params)
flowFile.'ExtractFileId' = result[0][0]
REL_SUCCESS << flowFile
} catch (Exception e) {
throw e;
} finally {
clientDb.close();
}
I added clientDb.close() as @daggett said in comments.
这篇关于如何在“ExecuteGroovyScript"处理器中使用“DBCPConnectionPoolLookup"?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
查看全文
