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

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

# 数据库使用mysql
DATABASES = {
  '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 task
import time

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

#　-*- coding:utf-8 -*-
from django.shortcuts import render
from django.http import HttpResponse
from task import celery_test


# celery练习１：把耗时程序放在celery中执行
def celerytest(request):
  # function.delay(参数),celery任务celery_test调用方法
  celery_test.delay()
  return HttpResponse('ok')

# 根级url配置 test.urls
from django.conf.urls import include, url
from django.contrib import admin

urlpatterns = [
  url(r'^admin/', include(admin.site.urls)),
  url(r'^celery/', include('booktest.urls')),
]

# 应用下的url配置　ｂooktest.urls
from django.conf.urls import url
import views

urlpatterns=[
  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