ztq異步任務(wù)隊(duì)列-展示頁
2024-10-24 14:41本頁面
【正文】 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 = ERROR 最后：測(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)行日志 更多特性。 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。) def bgrewriteaof(): 將 redis的 AOF文件壓縮 redis = () () 自動(dòng)定時(shí)壓縮 reids if not has_cron(bgrewriteaof): add_cron({39。:1}, bgrew
教學(xué)課件相關(guān)推薦
鄂ICP備17016276號(hào)-1