ztq異步任務(wù)隊列-文庫吧
2025-09-08 14:41 本頁面
【正文】 易度云辦公 ? 文檔轉(zhuǎn)換、索引、日志記錄、消息發(fā)送、郵件發(fā)送、短信發(fā)送、垃圾清理、 redis壓縮 設(shè)計目標(biāo) ? 實現(xiàn)簡單 ? 容易使用 ? 可靠 ? 可管理：擁塞、出錯 ? 容易調(diào)試 ? 靈活調(diào)度，高效利用服務(wù)器 模塊關(guān)系 Redis （數(shù)據(jù)存儲、進程通信） Worker1 WorkerN Worker2 監(jiān)控后臺 下達命令 執(zhí)行命令 報告狀態(tài) 查看狀態(tài) 應(yīng)用 放入任務(wù) 處理任務(wù) 查詢、優(yōu)先 錯誤處理 組成包 ztq_worker worker服務(wù) ztq_console 監(jiān)控服務(wù) (可選 ) ztq_core 核心 API 隊列任務(wù) (應(yīng)用 ) pyramid redis 配置 安裝 pip install ztq_core pip install ztq_worker 首先：定義隊列任務(wù) ztq_demo/ import time from ztq_core import async @async 使用默認(rèn)隊列 default def send(body): print ‘START: ‘, body sleep(3) print ‘END:’, body @async(queue=‘mail’) 使用隊列 mail def send_failed(body): print ‘FAIL START’, body raise Exception(‘connection error’) 接下來：運行 worker 運行： bin/ztq_worker [server] host = localhost port = 6379 db = 0 alias = w01 active_config = false modules = 需要運行的 task [queues] default= 0 default隊列，起 1個處理線程 mail = 0, 0 mail隊列，起 2個處理線程 [log] handler_file = ./ level = ER
教學(xué)課件相關(guān)推薦
鄂ICP備17016276號-1