问题描述
我试图在 Airfow DAG 中的 Denodo 数据库上查询一些表,但我一直收到相同的错误。这是我在 Airflow 服务器中配置连接的方式:
连接 ID:Denodo_DB
Conn 类型:JDBC 连接
连接网址:jdbc:vdb://oser001.com:9999/admin
密码:pwd
驱动路径:路径
驱动类:com.denodo.vdp.jdbc.Driver
这是我当前的代码:
import jaydebeapi
from builtins import str
from airflow.hooks.jdbc_hook import JdbcHook
SRC_CONN_DENodo = 'Denodo_DB'
def getDenodoConn(*op_args,**context):
print('getDenodoConn() ------ ')
conn_Meta = JdbcHook.get_connection(SRC_CONN_DENodo)
host = str(conn_Meta.host)
login= str(conn_Meta.login)
psw = str(conn_Meta.password)|
jdbc_driver_loc = conn_Meta.extra_dejson.get('extra__jdbc__drv_path')
jdbc_driver_name = conn_Meta.extra_dejson.get('extra__jdbc__drv_clsname')
denodo_conn = jaydebeapi.connect(jclassname=jdbc_driver_name,url=host,driver_args=[login,psw],jars=jdbc_driver_loc)
print('Connected to Denodo database')
jpype._jclass.java.sql.sqlException:java.sql.sqlException:连接错误:OSER001
这是我第一次使用 jaydebeapi 库以及 Denodo 数据库,所以我不确定我是否做对了。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)