0 編輯py檔案celery_task.py
1 from celery import celery 引入模組 4.0
2 ap =celery('tasks',broker=celery_broker,backend=celery_backend)
broker 消費佇列 可使用redis/rabbitmq方式儲存消費佇列
backend任務結果佇列 可使用redis/rabbitmq方式儲存消費佇列
rabbitmq:大而全，更安全，資料處理更快速。redis:使用更方便，開發更快速
補充1 autoretry_for=(exception,) 當出現異常的時候自動進行嘗試 exception所有異常都需要重試
2 retry_kwargs=
當出現問題的時候規定的最大嘗試次數和每次嘗試的間隔時間 def add(x, y): return x + y
4 啟動/停止
celery worker -a celery_task.py --concurrency=n --loglevel=info(開啟n個並行執行緒)
ps aux|grep "celery worker"|grep -v grep|awk ''|xargs kill -9
5 進行呼叫加入celery中
method.delay()
6 常用命令
1 celery -a task_entry inspect active 檢視正在執行的所有任務
2 celery -a task_entry inspect reserved 等待排程等
3 celery -a task_entry inspect registered 註冊成功的任務可以進行驗證是否生效
Celery基礎介紹
1.celery簡介 2.celery 的架構 3.celery 工作原理 2.任務執行單元worker實時監視訊息佇列獲取佇列中的任務執行 3.woker執行完任務後將結果儲存在backend中 4.安裝 5.使用import time def add x,y time.sleep 5 模擬耗時操...
celery專案中的應用
我的目錄結構是這樣的 就是參考celery官方教程寫的了.coding utf 8 from future import absolute import,unicode literals from celery import celery author liunan date 2020 12 16 ...
Tomcat獨立布暑專案
前言 本文記錄不用myeclipse本身的tomcat布暑專案，而是用安裝的tomcat進行布暑。1.本人用myeclipse8.5建立了乙個web專案，名為 blog,儲存在 g workspace myeclipse 8.5 blog 2.tomcat6.0安裝在c program files ...