?Python 中可以使用Celery框架

Celery框架是提供異步任務(wù)處理的框架，有兩種用法，一種：應(yīng)用程式發(fā)布任務(wù)消息，后臺Worker監(jiān)聽執(zhí)行，好處在于不影響應(yīng)用程序繼續(xù)執(zhí)行。第二種，設(shè)置定時執(zhí)行（這邊沒測）

Celery框架4.0以上不支持windows環(huán)境安裝了，但是3.0左右還是可以使用的

配套Python2.7 就比較完美。

1. 安裝Celery 需要在Python 2.7中pip install?Celery 和其他一些附屬包例如：amqplib,billiard,kombu,librabbitmq,pymssql,redis 等

安裝完成后：

2.測試Celery是否安裝OK?

簡單例子流程：

3.寫發(fā)布任務(wù)和執(zhí)行任務(wù)的代碼（Rabbit MQ 安裝請參考安裝那一章）

發(fā)布的任務(wù)： 鏈接數(shù)據(jù)庫獲取10筆數(shù)據(jù)，當(dāng)作任務(wù)的參數(shù)傳遞給Rabbit MQ

發(fā)送任務(wù)，只需要直接運(yùn)行這個CeleryGet.py文件

RabbitMQ：接收到消息（當(dāng)不開啟處理任務(wù)程式，那么任務(wù)就在Rabbit MQ中存儲）

處理任務(wù)程式：（把任務(wù)中做為參數(shù)傳遞到MQ的數(shù)據(jù)獲取下來，并insert到一個數(shù)據(jù)庫中）

在此CelerySend.py 根目錄下運(yùn)行命令： ?celery
-A CelerySend worker --loglevel=info

結(jié)果：

成功處理任務(wù)后顯示：

每個任務(wù)都有一個獨(dú)特的TaskID， []中間的部分， Succeeded 表示任務(wù)執(zhí)行狀態(tài)，

有個重點(diǎn)，可以配置redis數(shù)據(jù)庫，對任務(wù)的狀態(tài)和執(zhí)行進(jìn)行結(jié)果進(jìn)行保存。此部分沒有增加

所以Results： 后面為空

?

轉(zhuǎn)載于:https://www.cnblogs.com/Soar-Pang/p/6494246.html

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的Celery框架简单实例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。