使用延迟作业我想根据错误消息修改 reschedule_at

Question

使用错误、失败和 reschedule_at 回调是否有办法使 reschedule_at 时间取决于我收到的错误类型？

我已经设置了 reschedule_at 方法，但它会影响该类型的所有作业。我不知道在哪里根据错误类型以及在哪个处理程序中处理此行为。

Answer 1

经过一些测试后，您似乎可以使用以下方法根据特定作业错误消息进行自定义重新安排：

1. 在作业中定义一个实例变量来保存自定义重试延迟。该变量将在所有其他变量中序列化到数据库（或任何其他 DelayedJob 后端），即其状态将在作业运行之间保留。

2. 在挂钩中，根据参数（是一个对象）中出现的错误error将延迟设置为任意值。exceptionException

3. 在方法中使用自定义延迟reschedule_at。

reschedule_at该解决方案利用了该方法在hook之后调用的error事实。请参见以下示例：

class MyJob

  attr_accessor :retry_delay

  def initialize
    self.retry_delay = 5 # default retry delay
  end

  def error(job, exception)
    # set up a different the delay time on a specific error
    if exception.is_a? NameError
      self.retry_delay = 10
    end
  end

  def reschedule_at(current_time, attempts)
    current_time + retry_delay.seconds
  end

end