windows环境下,我在django项目中使用了celery。在使用中,长时间未操作时(大于八小时),celery操作mysql报错:<2013, lost connection to mysql server during query<[winerror 10053] 你的主机中的软件中止了一个已建立的连接>>,但是这个时候django对mysql的操作是正常的(我连接mysql使用的pymysql库),celery中就报错。
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', '....'])
broker_url = 'redis:/......'
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
# ......
刚才说的不太对,django应该是在每个请求的进来的时候发起连接,请求结束后再断开吧。。没研究这么细过,celery应该就不是了,进程没有断那就一直保持连接了的样子
贴代码吧,不然无法分析。。。。
有用到连接池吗?
是提前和mysql建立连接么,还是读写数据的时候临时再建立连接么?
虽然没试过,但对八小时有点敏感,可以参考下这个,考虑设置长点试试?
https://blog.csdn.net/weixin_30904593/article/details/95011546