从气流连接 id 中检索 azure blob 存储连接字符串

Question

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

我使用 azure_conn 调用了 azure blob 存储连接 ID，如下所示。我正在尝试查看如何 return 从这个变量 azure_conn

返回连接字符串

azure_conn = WasbHook(wasb_conn_id='wasb_conn_id')

变量azure_conn的类型是

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

Answer 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

Retrieve azure blob storage connection string from airflow connection id