时间戳

首页 > 解决方案 > 如何引用通过环境变量设置的连接？

airflow - 如何引用通过环境变量设置的连接？

问题描述

我通过这样的环境变量设置我的数据库连接：

AIRFLOW_CONN_MY_MSSQL=mssql+pyodbc://<user>:<password>@<host>:<port>

此连接是否应该在 UI 中以Conn Id =可见my_mssql？

如何引用通过环境变量设置的连接？

我问的原因是下面的代码抛出一个异常，指出与 id 的连接my_mssql不存在：

ms_hook = MsSqlHook(mssql_conn_id='my_mssql')
ms_connection = ms_hook.get_conn()

airflow.exceptions.AirflowException：my_mssql未定义conn_id

标签： airflow

解决方案

使用环境变量创建的气流连接不会出现在 UI 中。

如果它抛出错误，感觉你的 DAG 没有那个环境变量。

您可以使用以下命令进行仔细检查：

import os
print(os.environ)

推荐阅读