pymongo事务举例

from pymongo import MongoClient
​
# 连接到 MongoDB 实例
client = MongoClient('mongodb://localhost:27017/')
​
# 获取数据库
db = client['testdb']
​
# 启动一个会话
with client.start_session() as session:
  # 在会话中开启一个事务
  with session.start_transaction():
    # 在事务中执行一些操作
    db.users.insert_one({'username': 'pidancode.com', 'password': '123456'})
​
    # 如果操作失败，则可以抛出异常来回滚事务
    # 注意，如果事务中的任何一个操作失败，整个事务都将被回滚