从气流连接 ID 中检索 azure blob 存储连接字符串答案

【问题标题】：Retrieve azure blob storage connection string from airflow connection id从气流连接 ID 中检索 azure blob 存储连接字符串
【发布时间】：2021-11-11 11:04:26
【问题描述】：

我正在尝试查看如何检索存储在气流中的 azure 连接字符串值作为连接 ID。

我使用azure_conn 调用了azure blob 存储连接ID，如下所示。我想看看如何从这个变量azure_conn返回连接字符串@

azure_conn = WasbHook(wasb_conn_id='wasb_conn_id')

变量 azure_conn 的类型

<class 'airflow.providers.microsoft.azure.hooks.wasb.WasbHook'>

【问题讨论】：

标签： azure airflow azure-storage connection-string

【解决方案1】：

WasbHook 可以访问从BaseHook 继承的get_connection() 方法（请参阅here）。您可以像现在一样实例化 WasbHook，然后调用 get_connection() 方法从您设置的 Azure Blob 存储连接中检索属性。

hook = WasbHook(wasb_conn_id='wasb_conn_id')
conn = hook.get_connection(hook.conn_id)
print(conn.extra_dejson) # To retrieve the connection string

【讨论】：