ztq異步任務(wù)隊列(編輯修改稿)
2024-11-17 14:41 本頁面
【文章內(nèi)容簡介】 ROR 最后：測試異步運行 import ztq_core from import send 設(shè)置 Redis 連接 (‘default’, ‘localhost’, 6379, 0) send(‘hello, world’) 動態(tài)指定 queue send(‘hello world from mail’, ztq_queue=‘mail’) 好，喘口氣 小窺下監(jiān)控后臺 安裝運行 ? pip install ztq_console ? bin/pserve 當(dāng)前 worker狀態(tài) 隊列情況 錯誤處理 隊列執(zhí)行日志 Worker運行日志 更多特性。 搶占式執(zhí)行 后插入先執(zhí)行 如果任務(wù)已經(jīng)在隊列，會優(yōu)先 send (body, ztq_first=True) Ping: 探測任務(wù)狀態(tài) running: 運行； queue:排隊中； error: 出錯； none: 不存在 (send, body) ztq_first存在就優(yōu)先 。 ztq_run不存在就運行 (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：定時任務(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 = () () 自動定時壓縮 reids if not has_cron(bgrewriteaof): add_cron({39。hour39。:1}, bgrewriteao
教學(xué)課件相關(guān)推薦
鄂ICP備17016276號-1