如何为 resque 作业设置超时

Question

我需要实现一个功能，让 resque 作业在特定时间内未处理时超时。

因此，假设创建了一个作业，但由于队列太长和/或没有足够的工人处理它们而无法在一小时内处理。

在这种情况下，我不想删除工作......最好的方法是什么？也许有我正在监督的配置参数或第 3 方 gem？

谢谢

Answer 1

我不知道在 Resque 中是否有默认方法可以做到这一点，但自己做并不难。

在你的工作中做这样的事情：

def perform(id, queued_at)
  return false unless Time.parse(queued_at) >= 1.hour.ago

  ...
end

要将作业排入队列，请执行以下操作：Resque.enqueue(MyJobClass, object.id, DateTime.now)。如果排队时间超过一个小时，第一行将自动转储作业并阻止其执行。