RQ中，在一个Queue执行完之后触发事件的方法

[0bit]

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

[Livid]

这种处理方法也挺环保的。

因为 worker 本来就应该是持续运行的，所以只有 burst queue 才会存在说运行结束的概念。

[wuxqing]

官方的例子：
https://github.com/nvie/rq/blob/master/examples/run_example.py

[0bit]

@Livid 那我应该把每个任务，加上timeout，免得卡死。多谢了。


@wuxqing 多谢，之前还真的没看过这个例子。