airflow.providers.microsoft.azure.utils¶

屬性¶

`get_sync_default_azure_credential`
`get_async_default_azure_credential`

類¶

AzureIdentityCredentialAdapter

使 azure-identity 憑據與舊版本相容。

函式¶

`get_field`(*, conn_id, conn_type, extras, field_name)	從 extra 中獲取欄位，首先檢查短名稱，然後為了向後相容性檢查帶字首的名稱。
`add_managed_identity_connection_widgets`(func)
`parse_blob_account_url`(host, login)

模組內容¶

airflow.providers.microsoft.azure.utils.get_field(*, conn_id, conn_type, extras, field_name)[source]¶

從 extra 中獲取欄位，首先檢查短名稱，然後為了向後相容性檢查帶字首的名稱。

airflow.providers.microsoft.azure.utils.get_sync_default_azure_credential: functools.partial[azure.identity.DefaultAzureCredential][source]¶

airflow.providers.microsoft.azure.utils.get_async_default_azure_credential: functools.partial[azure.identity.aio.DefaultAzureCredential][source]¶

airflow.providers.microsoft.azure.utils.add_managed_identity_connection_widgets(func)[source]¶

class airflow.providers.microsoft.azure.utils.AzureIdentityCredentialAdapter(credential=None, resource_id='https://management.azure.com/.default', *, managed_identity_client_id=None, workload_identity_tenant_id=None, **kwargs)[source]¶

Bases: msrest.authentication.BasicTokenAuthentication

使 azure-identity 憑據與舊版本相容。

適配來自 azure-identity 的憑據，使其與需要 msrestazure 或 azure.common.credentials 的 SD 相容。

檢視 https://stackoverflow.com/questions/63384092/exception-attributeerror-defaultazurecredential-object-has-no-attribute-sig

set_token()[source]¶

呼叫 azure-core BearerTokenCredentialPolicy 策略以獲取令牌。

使用此策略可以免費獲得 azure-core 的快取系統。我們可以透過使用私有方法來簡化此程式碼，但從定義上來說，我無法保證它們會永遠存在，因此透過模擬對策略的虛假呼叫來提取令牌，並使用 100% 公共 API。

signed_session(azure_session=None)[source]¶

建立應用了所需認證頭部的 requests 會話。

如果提供了會話物件，則直接配置它。否則，建立一個新會話並返回它。

引數:: session (requests.Session) – 用於配置認證的會話
返回型別:: requests.Session

airflow.providers.microsoft.azure.utils.parse_blob_account_url(host, login)[source]¶