NQS__的博客

在使用 SQLAlchemy 来查询并统计 MySQL 中 JSON 字段的一个值时，你可以结合 SQLAlchemy 的。：使用 SQLAlchemy 的查询接口和函数来提取 JSON 字段的值，并按这个值进行分组统计。首先，确保你已经安装了 SQLAlchemy。方法来进行分组统计。下面是如何在 SQLAlchemy 中实现这一点的基本步骤。的 JSON 类型字段，我们想要按照。：首先，创建一个数据库引擎来管理连接。：定义一个模型来映射到数据库中的表。的表，其中有一个名为。

sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError) (2013, 'Lost connection to MySQL server during query')

sqlalchemy的连接池默认设置pool_size=5， max_overflow=10。批量添加100个耗时任务，发现有成功执行仅有15个，找到报错log。考虑内存和cpu，合理设置以上2个参数。

前端查询列表页一直转圈圈，打开控制台发现是API 500了。看了下后端日志，核心问题是。前端试了下还是转圈，API依然500，又看了下后端日志,原来是mysql连接断开。修改mysql容器的配置。手动重启后端服务即可。

望着代码陷入自我怀疑，再三确认了多线程的代码没问题，想起来如题的坑，于是在子线程的函数中加入try catch，通过logging主动捕获并打印出异常。批量耗时任务创建的api，最开始采用for循环串行执行耗时任务，使用的是请求初始化时的数据库session，技术上没问题。于是修改子线程函数，增加参数，接受一个新创建的会话。上来直接改造多线程，发现子线程很快stoped，根本没执行。但业务上需要优化成并发。终于，世界恢复平静！