Flask+SQLAlchemy多线程报错：Packet sequence number wrong 求助

错误原因 #

你遇到的Packet sequence number wrong错误，本质是多线程复用了同一个数据库连接导致的MySQL连接状态混乱，根源出在session的创建时机和Flask-SQLAlchemy的上下文管理冲突上：

1. Flask-SQLAlchemy的db本身已经封装了基于请求上下文的scoped_session，你手动额外创建的DBSession会和原生的上下文管理机制冲突。
2. 在Worker线程的__init__方法中调用DBSession()是在主线程执行的，此时获取的session绑定的是主线程的数据库连接；当Worker线程启动后使用这个session，就会跨线程复用连接——而MySQL连接是单线程安全的，并发操作必然引发包序列错误。

修正方案 #

方案1：使用Flask-SQLAlchemy原生session，线程内手动创建独立会话（推荐） #

首先简化__init__.py的初始化，不要手动构造scoped_session：

# __init__.py
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = '你的数据库URI'
db = SQLAlchemy(app)

然后修改Worker线程，在run方法内创建session（确保会话属于当前线程）：

from your_app import db
from threading import Thread

class Worker(Thread):
    def run(self):
        # 在当前线程内创建独立session
        session = db.sessionmaker(bind=db.engine)()
        try:
            # 执行数据库操作
            result = session.query(YourModel).all()
            session.commit()
        except Exception as e:
            session.rollback()
            raise e
        finally:
            # 务必关闭session释放连接
            session.close()

方案2：给Worker线程推送Flask上下文 #

如果需要复用Flask的上下文环境，可以在run方法内推送app上下文，让db.session自动绑定到当前线程：

from your_app import app, db
from threading import Thread

class Worker(Thread):
    def run(self):
        with app.app_context():
            # 此时db.session会自动关联当前线程的上下文
            result = db.session.query(YourModel).all()
            db.session.commit()

关键注意点 #

• 永远不要在主线程中创建session然后交给子线程使用，必须在子线程的执行逻辑（run方法）内创建或获取绑定当前线程的session。
• Flask-SQLAlchemy的db.session默认是和请求上下文绑定的，自定义线程中没有请求上下文时，要么手动创建独立session，要么手动推送app上下文。

内容的提问来源于stack exchange，提问作者Tomy137