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

Question

windows环境下，我在django项目中使用了celery。在使用中，长时间未操作时（大于八小时），celery操作mysql报错：<2013, lost connection to mysql server during query<[winerror 10053] 你的主机中的软件中止了一个已建立的连接>>，但是这个时候django对mysql的操作是正常的（我连接mysql使用的pymysql库），celery中就报错。

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
    # ......

Answer 1

刚才说的不太对，django应该是在每个请求的进来的时候发起连接，请求结束后再断开吧。。没研究这么细过，celery应该就不是了，进程没有断那就一直保持连接了的样子