python - 如何在 Python 中正确捕获和处理 RQ 超时？

Question

试图找到一种捕捉 RQ 超时的好方法作业，因此可以在超时后重新排队。

基本上，正确的解决方案将提供一种方法(例如，工作程序中的异常处理程序或类似的东西)来重新排队超时的作业。此外，如果作业返回到 failed 队列，这也是一个很好的答案。

非常感谢!任何帮助将不胜感激!

Answer 1

听起来您想使用 exception handling .来自文档:

Jobs can fail due to exceptions occurring. When your RQ workers run in the background, how do you get notified of these exceptions?

Default: the failed queue The default safety net for RQ is the failed queue. Every job that fails execution is stored in here, along with its exception information (type, value, traceback). While this makes sure no failing jobs "get lost", this is of no use to get notified pro-actively about job failure.

Custom exception handlers Starting from version 0.3.1, RQ supports registering custom exception handlers. This makes it possible to replace the default behaviour (sending the job to the failed queue) altogether, or to take additional steps when an exception occurs.

您还可以将作业存储在以 job_id 为键，以 time.time() + timeout 为分数的 redis 排序集中，然后让工作人员运行 ZRANGEBYSCORE sorted_set 0 [current_time] 并处理作为超时作业返回的任何内容。