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