#docker #connection #uri #airflow
Вопрос:
Я следил за этой официальной документацией https://airflow.apache.org/docs/apache-airflow/stable/howto/connection.html чтобы попытаться настроить соединения в потоке воздуха. Я хочу получить доступ к uri подключений в моих скриптах python, чтобы я мог работать со своими базами данных.
airflow connections get sqlite_default в баш дает мне подробную информацию о связи. Я хочу сделать аналогичную вещь внутри скрипта python. Как это может быть возможно?
Я сохранил свои подключения к воздушному потоку из пользовательского интерфейса, как указано в документации.
Ответ №1:
Для тех, кто пытается разобраться в этом, я смог получить uri, выполнив следующие действия :
- https://airflow.apache.org/docs/apache-airflow/stable/howto/connection.html показывает, как хранить соединения в потоке воздуха
- Чтобы получить uri подключения
from airflow.hooks.base_hook import BaseHook
BaseHook.get_connection(CONN_ID).get_uri()
предполагается CONN_ID , что это имя сохраненного соединения.