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

Question

我通过环境变量设置数据库连接，如下所示：

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

此连接是否在控件Id = my_mssql的UI中可见？

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

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

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

airflow.exceptions.AirflowException: conn_id my_mssql未定义

Answer 1

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

它认为，如果DAG抛出错误，则DAG没有该环境变量。

你能再检查一遍吗？

import os
print(os.environ)