首页/数据/数据工程与 ETL 速查/Airflow Connections 连接管理
本包目录(311 条)

Airflow Connections 连接管理

Connections 集中保存数据库、API 等外部系统的连接信息,DAG 里只引用 conn_id,凭据不落代码;可在界面、环境变量或 CLI 维护,生产建议接 Secrets Backend。

引用方式conn_id(如 mysql_dw)
权限连接可配置 team/role 可见性
密码存储元数据库加密存储,或接 Vault 等后端
环境变量AIRFLOW_CONN_<CONN_ID> 传连接 URI

CLI 管理连接

CLI 管理连接
airflow connections add mysql_dw \
  --conn-type mysql \
  --conn-host 10.0.0.10 --conn-port 3306 \
  --conn-login etl --conn-password '***'
airflow connections list

环境变量方式

环境变量方式
export AIRFLOW_CONN_MYSQL_DW='mysql://etl:***@10.0.0.10:3306/dw'
DAG 代码里出现明文密码是评审常见扣分项;统一用 conn_id 加环境变量或密钥后端。

易错点

  • conn_id 在不同环境指向不同库,切环境时忘改连接会写错库
  • 连接信息更新后 worker 未刷新缓存,任务仍使用旧配置

数据来源与参考

  • Apache Airflow 官方文档:Managing Connections
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌