Mongodb 的事务在python中的操做

代码实现以下：

import pymongo

mgClient = pymongo.MongoClient("ip", "port")
session = mgClient.start_session()

a_collection = mgClient.get_database("库").集合名a
b_collection = mgClient.get_database("库").集合名b

# 事务开始
session.start_transaction()
        
try:
    a_collection.insert({"world":1})
    b_collection.insert({"hello":1})
except:
    # 操做异常，中断事务
    session.abort_transaction()
else:
    session.commit_transaction()
finally:
    session.end_session()