MongoDB复制集实战及原理分析

from pymongo import MongoClient
from time import sleep
 
# 连接到MongoDB复制集
def connect_to_replica_set(replica_set_members):
    client = MongoClient(replica_set_members, replicaSet='rs0')
    return client
 
# 等待MongoDB复制集同步完成
def wait_for_replica_set_sync(client):
    while True:
        # 获取集群的状态
        status = client.admin.command('replSetGetStatus')
        # 如果所有成员都已经同步，则返回
        if all(member['stateStr'] == 'SECONDARY' for member in status['members']):
            return
        # 如果没有同步，则等待一段时间后重试
        sleep(1)
 
# 示例：连接到复制集并等待同步
client = connect_to_replica_set(['mongodb1.example.com:27017', 'mongodb2.example.com:27017', 'mongodb3.example.com:27017'])
wait_for_replica_set_sync(client)

这段代码展示了如何使用pymongo库连接到MongoDB复制集，并使用replSetGetStatus命令来检查集群的同步状态。在实际应用中，你需要替换mongodb1.example.com:27017, mongodb2.example.com:27017, 和 mongodb3.example.com:27017为你的实际复制集成员地址和端口。