Microsoft Azure Cosmos¶

Microsoft Azure Cosmos 连接类型启用 Azure Cosmos 集成。

向 Azure 身份验证¶

使用 Airflow 连接到 Azure Cosmos 有三种方法。

使用主密钥，即向 Airflow 连接添加特定凭据（client_id、secret、tenant）和帐户名称。
通过设置managed_identity_client_id、workload_identity_tenant_id（在 hook 下，它使用DefaultAzureCredential和这些参数）使用托管标识。
回退到DefaultAzureCredential。这包括尝试不同选项来进行身份验证的机制：托管系统标识、环境变量、通过 Azure CLI 进行身份验证等。

默认连接 ID¶

所有与 Microsoft Azure Cosmos 相关的 hook 和运算符默认使用azure_cosmos_default。

配置连接¶

登录

指定用于初始连接的 Cosmos 端点 URI。

密码（可选）

指定用于初始连接的 Cosmos 主密钥令牌。可以省略它以回退到DefaultAzureCredential。

其他（可选）

指定可在 Azure Cosmos 连接中使用的额外参数（作为 json 字典）。以下参数均为可选

database_name：指定要使用的 azure cosmos 数据库。
集合名称：指定要使用的 Azure Cosmos 集合。
分区键：指定集合的分区键。
订阅 ID：指定用于初始连接的订阅 ID。用于回退到 DefaultAzureCredential
资源组名称：指定 Azure Cosmos 所在的 Azure 资源组名称。用于回退到 DefaultAzureCredential
托管标识客户端 ID：用户分配的托管标识的客户端 ID。如果与工作负载标识租户 ID 一起提供，它们将传递到 DefaultAzureCredential。
工作负载标识租户 ID：应用程序的 Microsoft Entra 租户 ID。也称为其“目录”ID。如果与托管标识客户端 ID 一起提供，它们将传递到 DefaultAzureCredential。

在环境变量中指定连接时，应使用 URI 语法指定它。

请注意，URI 的所有组件都应进行 URL 编码。

例如

export AIRFLOW_CONN_AZURE_COSMOS_DEFAULT='azure-cosmos://https%3A%2F%2Fairflow.azure.com:master%20key@?database_name=mydatabase&collection_name=mycollection'