ol_m_lo 2021-07-29 10:58 采纳率: 60%
浏览 101
已结题

django+celery中celery使用mysql 报错中止连接

出问题的地方在tasks.py文件中标注了.

windows环境下,我在django项目中使用了celery。在使用中,长时间未操作时(大于八小时),celery操作mysql报错:<2013, lost connection to mysql server during query<[winerror 10053] 你的主机中的软件中止了一个已建立的连接>>,但是这个时候django对mysql的操作是正常的(我连接mysql使用的pymysql库),celery中就报错。
ps:
我试过了更改wait_timeout,但是不行,应该在celery数据长时间未操作重连接的问题,因为django就没有这个问题。我正在尝试django.db.close_old_connectios()方法,在查询前手动关闭下失效连接。
希望能有一个可行的办法,是不是我celery配置有问题?还是celery中使用ORM需要什么特殊的设置、操作?

#main.py

import os
import django
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'django.setting')
django.setup()
os.environ.setdefault('FORKED_BY_MULTIPROCESSING', '1')
 
from django.conf import settings
from celery import Celery
 
app = Celery('django', backend='redis://........')
app.config_from_object('celery_tasks.config')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
app.conf.timezone = 'Asia/Shanghai'
app.conf.update(result_expire=24*60*60)
 
app.autodiscover_tasks(['celery_tasks.a_task', '....'])

#config.py

broker_url = 'redis:/......'

#tasks.py

from project.models import Status
from celery_tasks.main import app
 
 
@app.task(name='run_exe', bind=True)
def run_exe(self, *args, **kwargs):
    # ...
    # 出问题的地方,在执行orm查询时报错(此时异步中所有操作数据库的操作都是这个错误)。
    try:
        s_objs = Status.objects.filter(id=id)
    except Exception as e:
        pass
    # ......


  • 写回答

2条回答 默认 最新

  • ol_m_lo 2021-08-02 09:00
    关注

    到目前为止测试可行,我使用了手动关闭连接的方式,https://blog.csdn.net/apple516/article/details/114382217

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 8月10日
  • 已采纳回答 8月2日
  • 创建了问题 7月29日

悬赏问题

  • ¥15 win10,这种情况怎么办
  • ¥15 如何在配置使用Prettier的VSCode中通过Better Align插件来对齐等式?(相关搜索:格式化)
  • ¥100 在连接内网VPN时,如何同时保持互联网连接
  • ¥15 MATLAB中使用parfor,矩阵Removal的有效索引在parfor循环中受限制
  • ¥20 Win 10 LTSC 1809版本如何无损提升到20H1版本
  • ¥50 win10 LTSC 虚拟键盘不弹出
  • ¥30 微信小程序请求失败,网页能正常带锁访问
  • ¥30 德飞莱51单片机实现C4炸弹
  • ¥50 CrossLink-LIF-MD6000 型 FPGA 的 CMOS 转 MIPI D-PHY IP 核功能使用异常
  • ¥15 proteus控制16x16LED点阵显示屏的设计