要使用 Python 连接到一个远程的三节点 MongoDB 集群，可以使用 `pymongo` 库，它是 Python 中最常用的 MongoDB 客户端库之一。连接集群时，通常需要提供集群中所有节点的地址，以便客户端能够进行负载均衡和故障转移。 ### 使用 `pymongo` 连接到三节点 MongoDB 集群 1. **安装 `pymongo`** 如果尚未安装 `pymongo`，可以通过以下命令进行安装： ```bash pip install pymongo ``` 2. **构建连接字符串** MongoDB 的连接字符串格式如下： ``` mongodb://<user>:<password>@<host1>:<port1>,<host2>:<port2>,<host3>:<port3>/<database>?replicaSet=<replicaSetName> ``` 其中： - `<user>` 和 `<password>` 是数据库的认证凭据（如果启用了认证）。 - `<host1>:<port1>`、`<host2>:<port2>`、`<host3>:<port3>` 是三个节点的地址和端口。 - `<database>` 是默认连接的数据库名称。 - `<replicaSetName>` 是副本集的名称，这是 MongoDB 集群中用于标识一组节点的逻辑名称。 3. **编写连接代码** 下面是一个使用 `pymongo` 连接到三节点 MongoDB 集群的示例代码： ```python from pymongo import MongoClient # MongoDB 连接字符串 uri = "mongodb://username:password@host1:27017,host2:27017,host3:27017/mydatabase?replicaSet=myReplicaSet" # 创建客户端连接 client = MongoClient(uri) # 测试连接是否成功 try: # 获取服务器信息 server_info = client.server_info() print("Connected to MongoDB cluster successfully.") print("Server version:", server_info["version"]) except Exception as e: print("Failed to connect to MongoDB cluster:", e) ``` 4. **处理副本集和负载均衡** `pymongo` 客户端会自动与 MongoDB 集群进行通信，识别副本集的主节点，并在主节点故障时自动切换到其他节点。此外，客户端还支持读取偏好设置，允许将读取操作分配到不同的节点上，以实现负载均衡[^1]。 可以通过设置 `read_preference` 来指定读取操作的偏好节点类型： ```python from pymongo import ReadPreference # 设置读取偏好为从副本集的次要节点读取 client = MongoClient(uri, read_preference=ReadPreference.SECONDARY) ``` 5. **安全连接（SSL/TLS）** 如果 MongoDB 集群启用了 SSL/TLS 加密通信，可以在连接字符串中添加 `ssl=true` 参数，并指定 CA 证书路径（如有必要）： ```python uri = "mongodb://username:password@host1:27017,host2:27017,host3:27017/mydatabase?replicaSet=myReplicaSet&ssl=true&ssl_ca_certs=/path/to/ca.pem" ``` 6. **连接超时和重试策略** 可以配置连接超时时间和重试策略，以增强连接的稳定性： ```python client = MongoClient( uri, connectTimeoutMS=30000, # 30秒连接超时 socketTimeoutMS=30000, # 30秒套接字超时 maxPoolSize=100, # 最大连接池大小 retryWrites=True # 自动重试写操作 ) ``` 通过以上步骤，Python 应用程序可以成功连接到远程三节点 MongoDB 集群，并具备高可用性和负载均衡能力。 --- ###