MongoDB中Connections与Sessions的区别及使用疑问

一、Connection与Session的本质差异 #

• Connection（连接）：是客户端和MongoDB服务器之间的物理TCP链路，负责数据传输。客户端通常用连接池管理多个连接，避免频繁创建销毁带来的性能损耗，一个连接可以承载多个逻辑会话。
• Session（逻辑会话）：是MongoDB服务器端维护的逻辑上下文，存在于服务器缓存中（默认5分钟自动清理，可配置）。它和底层连接解耦，用来串联一系列操作，实现特定功能。

二、Session的核心作用 #

• 事务支持：MongoDB的多文档事务必须绑定到会话，会话保证事务内所有操作在统一上下文执行，确保ACID特性。
• 因果一致性：借助会话可以保证读写操作的因果顺序，避免分布式环境下读取到过期的复制数据。
• 操作追踪：服务器通过会话ID关联同一客户端的一系列操作，方便日志审计、性能排查。
• 可重试写入：开启会话后，客户端可以安全重试部分写操作，服务器会通过会话ID识别重复请求，防止重复执行。

三、同一会话执行多集合操作的行为 #

用同一个会话操作不同集合，具体表现为：

• 共享上下文：所有操作关联同一个会话ID，服务器统一维护会话的状态（比如事务状态、一致性标记）。
• 事务内跨集合操作：如果开启了事务，同一会话内对多个集合的读写操作会被纳入同一个事务，提交或回滚会作用于所有操作。
• 非事务场景：没有事务的情况下，同一会话下的多集合操作就是独立执行的普通请求，只是共享会话的元数据，不会互相干扰结果。

四、PyMongo与MongoEngine中的会话实践 #

PyMongo #

通过client.start_session()创建会话，操作时指定session参数即可：

from pymongo import MongoClient

client = MongoClient()
# 自动管理会话生命周期
with client.start_session() as session:
    # 跨集合查询
    db = client.test_db
    db.col1.find_one(session=session)
    db.col2.insert_one({"key": "demo"}, session=session)
    
    # 会话内开启事务
    with session.start_transaction():
        db.col3.update_one({"_id": 1}, {"$set": {"status": "active"}}, session=session)
        db.col4.delete_one({"_id": 2}, session=session)

注意：务必正确关闭会话（用with语句或手动调用end_session()），否则服务器缓存会被占用，可能触发TooManyLogicalSessions错误。

MongoEngine #

MongoEngine基于PyMongo封装，会话使用可以通过客户端对象创建后传入操作：

from mongoengine import connect, Document, StringField

# 连接数据库
connect("test_db")

# 定义文档模型
class CollectionA(Document):
    name = StringField()

class CollectionB(Document):
    content = StringField()

# 获取底层PyMongo客户端
client = connect().client
with client.start_session() as session:
    # 会话内执行跨集合查询
    CollectionA.objects(session=session).first()
    CollectionB(session=session).objects.create(content="test_content")
    
    # 会话内执行事务
    with session.start_transaction():
        CollectionA(session=session).objects(id=1).update(set__name="updated_name")
        CollectionB(session=session).objects(id=2).delete()

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