Что такое connections Airflow

Python Middle Без компании
Что такое connections Airflow
Ответы
В Airflow **connections** — это способ хранения и управления учетными данными для внешних систем (базы данных, API и т.д.) без хранения их в коде. Они хранятся в метаданных Airflow и могут быть созданы через UI, CLI или API. **Пример создания соединения через UI:** - Перейдите в **Admin → Connections**. - Нажмите **+**, укажите: - **Conn Id** (уникальный идентификатор, например `my_postgres_conn`). - **Conn Type** (тип соединения, например `Postgres`). - **Host, Login, Password, Port** и другие параметры. **Использование в DAG:** ``` from airflow.providers.postgres.hooks.postgres import PostgresHook def query_data(): hook = PostgresHook(postgres_conn_id="my_postgres_conn") df = hook.get_pandas_df("SELECT * FROM table") ``` **Преимущества:** - Безопасность (пароли не в коде). - Централизованное управление. - Поддержка множества коннекторов (HTTP, SSH, облачные сервисы и др.).