这是一个创建于 4165 天前的主题，其中的信息可能已经有所发展或是发生改变。
先吐槽一句，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)
# 相关的统计函数()
我现在要处理很多包，因为要每个包独立处理，所以每个包生成一个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)
# 相关的统计函数()
 |
1
Livid MOD 这种处理方法也挺环保的。
因为 worker 本来就应该是持续运行的，所以只有 burst queue 才会存在说运行结束的概念。 |
 |
2
wuxqing 2013-07-09 08:54:39 +08:00
|
Select Language