环境前提:windows7 + pycharm +Python 3.5.2
本文主要是记录一下当我需要在windows上验证我自己相关的异步任务处理的稍候,应该怎么进行调试!因为往后的项目都是在windows下进行的。
PS:因为百度了一下,听说是celery4.0 以上的已经不支持windows了!所以这里也是使用一些低版本的来进行调式
第1步:新建一个基于Python 3.5.2的虚拟环境隔离其他环境的依赖
新建一个虚环境
第2步:查看是否已安装了celery
(第一个查看位置)
image.png
(第二个查看位置,(因为我们启动的时候是使用命令行进行启动的))
image.png
D:\python_learn\celeryTest>celery --version
3.1.18 (Cipater)
第3步:安装或卸载 celery
关于celery的安装和卸载处理
pip install celery #安装
pip install celery == 3.1.18 #指定安装版本
pip uninstall celery #卸载
第4步:编写相关的任务模块
image.png
创建Celery实例tasks.py:
# coding:utf-8
from celery import Celery
app = Celery('tasks', broker="redis://localhost:6379/0")
@app.task
def add(x, y):
return x + y
PS:
Celery实例中的第一个参数是当前【模块名称】,这个参数是必须的,第二个参数是中间人关键字参数,指定我们所使用的的消息中间人的URL,这里我们使用的是redis。
定义任务,称为add,任务执行的目的是:返回两个数字的和
第5步:开始运行Celery职程服务器(Worker) 启动工作者
celery -A tasks worker --loglevel=info
PS:
-A 后面是 对应的模块的名称
--loglevel=info 是显示的日志基本类型
如果启动命令正常,会看到如下图示的结果:
image.png
image.png
第6步:编写运行任务的文件
image.png
image.png
第7步:安装对应的redis
image.png
第8步:再次执行测试文件
image.pngimage.png
第9步:查看执行结果
image.png
网友评论