SQLAlchemy的多线程使用

Question

我想制作一个用Python编写并使用SQLAlchemy的数据库应用程序编程接口（或其他任何数据库连接器，如果被告知将SQLAlchemy用于此类任务不是好方法）。该设置是在Linux或BSD上运行的MySQL服务器，以及在Linux或BSD机器（外部或本地）上运行的Python软件。

基本上我想做的是为每个连接生成一个新线程，并且该协议将是自定义且非常简单的，尽管对于每个请求，我想打开一个新事务（或我已阅读的会话），然后我需要提交会议。我现在面临的问题是，来自另一个连接的另一个会话同时发生的可能性很高。

我的问题是该如何处理这种情况？

• 我是否应该使用锁，以便仅一个会话可以同时运行？
• 会话实际上是线程安全的吗，我认为它们不是线程安全的吗？
• 有没有更好的方法来处理这种情况？
• 穿线的方式不行吗？

Answer 1

会话对象 不是 线程安全的，而是 线程本地的
。从文档：

“该Session对象被完全设计为以 非并发 方式使用，就多线程而言，这意味着“一次仅在一个线程中”
..某些进程需要就位，以免跨多个线程进行多调用实际上获得了同一个会话的句柄。我们将此概念 线程 称为 本地存储 。”

如果您不想自己完成管理线程和会话的工作，SQLAlchemy的ScopedSessionhtml" target="_blank">对象可以为您解决这个问题：

ScopedSession默认情况下，该对象使用threading.local（）作为存储，以便Session为所有调用ScopedSession注册表的人维护一个，但仅在单个线程的范围内。在另一个线程中调用注册表的调用者将获得另一个线程本地的Session实例。

使用这种技术，ScopedSession可以在应用程序中提供一种快速且相对简单的方式来提供单个全局对象，该对象可以安全地从多个线程中调用。

请参阅上下文/本地线程会话中的示例，以设置自己的线程安全会话：

# set up a scoped_session
from sqlalchemy.orm import scoped_session
from sqlalchemy.orm import sessionmaker

session_factory = sessionmaker(bind=some_engine)
Session = scoped_session(session_factory)

# now all calls to Session() will create a thread-local session
some_session = Session()

# you can now use some_session to run multiple queries, etc.
# remember to close it when you're finished!
Session.remove()