使用PyMongo连接MongoDB时出现间歇性无响应/挂起问题

问题场景 #

使用PyMongo 3.10连接MongoDB 4.2（Python 3.10环境）时，client.admin.command('ping')及其他数据库操作会间歇性出现无响应挂起的情况。即使添加了socketTimeoutMS、serverSelectionTimeoutMS等超时参数，程序仍无限期卡住，且不会抛出任何异常。

用户原始测试代码：

from pymongo import MongoClient
client = MongoClient(mongo_url)
print("Starting to ping")
ping = client.admin.command('ping')
print("Completed ping")

添加超时参数后的代码仍无改善：

from pymongo import MongoClient
client = MongoClient(mongo_url, waitQueueTimeoutMS=5000, socketTimeoutMS=5000,
                     serverSelectionTimeoutMS=5000, connectTimeoutMS=5000, maxPoolSize=100)
try:
    print("Starting to ping")
    ping = client.admin.command('ping')
    print("Completed ping")
except ConnectionFailure:
    print("Server not available")
except pymongo.errors.PyMongoError as e:
    print("Pymongo error: " + str(e))
except Exception as exc:
    print("Exception: " + str(exc))

可能原因 #

• 版本兼容性问题：PyMongo 3.10发布于2020年，早于Python 3.10（2021年发布），旧版本驱动对新Python版本的网络IO处理存在兼容性bug，导致超时机制失效。
• 连接池配置不合理：maxPoolSize=100设置过大，结合网络波动可能导致连接池中的连接处于假死状态，无法触发超时逻辑。
• 服务器端异常：MongoDB服务器存在连接队列阻塞、资源耗尽（CPU/内存过高）、网络分区等问题，导致客户端连接无法正常通信。

解决方案 #

1. 升级PyMongo到兼容版本
   PyMongo 4.0及以上版本正式支持Python 3.10，升级后超时机制的实现更稳定。执行升级命令：

pip install --upgrade pymongo>=4.0

2. 调整连接参数并启用心跳检测
   添加heartbeatFrequencyMS参数定期检测连接状态，同时适度调小连接池大小，修改后的代码：

from pymongo import MongoClient
from pymongo.errors import ConnectionFailure, PyMongoError

client = MongoClient(
    mongo_url,
    socketTimeoutMS=5000,
    connectTimeoutMS=5000,
    serverSelectionTimeoutMS=5000,
    heartbeatFrequencyMS=1000,  # 每秒检测一次连接心跳，及时发现失效连接
    maxPoolSize=50  # 适度调小连接池，避免资源过度占用
)

try:
    print("Starting to ping")
    client.admin.command('ping')
    print("Completed ping")
except ConnectionFailure:
    print("Server not available")
except PyMongoError as e:
    print(f"Pymongo error: {str(e)}")
except Exception as exc:
    print(f"Exception: {str(exc)}")

3. 检查MongoDB服务器状态
   查看MongoDB服务器日志，确认是否存在：

• 连接超时或拒绝连接的日志条目
• CPU、内存占用过高的情况
• 防火墙或网络策略限制了客户端与服务器的通信

4. 启用PyMongo调试日志
   添加日志配置，查看挂起时的内部操作细节，帮助定位问题：

import logging
logging.basicConfig(level=logging.DEBUG)
logging.getLogger('pymongo').setLevel(logging.DEBUG)

内容的提问来源于stack exchange，提问作者George