我正在寻找使用 Python 将数据库从一个 Cosmos 帐户迁移到另一个帐户的解决方案。 必须安装哪些 PyPi 软件包才能与 Cosmos 帐户通信并执行数据迁移?我正在尝试使用 Databricks 集群的方法
要使用 Python 与 Cosmos 帐户通信并执行数据迁移,您可以使用 azure-cosmos 包。该包提供了与 Cosmos DB 交互所需的功能和 API。
要安装 azure-cosmos 包,您可以通过运行以下命令来使用
PyPi
包管理器:
!pip install azure-cosmos
您可以设置 Azure Cosmos DB 连接配置,如下所示:
connectionConfig = {
"Endpoint" : "https://<your Azure Cosmos DB account name>.documents.azure.com:443/",
"Masterkey" : "<your Azure Cosmos DB primary key>",
"Database" : "<your database name>",
"preferredRegions" : "West US 2",
"Container": "<your container name>",
"schema_samplesize" : "1000",
"query_pagesize" : "200000",
"query_custom" : "SELECT * FROM c"
}
您还可以参考使用 Azure Cosmos DB 端点实现 Azure Databricks。
这里是如何使用 Python 将批量数据插入 Cosmos DB 的 SO 链接?