Celery+django+redis异步执行任务的实现示例

$ src/redis-server

$ src/redis-cli
redis> set foo bar
OK
redis> get foo
“bar”

# wget http://download.redis.io/releases/redis-3.2.6.tar.gz
# tar xzf redis-3.2.6.tar.gz
# cd redis-3.2.6
# make
# src/redis-server   # 启动redis服务，看清楚，这是在你的redis-3.2.6目录下执行的
# src/redis-cli   # 启动客户端

# pip install celery
# pip install redis

import time
from celery import task

@task()
def add(x, y):
    return x + y

@task
def sendmail(mail):
    print "++++++++++++++++++++++++++++++++++++"
    print('sending mail to %s...' % mail['to'])
    time.sleep(2.0)
    print('mail sent.')
    print "------------------------------------"
    return mail['to']

# celery -A tasks worker --loglevel=info

# celery -A app.tasks worker --loglevel=info

>>> from app.tasks import *
>>> sendmail.delay(dict(to='asd@as.com'))
<AsyncResult: 694b6fa8-a123-4c22-9ba2-b77d7cbb066f>
>>> add.delay(2, 15)
<AsyncResult: 42d34419-4a34-49ab-9627-45428eaaeb38>
>>> a=add.delay(1,1)
>>> a.ready()
True
>>> a.get()
2
>>> a=add.delay(10,5)
>>> a.get()
15

from app.tasks import add,sendmail

def task_workorder(request, id):
    """任务添加"""
    # ......你的代码......
    sendmail.delay(dict(to='asd@as.com'))  #申请人提交后会给审批人发邮件
    # ......你的代码......