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]¶