初始celery

pip3 install celery
#启动redis服务端

# Celery settings
?
CELERY_BROKER_URL = ‘redis://localhost‘
?
#: Only add pickle to this list if your broker is secured
#: from unwanted access (see userguide/security.html)
CELERY_ACCEPT_CONTENT = [‘json‘]
CELERY_RESULT_BACKEND = ‘redis://localhost‘
CELERY_TASK_SERIALIZER = ‘json‘

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
?
# 设置“celery”程序的默认Django设置模块。
os.environ.setdefault(‘DJANGO_SETTINGS_MODULE‘, ‘demo.settings‘)
?
app = Celery(‘demo‘)
# 这里的demo表示你项目的名字
?
# Using a string here means the worker doesn‘t have to serialize
# the configuration object to child processes.
# - namespace=‘CELERY‘ means all celery-related configuration keys
#   should have a `CELERY_` prefix.
app.config_from_object(‘django.conf:settings‘, namespace=‘CELERY‘)
?
# 从所有已注册的Django app configs加载任务模块
app.autodiscover_tasks()

from django.shortcuts import render,HttpResponse
from .tasks import add
# Create your views here.
def index(request):
    add.delay(1,2)
    return HttpResponse(‘200 OK‘)

import time
from celery import Celery
?
celery_app = Celery(‘tasks‘, backend=‘redis://localhost‘, broker=‘redis://localhost‘)
# this is celery settings
?
# this is a function about need many time
@celery_app.task
def add(a, b):
    time.sleep(5)
    return a + b

pip install eventlet

celery -A <mymodule> worker -l info -P eventlet