从 Airflow Connection 检索额外参数

Question

我在 Airflow 中定义了 Snowflake 连接。

我使用以下内容选择用户、密码和架构：

conn = BaseHook.get_connection("snowflake_conn")
conn.login

返回登录信息（本例中为示例）

如果我尝试访问“额外”参数，它不起作用。

conn = BaseHook.get_connection("snowflake_conn")
conn.role

返回 AttributeError: 'Connection' 对象没有属性 'role'

有什么不同的方式可以从气流连接设置中获取额外的参数吗？

Answer 1

额外参数存储在

extra

字段中，要访问该参数，您需要首先使用

Connection.extra_dejson

属性将其从字符串转换为 python 字典

conn = BaseHook.get_connection("snowflake_conn")
conn.extra_dejson.get("role")