使用 sqlalchemy 和 celery 异步处理数据库查询时，时不时会报错

@rogwan 是在 celery 中实例化的 session()连接
@Print.task(bind=True,name="pf_order_print",max_retries=10, base=ErrorMsgTask)
def print_order(self, order_id, user_id=0):
from handlers.base.pub_func import OrderPrintBaseFunc
time_begin = datetime.datetime.now()
session = DBSession()
.......
像这样

duyuyouci

Jun 5, 2019

@robinlovemaggie 确实不会引起系统错误，但是会影响用户使用😂

rogwan

Jun 5, 2019 via Android

@duyuyouci 你说的这个问题我没有遇到完全一样的，但是 celery 阻塞假死，导致数据连接出错的情况到是遇到几次。后来处理耗时短的业务就直接 Thread 了，耗时长的加回滚，和异常重连，基本就解决啦。

liuguichao

Jun 5, 2019

还有一种可能，遍历 ResultProxy 记录之前，需要先判断一下是否有返回行，直接 for 遍历会出错。
https://docs.sqlalchemy.org/en/13/core/connections.html?highlight=resultproxy#sqlalchemy.engine.ResultProxy.returns_rows

returns_rows
True if this ResultProxy returns rows.
I.e. if it is legal to call the methods fetchone(), fetchmany() fetchall().