ztq異步任務(wù)隊(duì)列(編輯修改稿)
2024-11-17 14:41 本頁(yè)面
【文章內(nèi)容簡(jiǎn)介】 ROR 最后：測(cè)試異步運(yùn)行 import ztq_core from import send 設(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)行日志 更多特性。 搶占式執(zhí)行 后插入先執(zhí)行 如果任務(wù)已經(jīng)在隊(duì)列，會(huì)優(yōu)先 send (body, ztq_first=True) Ping: 探測(cè)任務(wù)狀態(tài) running: 運(yùn)行； queue:排隊(duì)中； error: 出錯(cuò)； none: 不存在 (send, body) ztq_first存在就優(yōu)先 。 ztq_run不存在就運(yùn)行 (send, body, ztq_first=True, ztq_run=True) 事務(wù)： transaction import transaction (True) send_mail(from1, to1, body1) send_mail(from2, to2, body2) () send_mail(from2, to2, body2, ztq_transaction=False) 非事務(wù) Cron：定時(shí)任務(wù) from async import async import redis_wrap from ztq_core import has_cron, add_cron @async(queue=39。clock039。) def bgrewriteaof(): 將 redis的 AOF文件壓縮 redis = () () 自動(dòng)定時(shí)壓縮 reids if not has_cron(bgrewriteaof): add_cron({39。hour39。:1}, bgrewriteao
教學(xué)課件相關(guān)推薦
鄂ICP備17016276號(hào)-1