如何在Django（搭配PyMongo）中高效复用MongoClient连接？

PyMongo的MongoClient本身内置了连接池机制，默认维护着可复用的连接池，频繁创建销毁MongoClient实例会完全浪费这个特性，产生不必要的连接建立/销毁开销。在Django中，你可以通过以下方式实现跨请求复用：

1. 全局单例MongoClient实例（推荐） #

在项目中创建单独模块初始化全局MongoClient实例，所有请求复用该实例：

步骤1：配置Mongo连接参数 #

在settings.py中添加连接配置：

MONGO_URI = "mongodb://localhost:27017/"  # 你的Mongo连接地址
MONGO_DEFAULT_DB = "space"  # 默认使用的数据库

步骤2：创建全局连接模块 #

新建mongo_connection.py：

from pymongo import MongoClient
from django.conf import settings

# 全局复用的MongoClient实例，Django启动时初始化一次
mongo_client = MongoClient(
    settings.MONGO_URI,
    maxPoolSize=100,  # 连接池最大连接数，可根据业务调整
    minPoolSize=10,   # 保持最小空闲连接数，减少重新建连开销
    connect=False     # 懒加载连接，首次使用时才建立连接
)

def get_mongo_db(db_name=None):
    """获取指定数据库实例"""
    target_db = db_name or settings.MONGO_DEFAULT_DB
    return mongo_client[target_db]

步骤3：在视图中使用 #

修改视图函数，直接调用全局数据库实例：

import json
from .mongo_connection import get_mongo_db

def get_all_logs(request):
    req = json.loads(request.body.decode('utf-8'))
    record_id = str(req.get('record_id')).strip()
    db = get_mongo_db('space')
    log_info_with_record_id = list(db.database_alternative.find({'recordID': record_id}))
    # 后续业务处理...

2. 改造现有NewMongoClient为单例模式 #

如果不想放弃现有NewMongoClient包装类，可将其改造为单例模式，确保全局仅存在一个MongoClient实例：

from pymongo import MongoClient
from django.conf import settings

class NewMongoClient:
    _singleton_client = None

    def __init__(self, db='space'):
        self.db_name = db
        # 仅首次初始化时创建MongoClient实例
        if not NewMongoClient._singleton_client:
            NewMongoClient._singleton_client = MongoClient(settings.MONGO_URI)

    def db(self):
        return NewMongoClient._singleton_client[self.db_name]

    # 适配原有的with语句，不再销毁连接
    def __enter__(self):
        return self.db()

    def __exit__(self, exc_type, exc_val, exc_tb):
        # 无需关闭客户端，连接池会自动管理连接
        pass

改造后，视图代码可保持原有调用方式，底层已复用同一连接池：

def get_all_logs(request):
    req = json.loads(request.body.decode('utf-8'))
    record_id = str(req.get('record_id')).strip()
    with NewMongoClient(db='space').db() as db:
        log_info_with_record_id = list(db.database_alternative.find({'recordID': record_id}))

关键注意事项 #

• MongoClient是线程安全的，适配Django多线程请求模型，可安全复用全局实例。
• 不要手动调用client.close()，这会销毁整个连接池，失去复用意义。
• 连接池参数（maxPoolSize、minPoolSize）可根据业务并发量调整，避免连接数过高导致MongoDB负载过大。
• connect=False可让MongoClient延迟建立连接，不影响Django启动速度。

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