MongoDB事务仅支持副本集或分片集群,单机模式不支持;本地开发需用docker启动带replSet的容器并初始化副本集;PyMongo 4.0+默认支持事务,但需显式设置read_concern="snapshot"和write_concern={"w":"majority"},且所有操作必须在同一数据库内。

事务必须在副本集或分片集群中运行,单机模式直接报错
MongoDB 事务不支持 standalone 模式。如果你用 mongod --dbpath 启动单节点,调用 start_transaction() 时会立刻抛出 OperationFailure: Transactions are not supported in sharded clusters with majority read concern disabled 类似错误——即使你没开分片,只是副本集没初始化也会这样。
实操建议:
- 本地开发务必用
docker run -d -p 27017:27017 --name mongo-rs mongo:6.0 --replSet rs0启动,再进容器执行rs.initiate() - 连接字符串里必须带
?replicaSet=rs0,否则 PyMongo 不知道该用哪个 session 类型 - PyMongo 4.0+ 才默认启用事务支持;旧版本要显式传
maxPoolSize=1避免 session 被复用到不同 socket
session.start_transaction() 后必须配对 commit_transaction() 或 abort_transaction()
事务不是“自动提交”或“超时回滚”。PyMongo 不做任何兜底:没调 commit_transaction() 就退出,连接断开,事务状态就卡在 pending,可能阻塞后续操作(比如写冲突检测)。
常见错误现象:
立即学习“Python免费学习笔记(深入)”;
- 代码抛异常但没
except里调abort_transaction(),下次用同一个 session 再 start 会报InvalidOperation: Transaction numbers must be used with a logical session - 用了
with client.start_session()但忘了在 block 里调start_transaction(),结果所有操作都在默认读写级别下执行,根本没进事务
正确写法示例:
with client.start_session() as session:
session.start_transaction()
try:
collection.update_one({"_id": 1}, {"$inc": {"balance": -100}}, session=session)
collection.update_one({"_id": 2}, {"$inc": {"balance": 100}}, session=session)
session.commit_transaction()
except Exception:
session.abort_transaction()
raise
read_concern 和 write_concern 必须显式设置,否则事务可能不生效
默认的 read_concern="local" 和 write_concern=1 在事务里不够安全。比如你读取一个文档后判断余额是否充足,但没设 read_concern="snapshot",另一个事务可能在这期间修改并提交了同一文档,导致你的判断基于过期快照。
参数差异与影响:
-
read_concern="snapshot"是事务内读操作的强制要求(PyMongo 4.4+ 会自动加,但老版本需手动),它保证整个事务看到的是同一时间点的数据视图 -
write_concern={"w": "majority"}必须设,否则事务提交后主节点宕机,未同步到多数节点的操作可能丢失 - 不要设
read_concern="majority"—— 它和snapshot冲突,PyMongo 会静默忽略
事务内不能跨数据库操作,也不能用 mapReduce、$lookup 聚合阶段
PyMongo 报错信息很直白:Transaction numbers cannot be used with commands that operate on multiple databases。哪怕两个 collection 在同一 replicaSet,只要 db1.col 和 db2.col 不同库,就无法在一个事务里更新。
使用场景限制:
- 所有写操作必须指向同一个 database 实例(
client.db.collection),不能混用client.db1.col和client.db2.col -
$lookup如果目标集合在另一库,会直接失败;同库也仅限于非分片集合(sharded collection 的 $lookup 不支持事务) - 像
create_collection()、drop_database()这类管理命令,一律禁止在事务中调用
容易被忽略的一点:事务 session 绑定的是 database 对象,不是 client。所以 client.db1.collection.find_one(..., session=s) 和 client.db2.collection.find_one(..., session=s) 看似用了同一个 session,实际已越界。


















