因为win10上运行celery4.x就会出现问题,虽然能将celery服务器开起来,但是一旦接收任务就会报错,解决办法如下
pip install eventlet
然后启动worker的时候使用时间池来实现:加一个参数 -P eventlet,如下:
celery -A worker -l info -P eventlet
如果接收数据报错,我们加一句话即可
# 启动文件 from celery import Celery import os os.environ.setdefault('FORKED_BY_MULTIPROCESSING','1') # 主要加上这一段话 app = Celery(xxx)