编码/数据库库的数据库连接问题答案

【问题标题】：DB connection issue with encode/databases library编码/数据库库的数据库连接问题
【发布时间】：2021-11-21 04:02:41
【问题描述】：

我有一个错误

pymysql.err.InternalError: Packet sequence number wrong - got 0 expected 1

在让我的应用程序空闲（0 个对 DB 的请求）几个小时后。我想，数据库模块会创建连接池（确实如此）并在超时后自动重新创建连接，但事实并非如此。

要求 - Python 3.8、FastAPI、数据库[mysql]。

有什么想法吗？

main.py

.......
@app.on_event("startup")
async def startup():
    await db.connect()


@app.on_event("shutdown")
async def shutdown():
    await db.disconnect()
.......

db_config.py

import databases
import sqlalchemy
import os
import logging

from functools import wraps

HOST = 'mysql://user:user_passw@{host}:{port}/sw_database'.format(host=os.environ.get("DB_HOST", "127.0.0.1"),
                                                                  port=os.environ.get("DB_PORT", "3306"))

db = databases.Database(HOST)
metadata = sqlalchemy.MetaData()
logger = logging.getLogger(__name__)


def perform_transaction(foo):
    @wraps(foo)
    async def decorate(*args, **kwargs):
        async with db.connection() as connection:
            async with connection.transaction():
                try:
                    res = await foo(*args, **kwargs)
                except Exception as e:
                    logger.error(e)
                    return []
        return res

    return decorate

端点示例

from fastapi import APIRouter

from db_config import db, perform_transaction

router = APIRouter()

@router.get('/devices_list', responses=responses_for_devices_table)
@perform_transaction
async def get_devices_list():
    query = devices.select()
    return await db.fetch_all(query)

【问题讨论】：

尝试提供pool_recycle 参数以确保连接池丢弃任何因空闲时间过长而延迟的连接。 3600 的设置通常适用于 MySQL。您可以将其作为参数提供给Database(.., pool_recycle=3600)，或作为连接字符串中的选项 (...?pool_recycle=3600)。 github.com/encode/databases/blob/…
@MatsLindh 谢谢，我会测试它并在这里发布我的反馈。
@MatsLindh 谢谢，你是对的，我的问题已经解决了

标签： python fastapi pymysql aio-mysql

【解决方案1】：

您可以使用pool_recycle 参数来确保连接池丢弃或重新连接任何长时间处于空闲状态的连接。 3600 的设置通常适用于 MySQL - 它会在空闲一个小时后回收连接。

您可以将其作为参数提供给Database(.., pool_recycle=3600)，也可以作为连接字符串中的选项 (...?pool_recycle=3600)：

db = databases.Database(HOST, pool_recycle=3600)

.. 或

HOST = 'mysql://user:user_passw@{host}:{port}/sw_database?pool_recycle=3600'.format(..)

【讨论】：