環(huán)境前提:windows7 + pycharm +Python 3.5.2
本文主要是記錄一下當(dāng)我需要在windows上驗(yàn)證我自己相關(guān)的異步任務(wù)處理的稍候,應(yīng)該怎么進(jìn)行調(diào)試!因?yàn)橥蟮捻?xiàng)目都是在windows下進(jìn)行的。
PS:因?yàn)榘俣攘艘幌拢犝f是celery4.0 以上的已經(jīng)不支持windows了!所以這里也是使用一些低版本的來進(jìn)行調(diào)式
第1步:新建一個基于Python 3.5.2的虛擬環(huán)境隔離其他環(huán)境的依賴
新建一個虛環(huán)境
第2步:查看是否已安裝了celery
(第一個查看位置)
image.png
(第二個查看位置,(因?yàn)槲覀儐拥臅r候是使用命令行進(jìn)行啟動的))

image.png
D:\python_learn\celeryTest>celery --version
3.1.18 (Cipater)
第3步:安裝或卸載 celery
關(guān)于celery的安裝和卸載處理
pip install celery #安裝
pip install celery == 3.1.18 #指定安裝版本
pip uninstall celery #卸載
第4步:編寫相關(guān)的任務(wù)模塊
image.png
創(chuàng)建Celery實(shí)例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實(shí)例中的第一個參數(shù)是當(dāng)前【模塊名稱】,這個參數(shù)是必須的,第二個參數(shù)是中間人關(guān)鍵字參數(shù),指定我們所使用的的消息中間人的URL,這里我們使用的是redis。
定義任務(wù),稱為add,任務(wù)執(zhí)行的目的是:返回兩個數(shù)字的和
第5步:開始運(yùn)行Celery職程服務(wù)器(Worker) 啟動工作者
celery -A tasks worker --loglevel=info
PS:
-A 后面是 對應(yīng)的模塊的名稱
--loglevel=info 是顯示的日志基本類型
如果啟動命令正常,會看到如下圖示的結(jié)果:
image.png
image.png
第6步:編寫運(yùn)行任務(wù)的文件
image.png
image.png
第7步:安裝對應(yīng)的redis
image.png
第8步:再次執(zhí)行測試文件

image.png
image.png
第9步:查看執(zhí)行結(jié)果
image.png









