這篇文章將為大家詳細(xì)講解有關(guān)怎么在python爬蟲(chóng)中安裝celery，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

創(chuàng)新互聯(lián)公司專注于企業(yè)全網(wǎng)營(yíng)銷推廣、網(wǎng)站重做改版、和田縣網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5建站、成都做商城網(wǎng)站、集團(tuán)公司官網(wǎng)建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)公司、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁(yè)設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為和田縣等各大城市提供網(wǎng)站開(kāi)發(fā)制作服務(wù)。

先安裝celery

pip install celery

我們以官網(wǎng)給出的例子來(lái)做說(shuō)明，并對(duì)其進(jìn)行擴(kuò)展。首先在項(xiàng)目根目錄下，這里我新建一個(gè)項(xiàng)目叫做celerystudy，然后切換到該項(xiàng)目目錄下，新建文件tasks.py，然后在其中輸入下面代碼

from celery import Celery
 
app = Celery('tasks', broker='redis://:''@223.129.0.190:6379/2', backend='redis://:''@223.129.0.190:6379/3')
 
@app.task
def add(x, y):
return x + y

這里我詳細(xì)講一下代碼：我們先通過(guò)app=Celery()來(lái)實(shí)例化一個(gè)celery對(duì)象，在這個(gè)過(guò)程中，我們指定了它的broker，是redis的db 2,也指定了它的backend,是redis的db3, broker和backend的連接形式大概是這樣

redis://:password@hostname:port/db_number

然后定義了一個(gè)add函數(shù)，重點(diǎn)是@app.task，它的作用在我看來(lái)就是將add()

注冊(cè)為一個(gè)類似服務(wù)的東西，本來(lái)只能通過(guò)本地調(diào)用的函數(shù)被它裝飾后，就可以通過(guò)網(wǎng)絡(luò)來(lái)調(diào)用。這個(gè)tasks.py中的app就是一個(gè)worker。它可以有很多任務(wù)，比如這里的任務(wù)函數(shù)add。我們?cè)偻ㄟ^(guò)在命令行切換到項(xiàng)目根目錄，執(zhí)行

celery -A tasks worker -l info

啟動(dòng)成功后就是下圖所示的樣子

關(guān)于怎么在python爬蟲(chóng)中安裝celery就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。