pip3 install celery
#在这里我使用的是celery==4.2.2
#当celery版本过低的话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