Как ссылаться на соединения, установленные через переменные окружения? - PullRequest
1 голос
/ 28 октября 2019

Я установил соединение с базой данных через переменную среды следующим образом:

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

Должно ли это соединение быть видимым в пользовательском интерфейсе с Conn Id = my_mssql?

Как мне ссылаться на соединение, установленное через переменную окружения?

Причина, по которой я спрашиваю, состоит в том, что приведенный ниже код вызывает исключение, указывающее, что соединение с идентификатором my_mssql отсутствует:

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

airflow.exceptions.AirflowException: conn_id my_mssql не определено

1 Ответ

0 голосов
/ 30 октября 2019

Соединения воздушного потока, созданные с помощью переменных среды, не появятся в пользовательском интерфейсе.

Похоже, что ваша группа обеспечения доступности баз данных не имеет этой переменной среды, если выдает ошибку.

Можете ли вы дваждыпроверить с помощью:

import os
print(os.environ)
...