先吐槽一句，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)
# 相关的统计函数()
Select Language