惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

freeCodeCamp Programming Tutorials: Python, JavaScript, Git & More
V
Visual Studio Blog
IT之家
IT之家
博客园 - 聂微东
The Cloudflare Blog
月光博客
月光博客
阮一峰的网络日志
阮一峰的网络日志
S
SegmentFault 最新的问题
Apple Machine Learning Research
Apple Machine Learning Research
酷 壳 – CoolShell
酷 壳 – CoolShell
爱范儿
爱范儿
H
Help Net Security
博客园 - 叶小钗
V
V2EX
WordPress大学
WordPress大学
J
Java Code Geeks
Hugging Face - Blog
Hugging Face - Blog
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
博客园_首页
C
Check Point Blog
B
Blog
D
DataBreaches.Net
美团技术团队
罗磊的独立博客

RQ

关于长时间运行的 rqworker Python RQ (Redis Queue) 0.4.0 如何? RQ 对提高整个应用的性能很有帮助 如果基于 rq 来开发一个 MapReduce framework? rq-dashboard Rq 执行的的任务貌似对中文支持不佳 关于 RQ 的任务重试机制 这里有人在生产环境使用RQ麽?
RQ中,在一个Queue执行完之后触发事件的方法
0bit · 2013-07-09 · via RQ

先吐槽一句,RQ的官方文档,真的是少得可怜,很多东西都要自己到源码里开才会发现。
我现在要处理很多包,因为要每个包独立处理,所以每个包生成一个Queue,然后我需要的是,在这个Queue处理完成之后,对这个Queue的结果进行统计,貌似RQ中没有这种触发机制,不知道有没有什么好的方法。
我现在用的方法是,不用rqworker,自己在程序里调用Worker,然后设置burst=True,把相关的统计代码,放到worker执行完之后,但是总觉得不是十分的靠谱。
代码大概是这样的:
queueList = sorted([q for q in Queue.all() if q.name != 'failed'])
w = Worker(queueList.pop())
w.work(burst=True)
# 相关的统计函数()