python-3.x - MongoEngine ReplicaSet 连接在降级时失败

Question

最近我一直在尝试将 Mongoengine 和 Flask 与 Replica 集一起使用。我可以连接，但是当主节点发生变化时，连接会丢失并且出现中断。

这是一个片段，您可以在其中测试行为。它使用了非常有用的http://flip-flop.mlab.com/调试副本集问题的站点

from flask import Flask
from mongoengine import connect
from flask_mongoengine import MongoEngine
import os
db = MongoEngine()
app = Flask(__name__)


class TestDoc(db.Document):
    texto = db.StringField()


class ProductionConfig:
    def get_conn_data(self):
        conn = {
         'host':"mongodb://testdbuser:testdbpass@flip.mongolab.com:53117,flop.mongolab.com:54117/testdb?replicaSet=rs-flip-flop",
         'replicaSet': 'rs-flip-flop'
    }
        return conn


import time

app.config['MONGODB_SETTINGS'] = ProductionConfig().get_conn_data()
db.init_app(app)

if __name__ == '__main__':
    with app.test_client() as c:
        while True:
            time.sleep(1)
            print(TestDoc.objects().count())
            TestDoc(texto="1").save()

每次主要更改时我都会收到错误: pymongo.errors.AutoReconnect: connection closed
.

非常感谢!我尝试了几个不同的 pyMongo 版本，但没有成功。任何帮助都将非常非常感谢!

Answer 1

这里的问题是新主节点的选举不是即时的。来自 the docs :

It varies, but a replica set will generally select a new primary within a minute.

For instance, it may take 10-30 seconds for the members of a replica set to declare a primary inaccessible (see electionTimeoutMillis). One of the remaining secondaries holds an election to elect itself as a new primary. During the election, the cluster is unavailable for writes.

The election itself may take another 10-30 seconds.

在主节点关闭和副本被选为新主节点之间的时间里，没有连接可以接受写入(因为它们必须去主节点)。

但是，您可以对代码执行一些操作，以使其在这些情况下更具弹性。

首先，您应该在连接上设置读取首选项( more info here ):

    conn = {
     'host':"mongodb://testdbuser:testdbpass@flip.mongolab.com:53117,flop.mongolab.com:54117/testdb",
     'replicaSet': 'rs-flip-flop',
    'read_preference': ReadPreference.SECONDARY_PREFERRED
    } 

这意味着在选举期间读取应该非常强大。

不幸的是，没有将您所有的写入都包含在 try 中。如果在选举期间尝试编写代码，您的代码将会崩溃。

这应该比您的问题示例中看起来的问题要少，因为(假设您正在 flask route 进行写入)网络服务器将抛出 500 错误响应。当您再次从 flask 请求路由时，选举应该已经完成​​，并且 mongoengine 将写入新的主节点。