ztq异步任务队列内容摘要：
ROR 最后：测试异步运行 import ztq_core from import send 设置 Redis 连接 (‘default’, ‘localhost’, 6379, 0) send(‘hello, world’) 动态指定 queue send(‘hello world from mail’, ztq_queue=‘mail’) 好，喘口气 小窥下监控后台 安装运行 • pip install ztq_console • bin/pserve 当前 worker状态 队列情况 错误处理 队列执行日志 Worker运行日志 更多特性。 抢占式执行 后插入先执行 如果任务已经在队列，会优先 send (body, ztq_first=True) Ping: 探测任务状态 running: 运行； queue:排队中； error: 出错； none: 不存在 (send, body) ztq_first存在就优先。 ztq_run不存在就运行 (send, body, ztq_first=True, ztq_run=True) 事务： transaction import transaction (True) send_mail(from1, to1, body1) send_mail(from2, to2, body2) () send_mail(from2, to2, body2, ztq_transaction=False) 非事务 Cron：定时任务 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。阅读剩余 0%
本站所有文章资讯、展示的图片素材等内容均为注册用户上传(部分报媒/平媒内容转载自网络合作媒体)，仅供学习参考。
用户通过本站上传、发布的任何内容的知识产权归属用户或原始著作权人所有。如有侵犯您的版权，请联系我们反馈本站将在三个工作日内改正。