Celery框架簡單實例

?Python 中可以使用Celery框架

Celery框架是提供異步任務處理的框架，有兩種用法，一種：應用程式發布任務消息，后臺Worker監聽執行，好處在于不影響應用程序繼續執行。第二種，設置定時執行（這邊沒測）

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

配套Python2.7 就比較完美。

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

安裝完成后：

2.測試Celery是否安裝OK?

簡單例子流程：

3.寫發布任務和執行任務的代碼（Rabbit MQ 安裝請參考安裝那一章）

發布的任務： 鏈接數據庫獲取10筆數據，當作任務的參數傳遞給Rabbit MQ

發送任務，只需要直接運行這個CeleryGet.py文件

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

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

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

結果：

成功處理任務后顯示：

每個任務都有一個獨特的TaskID， []中間的部分， Succeeded 表示任務執行狀態，

有個重點，可以配置redis數據庫，對任務的狀態和執行進行結果進行保存。此部分沒有增加

所以Results： 后面為空

?