如何在 Python 中从 MongoDB 和 PyMongo 捕获操作失败

Question

我一直遇到一个问题，在我通过 pymongo 与 mongohq 的 mongodb 连接空闲一段时间（没有查询）后，它会超时。这很好，但是数据库的连接仅在 Django 应用程序启动时创建。看起来重新连接正常，但需要重新进行身份验证。当连接断开并重新连接并且查询尝试运行时，它会引发 OperationFailure 和以下异常值数据库错误：未经授权的 db [shanereustle] 锁类型：-1 code> 告诉我它正在重新连接，但没有进行身份验证。我已经从 pymongo.errors 导入了 OperationFailure 并一直在尝试使用以下 try... except 但我似乎无法捕获错误并进行身份验证。

try:
    db.mongohq.shanereustle.blog.find()
except OperationFailure:
    db.authenticate() #this function reauthenticates the existing connection

但由于某种原因，这并没有抓住。如果我不使用此代码，而是在查询之前运行 db.authenticate() ，它将很好地重新进行身份验证，但我不想在每个查询上重新进行身份验证。非常欢迎有关正确方法的其他建议，我很感谢您的帮助。

谢谢！

Answer 1

您可以尝试使用 find_one() 而不是 find() 吗？后者不会自动遍历光标。

我刚刚用 --auth 数据库尝试过，它有效：

try:
  connection.test.foo.find_one()
except pymongo.errors.OperationFailure:
  print "caught"