使用MongoEngine与多进程：如何关闭连接？仍遇MongoClient警告

我完全懂你的困扰——这个警告真的很顽固，哪怕你觉得已经按官方思路做了，还是会跳出来。核心问题其实是MongoEngine底层的PyMongo连接实例会被fork后的子进程继承，哪怕你在父进程里关闭了连接，MongoEngine内部的缓存引用可能还没清理干净，PyMongo的检测机制还是能抓到这个“遗留”的实例，触发警告。

先给你一个能直接跑的最小示例，先解决问题，再讲细节：

from multiprocessing import Process
from mongoengine import connect, disconnect, Document, StringField

# 定义一个简单的测试模型
class TestDocument(Document):
    content = StringField(required=True)

def worker_task():
    # 子进程必须独立初始化连接，绝对不能复用父进程的任何连接对象
    connect(
        db="test_multiprocess",
        host="mongodb://localhost:27017",
        alias="default"  # 如果用了别名，这里要对应
    )
    
    # 执行你的数据库操作
    doc = TestDocument(content="Created in child process")
    doc.save()
    print(f"子进程保存文档ID: {doc.id}")
    
    # 子进程结束后可以断开连接，可选但推荐
    disconnect(alias="default")

if __name__ == "__main__":
    # 模拟父进程前期的数据库操作
    connect(
        db="test_multiprocess",
        host="mongodb://localhost:27017",
        alias="default"
    )
    print("父进程完成初始数据库操作")

    # 关键：用MongoEngine的disconnect彻底清理连接，而不是只调用client.close()
    disconnect(alias="default")
    print("父进程已彻底断开MongoEngine连接")

    # 创建并启动子进程
    worker = Process(target=worker_task)
    worker.start()
    worker.join()

    print("所有进程执行完成")

为什么你之前的操作没生效？ #

你可能只是调用了client.close()来关闭连接，但这只关闭了套接字，MongoEngine内部还缓存着这个已经关闭的MongoClient实例。当你fork子进程时，这个缓存的实例会被继承，PyMongo的检测逻辑会发现它是在fork前创建的，哪怕已经关闭，还是会抛出警告。

而disconnect()方法会彻底清理MongoEngine内部的连接注册表，把所有关联的client实例引用都移除，这样fork后的子进程就不会继承到任何旧的连接对象。

额外注意事项 #

• 处理多别名连接：如果你的项目用了多个数据库连接别名，要确保每个别名都调用disconnect(alias="your_alias")，不能只断开默认连接。
• 避免隐式连接：有些项目会在模块导入时就自动连接数据库（比如在settings文件里调用connect()），这时候要在fork前手动断开这些隐式创建的连接。
• Windows平台的特殊处理：Windows的多进程会重新导入主模块，一定要用if __name__ == "__main__":把连接和fork逻辑包裹起来，避免子进程重复执行父进程的连接代码。
• 不要跨进程传递模型对象：哪怕你处理了连接，也不要把父进程中创建的Document对象传递给子进程，这会携带旧的连接引用，同样可能触发问题。

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