如何连接Airflow到oracle数据库

Question

我试图创建一个连接到一个oracle db实例（oracle：薄）使用Airflow。

根据他们的文档，我输入了我的主机名，后跟端口号和SID：

主持人：举个例子。通讯：1524/sid

填写其他字段为：

控制类型：甲骨文

模式：用户名（文档说明：使用您的用户名作为模式）

登录：用户名

密码: * * *

建立连接后，它会为我尝试执行的每个查询（ORA-12514）提供保存错误代码。甲骨文似乎不让气流连接：

ORA-12514： TNS：侦听器当前不知道连接描述符中请求的服务

以前有人遇到过同样的问题吗？我的意思是，对于这样一个大平台来说，连接到数据库不应该是个问题。或者我可能做错了什么。谢谢

版本：气流v1。7.0，Oracle11g

编辑：

Answer 1

对于服务名称的使用，如果将（端口、架构和额外）留空，可以将完整的oracle连接描述符放在主机下：

说明：地址=（协议=TCP）（主机=localhost）（端口=1521）（CONNECT_DATA=（服务器=指定）（SERVICE_NAME=mysidname））

Answer 2

您的连接设置有问题，或者您的设置没有正确加载到oracle挂钩，或者您缺少保存/加载连接设置的python包。你可以通过硬编码你的证书来测试它。

https://github.com/airbnb/airflow/blob/master/airflow/hooks/oracle_hook.py

conn = self.get_connection(self.oracle_conn_id)
dsn = conn.extra_dejson.get('dsn', None)
sid = conn.extra_dejson.get('sid', None)
service_name = conn.extra_dejson.get('service_name', None)
if dsn and sid and not service_name:
    dsn = cx_Oracle.makedsn(dsn, conn.port, sid)
    conn = cx_Oracle.connect(conn.login, conn.password, dsn=dsn)
elif dsn and service_name and not sid:
    dsn = cx_Oracle.makedsn(dsn, conn.port, service_name=service_name)
    conn = cx_Oracle.connect(conn.login, conn.password, dsn=dsn)
else:
    conn = cx_Oracle.connect(conn.login, conn.password, conn.host)

Answer 3

在深入研究了源代码之后，我终于明白了它的工作原理：

控制类型：甲骨文

主持人：举个例子。通用域名格式

模式：用户名

登录：用户名

端口：端口号

额外：{“sid”：“我的sid”，“dsn”：“example.com”}