欢迎访问宙启技术站
智能推送

使用Python的connect()方法连接到MicrosoftAzureCosmosDB数据库

发布时间:2023-12-28 01:14:34

连接到Microsoft Azure Cosmos DB数据库可以使用PyMongo库中的MongoClient类。以下是连接到Azure Cosmos DB数据库的步骤:

1. 安装PyMongo库:

pip install pymongo

2. 导入MongoClient类:

from pymongo import MongoClient

3. 创建MongoClient实例:

uri = "<连接字符串>"
client = MongoClient(uri)

连接字符串可以在Azure Cosmos DB首选项中找到。它类似于:

mongodb://用户名:密码@<主机>:10255/?ssl=true&replicaSet=globaldb&retrywrites=false&maxIdleTimeMS=120000&appName=@microsoft.azure.cosmosdb.mongodbchangestreamstest@

4. 选择数据库:

db = client["<数据库名称>"]

<数据库名称>替换为Azure Cosmos DB中的实际数据库名称。如果数据库不存在,将自动创建该数据库。

5. 选择集合:

collection = db["<集合名称>"]

<集合名称>替换为要在数据库中使用的实际集合名称。如果集合不存在,将自动创建该集合。

6. 执行操作:

document = {"name": "John", "age": 30}
result = collection.insert_one(document)

在这个例子中,我们将一个文档插入到集合中。你可以使用insert_one()方法插入一个文档或使用find_one()方法检索一个文档。

7. 关闭连接:

client.close()

一旦完成所有操作,应该关闭数据库连接。

完整的示例代码如下:

from pymongo import MongoClient

uri = "mongodb://用户名:密码@<主机>:10255/?ssl=true&replicaSet=globaldb&retrywrites=false&maxIdleTimeMS=120000&appName=@microsoft.azure.cosmosdb.mongodbchangestreamstest@"
client = MongoClient(uri)

db = client["<数据库名称>"]
collection = db["<集合名称>"]

document = {"name": "John", "age": 30}
result = collection.insert_one(document)
print(result.inserted_id)

client.close()

这是一个简单的连接到Microsoft Azure Cosmos DB数据库的示例。你可以根据自己的需求执行其他操作,如更新、删除、查找等。记得根据实际情况更改连接字符串、数据库名称和集合名称。