1.celery簡介
2.celery 的架構
3.celery 工作原理
2.任務執行單元worker實時監視訊息佇列獲取佇列中的任務執行
3.woker執行完任務後將結果儲存在backend中
4.安裝
5.使用
import time
def add(x, y):
time.sleep(5) # 模擬耗時操作
return x + y
ready(): 判斷任務是否有結果，返回true or false
state:返回任務狀態
task_id: 返回任務id
result: 返回任務結果，同get()方法
info: 獲取任務資訊，預設返回結果
successful(): 判斷任務是否成功，返回true or false
使用配置檔案
broker_url = 'redis:' # broker配置，使用redis作為訊息中介軟體
celery_result_backend = 'redis:' # backend配置，這裡使用redis
celery_result_serializer = 'json' # 結果序列化方案
celery_task_result_expires = 60 * 60 * 24 # 任務過期時間
celery_timezone='asia/shanghai' # 時區配置
celery_imports = ( # 指定匯入的任務模組,可以指定多個
'assets.tests',
)
import time
def add(x, y):
time.sleep(5) # 模擬耗時操作
return x + y
總結：定時任務的使用 下個章節分析
celery的使用介紹
celery是專注實時處理和任務排程的分布式任務佇列。主要應用場景 1，web應用，當需要觸發事件需要較長時間處理完成，可以交給celery進行非同步執行，執行完後返回結果，這段時間不用等待，提高系統的吞吐量和響應時間。2，完成任務時，需要額外的事件處理，如傳送郵件等。3，後台定時任務處理，cele...
Celery介紹及常見錯誤
情景 使用者發起request，並等待response返回。在本些views中，可能需要執行一段耗時的程式，那麼使用者就會等待很長時間，造成不好的使用者體驗，比如傳送郵件 手機驗證碼等。使用celery後，情況就不一樣了。解決 將耗時的程式放到celery中執行。celery名詞 安裝包 celer...
平台專案 celery基礎獨立
0 編輯py檔案celery task.py 1 from celery import celery 引入模組 4.0 2 ap celery tasks broker celery broker,backend celery backend broker 消費佇列 可使用redis rabbitm...