❶ celery 任務突然不執行是為什麼
node-celery for Node，還有nodejs實現的node-celery和一個php實現的客戶端，這為高可用性和橫向擴展提供了便利。 Celery是用python語言實現的，但是可以使用任何語言實現其協議。除了python以外。 Celery通過消息進行通信，通常通過一個中間人celery 任務突然不執行是為什麼
❷ Python 非同步任務隊列Celery 使用
在 Python 中定義 Celery 的時候，我們要引入 Broker，中文翻譯過來就是「中間人」的意思。在工頭(生產者)提出任務的時候，把所有的任務放到 Broker 裡面，在 Broker 的另外一頭，一群碼農(消費者)等著取出一個個任務准備著手做。這種模式註定了整個系統會是個開環系統，工頭對於碼農們把任務做的怎樣是不知情的。所以我們要引入 Backend 來保存每次任務的結果。這個 Backend 也是存儲任務的信息用的，只不過這里存的是那些任務的返回結果。我們可以選擇只讓錯誤執行的任務返回結果到 Backend，這樣我們取回結果，便可以知道有多少任務執行失敗了。
其實現架構如下圖所示：
可以看到，Celery 主要包含以下幾個模塊：
celery可以通過pip自動安裝。
broker 可選擇使用RabbitMQ/redis，backend可選擇使用RabbitMQ/redis/MongoDB。RabbitMQ/redis/mongoDB的安裝請參考對應的官方文檔。
------------------------------rabbitmq相關----------------------------------------------------------
官網安裝方法： http://www.rabbitmq.com/install-windows.html
啟動管理插件：sbin/rabbitmq-plugins enable rabbitmq_management 啟動rabbitmq：sbin/rabbitmq-server -detached
rabbitmq已經啟動，可以打開頁面來看看 地址： http://localhost:15672/#/
用戶名密碼都是guest 。進入可以看到具體頁面。 關於rabbitmq的配置，網上很多 自己去搜以下就ok了。
------------------------------rabbitmq相關--------------------------------------------------------
項目結構如下：
使用前，需要三個方面：celery配置，celery實例，需執行的任務函數，如下：
Celery 的配置比較多，可以在 官方配置文檔： http://docs.celeryproject.org/en/latest/userguide/configuration.html 查詢每個配置項的含義。
當然，要保證上述非同步任務and下述定時任務都能正常執行，就需要先啟動celery worker，啟動命令行如下:
需 啟動beat ，執行定時任務時, Celery會通過celery beat進程來完成。Celery beat會保持運行, 一旦到了某一定時任務需要執行時, Celery beat便將其加入到queue中. 不像worker進程, Celery beat只需要一個即可。而且為了避免有重復的任務被發送出去，所以Celery beat僅能有一個。
命令行啟動：
如果你想將celery worker/beat要放到後台運行，推薦可以扔給supervisor。
supervisor.conf如下：
❸ python 使用celery為了解決什麼業務問題
Celery是一個專注於實時處理和任務調度的分布式任務隊列。所謂任務就是消息，消息中的有效載荷中包含要執行任務需要的全部數據。
使用Celery的常見場景如下：
1. Web應用。當用戶觸發的一個操作需要較長時間才能執行完成時，可以把它作為任務交給Celery去非同步執行，執行完再返回給用戶。這段時間用戶不需要等待，提高了網站的整體吞吐量和響應時間。
2. 定時任務。生產環境經常會跑一些定時任務。假如你有上千台的伺服器、上千種任務，定時任務的管理很困難，Celery可以幫助我們快速在不同的機器設定不同種任務。
3. 同步完成的附加工作都可以非同步完成。比如發送簡訊/郵件、推送消息、清理/設置緩存等。
Celery還提供了如下的特性：
1. 方便地查看定時任務的執行情況，比如執行是否成功、當前狀態、執行任務花費的時間等。
2. 可以使用功能齊備的管理後台或者命令行添加、更新、刪除任務。
3. 方便把任務和配置管理相關聯。
4. 可選多進程、Eventlet和Gevent三種模式並發執行。
5. 提供錯誤處理機制。
- 提供多種任務原語，方便實現任務分組、拆分和調用鏈。
- 支持多種消息代理和存儲後端。