python分布式框架celery项目开发_Python芹菜分布式并行框架,PythonCelery
环境搭建
安装rides服务
安装rides客户端
pip install celery
编写第一个任务
tasks.py
# encoding:utf-8
from celery import Celery
# 指定broker-----rides地址后面/5指定任务存放在rides第几个库
broker = 'redis://127.0.0.1:6379/5' #任务调度队列，接收任务生产者发来的消息(即任务)，将任务存入队列。
# 指定backend
backend = 'redis://127.0.0.1:6379/6' #存储任务的执行结果
# 定义celery app
app = Celery('tasks',broker=broker,backend=backend)
# 任务(可以新建各种任务)
@app.task
def add(x,y):
c = x+y
return c
main.py
# encoding:utf-8
from tasks import add
r = add.delay(2, 2)
print('是否准备：{}'.format(r.ready()))
print('函数运行结果：{}'.format(r.result))
print('获取函数结果：{}'.format(r.get()))
接下来命令行切换到task.py文件所在的目录下执行命令：
celery -A tasks worker -l info -P eventlet
可以看到：
然后重新打开另一个命令窗口运行main.py：
然后数据结果就储存在了Redis：