从官方文档，熟悉其使用：
http://docs.celeryproject.org/en/master/getting-started/first-steps-with-celery.html

1.mkdir celerytest
2.cd celerytest
创建以下两个文件。
Tasks.py
from celery import Celery
# app = Celery(‘tasks’, broker=’amqp://guest@localhost//’)
app = Celery(‘tasks’, backend=’redis://localhost:6379/1′, broker=’redis://localhost:6379/0′)
# app = Celery(‘tasks’, broker=’redis://localhost:6379/0′) no result return

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

————
Test.py
from tasks import add
result = []
if __name__ == ‘__main__’:
for i in range(10):
for j in range(100):
result.append(add.delay(i, j))
for r in result:
print r.ready(),r.get()

在celerytest目录下执行以下命令
3.celery -A tasks worker –loglevel=info
4.运行test.py程序