我想知道如何才能檢索到存盤在airflow中作為連接ID的azure連接字串值。
我使用azure_conn呼叫了azure blob存盤的連接ID,如下所示。我想知道如何才能從這個變數azure_conn回傳連接字串
azure_conn = WasbHook(wasb_conn_id='wasb_conn_id')
變數azure_conn的型別是
<class 'airflow.providers.microsoft.azure.hooks.wasbHook'>
uj5u.com熱心網友回復:
WasbHook可以訪問從BaseHook繼承的get_connection()方法(見這里)。 您可以像現在這樣實體化WasbHook,然后呼叫get_connection()方法,從您設定的Azure Blob存盤連接中檢索屬性。
hook = WasbHook(wasb_conn_id='wasb_conn_id')
conn = hook.get_connection(hook.conn_id)
print(conn.extra_dejson) # 檢索連接字串。
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/308862.html
標籤:
