I have a Snowflake connection defined in Airflow.enter image description here

我使用以下方法 Select 用户、密码和模式:

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

返回登录名(本例中的示例)

如果我试图访问"额外"参数,它不工作.

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

返回AttributeError: 'Connection' object has no attribute 'role'

是否有任何不同的方法可以从气流连接设置中获取额外参数?

推荐答案

存储在extra字段中的额外参数,为了访问这些参数,首先需要使用Connection.extra_dejson属性将其从字符串转换为Python字典.

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

Python相关问答推荐

如何调整spaCy token 化器,以便在德国模型中将数字拆分为行末端的点

如何在箱形图中添加绘制线的传奇?

Python上的Instagram API:缺少client_id参数"

将图像拖到另一个图像

pyscript中的压痕问题

如何在WSL2中更新Python到最新版本(3.12.2)?

Scrapy和Great Expectations(great_expectations)—不合作

多处理队列在与Forking http.server一起使用时随机跳过项目

如何在Python中使用Pandas将R s Tukey s HSD表转换为相关矩阵''

使用tqdm的进度条

使用嵌套对象字段的Qdrant过滤

每次查询的流通股数量

在pandas中,如何在由两列加上一个值列组成的枢轴期间或之后可靠地设置多级列的索引顺序,

Polars定制函数返回多列

对于标准的原始类型注释,从键入`和`从www.example.com `?

如何将一个文件的多列导入到Python中的同一数组中?

EST格式的Azure数据库笔记本中的当前时间戳

在Pandas 中以十六进制显示/打印列?

如何删除剪裁圆的对角线的外部部分

使用Django标签显示信息