ztq異步任務(wù)隊(duì)列-全文預(yù)覽
【正文】 設(shè)置 Redis 連接 (‘default’, ‘localhost’, 6379, 0) send(‘hello, world’) 動(dòng)態(tài)指定 queue send(‘hello world from mail’, ztq_queue=‘mail’) 好，喘口氣 小窺下監(jiān)控后臺(tái) 安裝運(yùn)行 ? pip install ztq_console ? bin/pserve 當(dāng)前 worker狀態(tài) 隊(duì)列情況 錯(cuò)誤處理 隊(duì)列執(zhí)行日志 Worker運(yùn)行日志 更多特性。) def bgrewriteaof(): 將 redis的 AOF文件壓縮 redis = () () 自動(dòng)定時(shí)壓縮 reids if not has_cron(bgrewriteaof): add_cron({39。) def fail_callback(return_code, return_msg): print return_code, return_msg fcallback = prepare_task(send2) send(body, ztq_fcallback=fcallback) 進(jìn)度回調(diào)： pcallback from ztq_core import prepare_task pcallback = prepare_task(send2, body) send_mail(body, ztq_pcallback=pcallback) 拋出進(jìn)度信息 import ztq_worker async(queue=‘xxx’) def doc2pdf(filename): … 可被進(jìn)度回調(diào)函數(shù)調(diào)用 (page=2) 擁塞：批處理加速 為提升性能，需要多個(gè) xapian索引操作，一次性提交數(shù)據(jù)庫(kù) async(queue=‘xapian’) def index(data): pass def do_mit(): () 每執(zhí)行 20個(gè)索引任務(wù)之后，一次性提交數(shù)據(jù)庫(kù) 不夠 20個(gè)，但隊(duì)列空的時(shí)候，也會(huì)提交 register_batch_queue(‘xapian’, 20, batch_func=do_mit) 內(nèi)部原理 更多血淋淋的
教學(xué)課件相關(guān)推薦
鄂ICP備17016276號(hào)-1