python - Mongoengine Transactions怎么来的？

Question

为了在 mongoengine 上进行涉及更新两种以上不同类型文档的事务，我该怎么做？

Answer 1

使用下面的方法，就可以使用mongoengine中的事务请注意，在此方法中，您的查询必须是使用 pymongo 的原始查询

from mongoengine import *
from mongoengine.connection import get_connection, get_db

connect('testdb')

class TestDocument(Document):
    name = StringField(required=True)


mongo = get_connection()
with mongo.start_session() as session:
    with session.start_transaction():
        try:
            test = TestDocument(name='test')
            mongo.get_database(get_db()).get_collection('test_document').insert_one(
                test.to_mongo(), session=session
            )
            # just for raising an exception
            err = 1 / 0
        except Exception as e:
            print(e)
            session.abort_transaction()