Mongo在数据查找时找不到master

Question

我正在使用 pymongo 运行大型数据更新。要运行更新，需要使用collection.find_one(unique criteria)找到各个记录，进行更改，批量更新，最后使用db.collection.save([要保存的长记录列表])

在我的本地计算机（运行 1.6.3）上，导入工作正常。

在比我的本地计算机快得多的远程服务器（运行1.6.0）上，我可以很好地完成部分插入，但在查找原始记录时会突然出现以下错误：

connection = Connection(...)
...
raise AutoReconnect("could not find master/primary")
pymongo.errors.AutoReconnect: could not find master/primary

记录数我能通过的情况有所不同，但不是随机的。

起初我以为我遇到了连接限制。我在每次记录查找后开始手动关闭连接：

collection.database.connection.disconnect()

这并没有解决问题。我走在正确的轨道上吗？

Answer 1

因此，这里存在一些潜在的问题：

raise AutoReconnect("could not find master/primary") 
pymongo.errors.AutoReconnect: could not find master/primary

该错误表明现有连接已以某种方式失效。发生这种情况的原因有很多。

发生这种情况的最常见原因是副本集的主节点已下台或发生故障。在这种情况下，您的代码需要：

1. 捕获（或捕获）错误。
2. 决定重试策略。 （失败？重试一次？...）

你在这样做吗？
您运行的是副本集还是主/从？
您对这些服务器的性能有任何跟踪吗？
他们有网络问题吗？
他们在互换角色吗？

collection.database.connection.disconnect()

这并没有解决问题。我走在正确的道路上吗？

异常“发生”在哪里？它来自连接本身还是保存命令？

在远程服务器上（运行 1.6.0）

在撰写本文时，1.6.0 是 MongoDB 的一个非常旧的版本。在后续的 1.6.x 版本和 1.7.x 版本中修复了多个复制错误。 （我们已经是 1.8.1rc-0）

我会首先查看您的服务器发生的情况，但这很可能会引导您走上升级之路。

Answer 2

我在与 pymongo 的交互式 python 使用中遇到了这个问题，我让会话空闲并在返回时遇到 AutoReconnect 。我是这样处理的：

import functools
import pymongo
import time

MAX_AUTO_RECONNECT_ATTEMPTS = 5

def graceful_auto_reconnect(mongo_op_func):
  """Gracefully handle a reconnection event."""
  @functools.wraps(mongo_op_func)
  def wrapper(*args, **kwargs):
    for attempt in xrange(MAX_AUTO_RECONNECT_ATTEMPTS):
      try:
        return mongo_op_func(*args, **kwargs)
      except pymongo.errors.AutoReconnect as e:
        wait_t = 0.5 * pow(2, attempt) # exponential back off
        time.sleep(wait_t)

  return wrapper

@graceful_auto_reconnect
def some_func_that_does_mongodb_ops():
  ...
  ...

YMMV