中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

怎么在python爬蟲中利用celery調取文件

發布時間:2020-11-27 15:27:52 來源:億速云 閱讀:141 作者:Leah 欄目:編程語言

本篇文章給大家分享的是有關怎么在python爬蟲中利用celery調取文件,小編覺得挺實用的,因此分享給大家學習,希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。

除了通過```import```然后```add.delay()```這種方式,我們還可以通過```send_task()```這種方式,我們在項目根目錄另外新建一個py文件叫做 `excute_tasks.py`,在其中寫下如下的代碼

from tasks import add
 
if __name__ == '__main__':
add.delay(5, 10)

這時候可以在celery的worker界面看到執行的結果

[2017-05-19 14:25:48,039: INFO/MainProcess] Received task: tasks.add[f5ed0d5e-a337-45a2-a6b3-38a58efd9760]
 
[2017-05-19 14:25:48,074: INFO/MainProcess] Task tasks.add[f5ed0d5e-a337-45a2-a6b3-38a58efd9760] succeeded in 0.03369094600020617s: 15

此外,我們還可以通過```send_task()```來調用,將```excute_tasks.py```改成這樣

from tasks import app
if __name__ == '__main__':
app.send_task('tasks.add', args=(10, 15),)

這種方式也是可以的。`send_task()`還可能接收到為注冊(即通過`@app.task`裝飾)的任務,這個時候worker會忽略這個消息

[2017-05-19 14:34:15,352: ERROR/MainProcess] Received unregistered task of type 'tasks.adds'.
 
The message has been ignored and discarded.

以上就是怎么在python爬蟲中利用celery調取文件,小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

江达县| 丰城市| 蛟河市| 丹凤县| 洱源县| 翁源县| 梁平县| 蒲江县| 建宁县| 鄂伦春自治旗| 乌审旗| 巩义市| 张北县| 景泰县| 陵川县| 江油市| 东海县| 甘洛县| 义乌市| 米易县| 阳高县| 改则县| 平遥县| 公主岭市| 广平县| 延津县| 虞城县| 晋宁县| 甘德县| 石屏县| 房产| 双江| 香格里拉县| 故城县| 维西| 永登县| 威远县| 博爱县| 临邑县| 大丰市| 汾西县|