如何从 Airflow 的 python 脚本中的 connection_id 获取 uri？答案

【问题标题】：How to get uri from connection_id inside a python script in Airflow?如何从 Airflow 的 python 脚本中的 connection_id 获取 uri？
【发布时间】：2021-07-10 07:48:24
【问题描述】：

我一直在关注这个官方文档https://airflow.apache.org/docs/apache-airflow/stable/howto/connection.html 尝试在 Airflow 中建立连接。我想在我的 python 脚本中访问连接的 uri，以便我可以使用我的数据库。

airflow connections get sqlite_default in bash 为我提供了连接的详细信息。我想在 python 脚本中做类似的事情。怎么可能？

如文档中所述，我已从 UI 中保存了气流连接。

【问题讨论】：

标签： docker connection uri airflow

【解决方案1】：

对于任何想弄清楚这一点的人，我可以通过以下步骤获取 uri：

https://airflow.apache.org/docs/apache-airflow/stable/howto/connection.html 展示了如何在 Airflow 中存储连接
获取连接uri

from airflow.hooks.base_hook import BaseHook
BaseHook.get_connection(CONN_ID).get_uri()

假设CONN_ID 是已保存连接的名称。

【讨论】：