在 Airflow DAG 上使用 jaydebeapi 从 Denodo 数据库读取数据

如何解决在 Airflow DAG 上使用 jaydebeapi 从 Denodo 数据库读取数据

我试图在 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 数据库，所以我不确定我是否做对了。