每次引发错误时都会创建 Airbrakes 的延迟作业

Question

def perform
  refund_log = {
    success: refund_retry.success?,
    amount: refund_amount,
    action: "refund"
  }
  if refund_retry.success?
    refund_log[:reference] = refund_retry.transaction.id
    refund_log[:message] = refund_retry.transaction.status
  else
    refund_log[:message] = refund_retry.message
    refund_log[:params] = {}
    refund_retry.errors.each do |error|
      refund_log[:params][error.code] = error.message
    end
    order_transaction.message = refund_log[:params].values.join('|')
    raise "delayed RefundJob has failed"
  end
end

当我在 else 语句中提出“延迟的 RefundJob 失败”时，它会创建一个 Airbrake。如果它在 else 部分结束，我想再次运行该作业。

有没有办法在不引发异常的情况下重新排队作业？并防止产生空气制动？

我正在使用延迟作业版本 1。

Answer 1

最干净的方法是重新排队，即创建一个新作业并将其入队，然后正常退出该方法。

Answer 2

要详细说明@Roman 的响应，您可以创建一个新作业，其中包含retry 参数，然后将其加入队列。

如果您维护retry 参数（每次重新排队作业时增加它），您可以跟踪您进行了多少次重试，从而避免无休止的重试循环。

Answer 3

根据定义，DelayedJob 期望作业引发错误以重新排队。

从那里你可以：

• 忽略您在 airbrake 方面的执行，请参阅https://github.com/airbrake/airbrake#filtering，因此它仍然会再次排队而不填满您的日志
• 深入了解 DelayedJob 代码，您可以在 https://github.com/tobi/delayed_job/blob/master/lib/delayed/job.rb#L65 上看到名为 reschedule 的方法可用并由 run_with_lock (https://github.com/tobi/delayed_job/blob/master/lib/delayed/job.rb#L99) 使用。从那里您可以手动调用重新安排它，而不是引发您的异常。

关于后面的解决方案，我建议添加一些机制，在第三次或以后的尝试中仍会填写 airbrake 报告，您仍然可以检测到有问题，而无需为尝试填写日志而烦恼。