版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_38165374/article/details/74225308
django 耗时操作处理办法 celery
1.安装包
celery==3.1.25
celery-with-redis==3.0
django-celery==3.1.17
2.项目setting.py 配置
# 安装应用
INSTALLED_APPS = (
...
'djcelery',
}
......
#配置代理和任务模块
import djcelery
djcelery.setup_loader() #初始化
BROKER_URL = 'redis://127.0.0.1:6379/2' #2为数据库
CELERY_IMPORTS = ('test.task') # '小括号内为应用名.定义耗时方法所在的文件'
3.创建定义耗时操作的方法的文件task.py
from celery import task
@task
def sayhello():
'''
耗时操作的代码
'''
pass
4 .执行迁移生成celery需要的数据库表
在manage.py所在的目录下执行
python manage.py makemigrations
python manage.py migrate
5.启动Redis启动数据库
sodo service redis start
6.启动worker
需要在创建定义完耗时操作方法之后启动
python manage.py celery worker --loglevel=info
7.views中的操作
伪代码
from . import task #导入定义耗时操作方法的文件
...
def sayhello(request):
task.sayhello.delay() # 调用耗时操作中的方法,将这个任务加到队列中
return HttpResponse("hello world")