使用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数据库的示例。你可以根据自己的需求执行其他操作,如更新、删除、查找等。记得根据实际情况更改连接字符串、数据库名称和集合名称。
