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
在服务端查看:
时间: 2024-10-23 06:11:15