NoSQL保障MongoDB数据库副本集和MongoDB副本集操作
from pymongo import MongoClient
# 连接到MongoDB复制集
client = MongoClient('mongodb://user:password@host1:port1,host2:port2,host3:port3/?replicaSet=replicaName')
# 获取数据库和集合
db = client.mydatabase
collection = db.mycollection
# 插入文档
collection.insert_one({"name": "Alice", "age": 30})
# 查询文档
docs = collection.find({"name": "Alice"})
for doc in docs:
print(doc)
# 关闭客户端连接
client.close()这段代码演示了如何使用Python的pymongo库连接到一个MongoDB复制集，并对复制集中的数据执行基本的插入和查询操作。代码中的replicaSet参数用于指定复制集的名称，确保客户端能正确连接到正确的复制集成员。在实际应用中，需要替换user, password, host1, port1, host2, port2, host3, port3, mydatabase, mycollection以及复制集名称replicaName为实际的值。
评论已关闭