2

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

这是一个片段，您可以在其中测试行为。它使用非常有用的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 版本，但没有成功。任何帮助都将非常非常感谢！

4

1 回答 1

0

这里的问题是新主节点的选举不是即时的。从文档：

它会有所不同，但副本集通常会在一分钟内选择一个新的主节点。

例如，副本集的成员可能需要 10-30 秒才能声明主节点不可访问（请参阅electionTimeoutMillis）。其余辅助节点之一举行选举，将自己选为新的主节点。选举期间，集群不可写入。

选举本身可能还需要 10-30 秒。

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

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

首先，您应该在连接上设置读取首选项（更多信息在这里）：

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

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

不幸的是，try如果在选举期间尝试编写代码，如果没有将所有写入包装在块中，您的代码将会失败。

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

于 2016-05-27T15:05:26.947 回答