在多线程 sqlalchemy web 应用程序中推荐的scoped_session 使用模式是什么？

Question

我正在使用 python 和 sqlalchemy-0.7 编写一个应用程序。它首先初始化 sqlalchemy orm（使用声明式），然后启动一个多线程 Web 服务器 - 我目前正在使用 web.py 进行快速原型设计，但将来可能会改变。我还将为计划作业等添加其他“线程”，可能使用其他 python 线程。

从SA文档中我知道我必须使用scoped_session()来获取线程本地会话，所以我的web.py应用程序最终应该看起来像这样：

import web
from myapp.model import Session  # scoped_session(sessionmaker(bind=engine))
from myapp.model import This, That, AndSoOn
urls = blah...
app  = web.application(urls, globals())

class index:
    def GET(self):
        s = Session()
        # get stuff done
        Session().remove()
        return(stuff)

class foo:
    def GET(self):
        s = Session()
        # get stuff done
        Session().remove()
        return(stuff)

这是处理会话的正确方法吗？

据我了解，我应该在每个方法中获得一个scoped_session，因为它会给我一个我事先无法获得的线程本地会话（就像在模块级别一样）。

另外，我应该调用 .remove() 或 .commit() 或 类似的东西在每个方法结束时，否则会话仍将包含持久 对象，我将无法在其他线程中查询/访问相同的对象？

如果该模式是正确的，则可以通过仅编写一次（也许使用装饰器）来使其更好？这样的装饰器可以获取会话，调用该方法，然后确保正确处理会话。如何将会话传递给装饰函数？

Answer 1

是的，这是正确的方法。

示例：

带有 Flask 微框架/" rel="noreferrer">Flask-sqlalchemy 扩展执行您所描述的操作。它还会在每个 HTTP 请求（“视图”函数）结束时自动执行 .remove() 操作，因此当前线程会释放会话。仅调用 .commit() 是不够的，您应该使用 .remove()。

当不使用 Flask 视图时，我通常使用“with”语句：

@contextmanager
def get_db_session():
    try:
        yield session
    finally:
        session.remove()

with get_db_session() as session:
    # do something with session

您可以创建一个类似的装饰器。

作用域会话创建一个 DBMS 连接池，因此这种方法比在每个 HTTP 请求时打开/关闭会话更快。它也可以很好地与 greenlet（gevent 或 eventlet）配合使用。

Answer 2

如果为每个请求创建新会话并且每个请求都由单线程处理，则不需要创建作用域会话。

您必须调用s.commit()来使挂起对象持久，即将更改保存到数据库中。

您可能还想通过调用 s.close() 来关闭会话。