多线程使用SQLAlchemy

Question

我想创建一个用Python编写的数据库应用程序编程接口,并使用SQLAlchemy(或任何其他数据库连接器,如果它被告知使用SQLAlchemy进行此类任务不是一个好方法).该设置是在Linux或BSD上运行的MySQL服务器,以及在Linux或BSD机器上运行的Python软件(外部或本地).

基本上我想要做的是为每个连接生成一个新线程,协议将是自定义的并且非常简单,尽管对于每个请求我想打开一个新事务(或者我读过的会话)然后我需要提交会议.我现在面临的问题是,另一个会话很可能同时从另一个连接发生.

我的问题是我应该怎样处理这种情况？

• 我应该使用锁定,因此只能同时运行一个会话吗？
• 会话实际上是线程安全的,我认为它们不是吗？
• 有没有更好的方法来处理这种情况？
• 是不是要走的路？

Answer 1

会话对象不是线程安全的,但是是线程本地的.来自文档:

"该Session对象完全被设计为以非并发方式使用,在多线程方面意味着"一次仅在一个线程中".某些进程需要到位,以便多个线程之间的多个调用不会实际上得到了同一个会话的句柄.我们称之为概念线程本地存储."

如果您不想自己管理线程和会话,SQLAlchemy有一个ScopedSession对象可以为您处理:

ScopedSession默认情况下,该对象使用[threading.local()]作为存储,因此Session为所有调用ScopedSession注册表的人维护单个,但仅在单个线程的范围内.在另一个线程中调用注册表的调用者获取该另一个线程的本地会话实例.

使用这种技术,它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()