`airflow.providers.microsoft.azure.utils`¶

模块内容¶

类¶

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)

属性¶

`get_sync_default_azure_credential`
`get_async_default_azure_credential`

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

从 extra 获取字段，首先检查短名称，然后为了向后兼容，我们检查前缀名称。

airflow.providers.microsoft.azure.utils.get_sync_default_azure_credential: functools.partial[azure.identity.DefaultAzureCredential][源代码]¶

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

airflow.providers.microsoft.azure.utils.add_managed_identity_connection_widgets(func)[源代码]¶

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)[源代码]¶

基类：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()[源代码]¶

要求 azure-core BearerTokenCredentialPolicy 策略获取令牌。

使用该策略可以免费获得 azure-core 的缓存系统。我们可以通过使用私有方法使此代码更简单，但根据定义，我无法保证它们会永远存在，因此模拟对策略的虚假调用以提取令牌，使用 100% 的公共 API。

signed_session(azure_session=None)[源代码]¶

创建应用了任何所需身份验证标头的请求会话。

如果提供了会话对象，则直接配置它。否则，创建一个新会话并返回它。

参数: session (requests.Session) – 要配置身份验证的会话
返回类型: requests.Session

airflow.providers.microsoft.azure.utils.parse_blob_account_url(host, login)[源代码]¶

airflow.providers.microsoft.azure.utils¶

模块内容¶

类¶

函数¶

属性¶

`airflow.providers.microsoft.azure.utils`¶