Celery 是一个python开发的一部分布式任务调度模块
Celery本身不提供消息服务，使用第三方服务，borker传递任务，目前支持redis，mysql等
安装celery，redis
pip install celery
pip install redis
安装redis服务，并启动redis
使用celery的例子
服务端：
celery_service.py #coding:utf8 from celery import Celery import redis broker = "redis://172.16.61.158:6379/5" backend = "redis://172.16.61.158:6379/6" app = Celery("test",broker=broker,backend=backend) @app.task def add(x,y):
在服务器执行：
celery -A celery_service worker --loglevel=info
客户端：test_celery.py
#coding:utf8 import time from celery_service import add a = add.delay(10,20) time.sleep(1) print a print type(a) print a.result print a.status
执行结果：python test_celery.py
9d0c53e7-67ce-4e87-a823-35ffc004444f <class ‘celery.result.AsyncResult‘> 30 SUCCESS
在服务端查看：
