9-2celery简介

Posted 2020-10-18 zhan

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

在服务端查看：