django之使用celery-把耗时程序放到celery里面执行的方法

pip install celery==3.1.25pip install celery-with-redis==3.0pip install django-redis==3.1.17

# 数据库使用mysqlDATABASES = {  'default': ｛    'ENGINE':'django.db.backends.mysql',    'NAME':'test',    'USER':'root',    'PASSWORD':'mysql',    'HOST':'localhost',    'PORT':3306,  }}# 注册djcelery应用INSTALLED_APPS = (  ...  'djcelery',)# celery配置# 如报错　ImportError: No module named djcelery　，是因为没有在虚拟环境运行导致，　workon h1进入虚拟环境再运行解决import djcelery#　初始化所有的task任务，这些任务来自booktest.task模块djcelery.setup_loader()# 使用redis第０个数据库，并绑定ip端口BROKER_URL='redis://127.0.0.1:6379/0'#　设置初始化的任务来源CELERY_IMPORTS = 'booktest.task'

from celery import taskimport time# 加上@task装饰器，则python函数就变成一个celery任务@taskdef celery_test():  print('hello...')  time.sleep(5)  print('world...')

#　-*- coding:utf-8 -*-from django.shortcuts import renderfrom django.http import HttpResponsefrom task import celery_test# celery练习１：把耗时程序放在celery中执行def celerytest(request):  # function.delay(参数),celery任务celery_test调用方法  celery_test.delay()  return HttpResponse('ok')# 根级url配置 test.urlsfrom django.conf.urls import include, urlfrom django.contrib import adminurlpatterns = [  url(r'^admin/', include(admin.site.urls)),  url(r'^celery/', include('booktest.urls')),]# 应用下的url配置　ｂooktest.urlsfrom django.conf.urls import urlimport viewsurlpatterns=[  url(r'^celerytest/$', views.celerytest)]

python manage.py migrate

sudo redis-server /etc/redis/redis.conf

python manage.py celery worker --loglevel=info

python manage.py runserver