为 contextvars.Context 提供 ContextManager

Question

我正在尝试在我的数据库框架中管理事务（我在 pymongo 上使用 MongoDB 和 umongo）。

要使用事务，必须在整个调用链中传递一个 session kwarg。我想提供一个上下文管理器来隔离事务。只有调用链末尾的函数需要知道 session 对象。

我发现了上下文变量，我已经接近某些东西但还不完全是。

我想要的：

with Transaction():
    # Do stuff
    d = MyDocument.find_one()
    d.attr = 12
    d.commit()

这是我现在想到的：

s = ContextVar('session', default=None)

class Transaction(AbstractContextManager):

    def __init__(self):
        self.ctx = copy_context()
        # Create a new DB session
        session = db.create_session()
        # Set session in context
        self.ctx.run(s.set, session)

    def __exit__(self, *args, **kwargs):
        pass

    # Adding a run method for convenience
    def run(self, func, *args, **kwargs):
        self.ctx.run(func, *args, **kwargs)

def func():
    d = MyDocument.find_one()
    d.attr = 12
    d.commit()

with Transaction() as t:
    t.run(func)

但我没有很好的上下文管理器语法。上下文管理器的要点是 "everyting that's in there should be run in that context".

我上面写的并不比只使用函数好：

def run_transaction(func, *args, **kwargs):
    ctx = copy_context()
    session = 12
    ctx.run(s.set, session)
    ctx.run(func)

run_transaction(func)

我走错路了吗？

我是否滥用了上下文变量？

还有其他方法可以实现我想要做的事情吗？

基本上，我希望能够像上下文管理器一样打开上下文

session = ContextVar('session', default=None)

with copy_context as ctx():
    session = db.create_session()
    # Do stuff
    d = MyDocument.find_one()
    d.attr = 12
    d.commit()

我将其嵌入到 Transaction 上下文管理器中以管理会话内容，并且仅在用户代码中保留对 d 的操作。

Answer 1

您可以使用上下文管理器创建会话和事务并将会话存储在 ContextVar 中以供其他函数使用。


from contextlib import contextmanager
from contextvars import ContextVar
import argparse
import pymongo


SESSION = ContextVar("session", default=None)


@contextmanager
def transaction(client):
    with client.start_session() as session:
        with session.start_transaction():
            t = SESSION.set(session)
            try:
                yield
            finally:
                SESSION.reset(t)


def insert1(client):
    client.test.txtest1.insert_one({"data": "insert1"}, session=SESSION.get())


def insert2(client):
    client.test.txtest2.insert_one({"data": "insert2"}, session=SESSION.get())


def main():
    parser = argparse.ArgumentParser()
    parser.add_argument("--url", default="mongodb://localhost:27017")
    args = parser.parse_args()

    client = pymongo.MongoClient(args.url)

    # Create and lear collections, collections must be created outside the transaction
    insert1(client)
    client.test.txtest1.delete_many({})
    insert2(client)
    client.test.txtest2.delete_many({})

    with transaction(client):
        insert1(client)
        insert2(client)

    for doc in client.test.txtest1.find({}):
        print(doc)
    for doc in client.test.txtest2.find({}):
        print(doc)


if __name__ == "__main__":
    main()

为 contextvars.Context 提供 ContextManager

Provide contextvars.Context with a ContextManager

python

contextmanager

python-3.x

python-3.7

python-contextvars