SQLAlchemy/MySQL 在查询期间丢失与 MySQL 服务器的连接

Question

SQLAlchemy (0.9.8) 和 mysql-5.6.21-osx10.8-x86_64 和 MAC OS X 10.3.3 (Yosemite)

我总是断断续续：

InterfaceError: (InterfaceError) 2013: Lost connection to MySQL server during query u'SELECT..... '

我已经阅读了一些帖子，大多数情况都可以通过将其添加到 my.cnf 来解决

   max_allowed_packet = 1024M

对于我尝试做的事情来说应该足够大了。完成此操作后，我间歇性地踩它。并将这一行放在 /etc/my.cnf 中：

   log-error = "/Users/<myname>/tmp/mysql.err.log"
   log-warnings = 3

我希望得到更多细节，但我看到的只是这样的：

   [Warning] Aborted connection 444 to db: 'dbname' user: 'root' host: 'localhost' (Got an error reading communication packets)

我已经到了这样一个地步，我认为更详细的更好的日志记录可能会有所帮助，或者在此之前我可以尝试其他的东西。

谢谢。

Answer 1

您的 MySQL 连接似乎在长时间不活动后超时，我敢打赌，如果您经常使用现有设置查询数据库，则不会发生这种情况。 MySQL 和 sql 端都有一些设置可以解决这个问题：

1. 检查您的 SQLa 引擎的 pool_recycle 值，尝试不同/更小的值，例如1800（秒）。如果您正在从文件中读取数据库设置，请将其设置为

   pool_recycle: 1800

否则在引擎初始化时指定它，例如

from sqlalchemy import create_engine
e = create_engine("mysql://user:pass@localhost/db", pool_recycle=1800)

1. 检查/修改您的wait_timeout MySQL 变量，请参阅https://dev.mysql.com/doc/refman/5.6/en/server-system-variables.html#sysvar_wait_timeout，这是服务器在关闭非交互式连接之前等待其活动的秒数。例如

   显示全局变量，例如“wait_timeout”；

找到适合您环境的组合。

Answer 2

根据this、this 和互联网上许多其他文章的建议，使用以下装饰器包装我的所有函数帮助我解决了以 mariadb 作为后端数据库的“丢失连接”问题。请注意，下面的 db 是 flask_sqlalchemy.SQLAlchemy 的一个实例，但是对于 sqlalchemy 会话，这个概念也将保持不变。

def manage_session(f):
    def inner(*args, **kwargs):

        # MANUAL PRE PING
        try:
            db.session.execute("SELECT 1;")
            db.session.commit()
        except:
            db.session.rollback()
        finally:
            db.session.close()

        # SESSION COMMIT, ROLLBACK, CLOSE
        try:
            res = f(*args, **kwargs)
            db.session.commit()
            return res
        except Exception as e:
            db.session.rollback()
            raise e
            # OR return traceback.format_exc()
        finally:
            db.session.close()
    return inner

我还在 Flask SQLAlchemy 配置中添加了 50 秒的 pool_recycle，但这对解决方案没有明显贡献。

编辑1：

下面是在最终代码中如何使用它的示例 sn-p：

from flask_restful import Resource

class DataAPI(Resource):

    @manage_session
    def get(self):
        # Get data rows from DB