首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >编码/数据库库的数据库连接问题

编码/数据库库的数据库连接问题
EN

Stack Overflow用户
提问于 2021-09-29 08:42:15
回答 1查看 39关注 0票数 1

我有一个错误

代码语言:javascript
运行
复制
pymysql.err.InternalError: Packet sequence number wrong - got 0 expected 1

在让我的应用程序空闲(0个请求到数据库)几个小时之后。我认为,数据库模块创建连接池(它确实创建了),并在超时后自动重新创建连接,但它没有。

需求-Python3.8,FastAPI,数据库Python。

有什么想法吗?

main.py

代码语言:javascript
运行
复制
.......
@app.on_event("startup")
async def startup():
    await db.connect()


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

db_config.py

代码语言:javascript
运行
复制
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

端点示例

代码语言:javascript
运行
复制
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)
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2021-09-30 14:07:08

您可以使用pool_recycle参数来确保连接池删除或重新连接空闲时间过长的任何连接。设置为3600通常适用于MySQL -它将在空闲一个小时后重新启动连接。

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

代码语言:javascript
运行
复制
db = databases.Database(HOST, pool_recycle=3600)

。。或

代码语言:javascript
运行
复制
HOST = 'mysql://user:user_passw@{host}:{port}/sw_database?pool_recycle=3600'.format(..)
票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/69373128

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档