【mongodb】mongodb副本集的搭建和使用

以下是搭建MongoDB副本集和连接副本集的示例代码：

from pymongo import MongoClient
 
# 连接副本集
def connect_to_replica_set(replica_set_name, hosts):
    client = MongoClient(
        f"mongodb://{replica_set_name}/test_database?replicaSet={replica_set_name}",
        host=hosts
    )
    return client
 
# 搭建副本集
def setup_replica_set(primary_host, secondary_hosts):
    # 连接到主节点
    primary_client = MongoClient(primary_host)
    admin_db = primary_client.admin
 
    # 初始化副本集配置
    config = {
        "_id": "rs0",
        "members": [
            {"_id": 0, "host": primary_host},
            # 添加副本集成员
            # 例如: {"_id": 1, "host": "mongodb1:27017"}
        ]
    }
 
    # 将配置应用到副本集
    admin_db.command("replSetInitiate", config)
 
    # 添加额外的副本集成员
    # 例如:
    # admin_db.command("replSetReconfig", new_config)
 
 
# 假设副本集名称为 "rs0"，主节点地址为 "mongodb0:27017"，副本节点地址为 "mongodb1:27017"
setup_replica_set("mongodb0:27017", ["mongodb1:27017"])
 
# 连接副本集
client = connect_to_replica_set("rs0", "mongodb0:27017")
 
# 使用client进行数据库操作

这段代码展示了如何使用Python的pymongo库来搭建一个MongoDB副本集，并且如何连接到这个副本集。在setup_replica_set函数中，你需要提供主节点的地址和副本节点的地址列表。在connect_to_replica_set函数中，你需要提供副本集的名称和主节点的地址。

请注意，这个示例假设你已经有了运行在指定端口上的MongoDB实例。在生产环境中，你需要确保所有的MongoDB实例都配置正确，并且网络通信是可行的。