0

我正在使用下面的代码很好地连接到 replicaSet。

今天早上,我们拥有的 2 个副本集实例之一出现故障。

仍然当我使用下面的代码时,在某些情况下我得到了与崩溃的副本集的连接,在其他情况下我得到了与正在运行的副本集的连接。

有什么方法可以防止连接到崩溃的实例。

这是我使用的代码:

    from pymongo import ReplicaSetConnection
    from pymongo import ReadPreference

    # assume I have defined the used variables
    db = ReplicaSetConnection('%s:%s' %(host, port), replicaSet=r_set)[db_name]
    db.read_preference = ReadPreference.SECONDARY_ONLY

谢谢!!

4

0 回答 0