如何处理达到最大重试次数的Rails ActiveJob失败任务？

针对你遇到的ActiveJob因第三方API不可用耗尽重试次数后，需要执行自定义失败逻辑的需求，这里有几个可靠的实现方式：

方案1：利用retry_on的回调块（原生ActiveJob方式） #

retry_on支持传入回调块，当最后一次重试失败时，会自动触发块内代码，无需额外判断执行次数，准确性最高：

class SomeJob < ApplicationJob
  queue_as :default
  MAX_RETRY_ATTEMPTS = 3

  # 配置重试规则，最后一次失败时执行块内逻辑
  retry_on StandardError, wait: :polynomially_longer, attempts: MAX_RETRY_ATTEMPTS do |job, error|
    # 在这里执行你的失败处理逻辑
    mark_user_failure(job.args[:user_id])
    alert_team_about_failure(job.class.name, job.args, error)
  end

  def perform(args)
    # 你的业务逻辑：调用第三方API等操作
  end

  private

  def mark_user_failure(user_id)
    User.find(user_id).update!(status: :api_operation_failed)
  end

  def alert_team_about_failure(job_name, args, error)
    # 比如发送Slack通知、邮件提醒团队
    SlackNotifier.post("Job #{job_name} 彻底失败，参数：#{args}，错误：#{error.message}")
  end
end

方案2：结合executions属性判断执行次数 #

每个ActiveJob实例都自带executions属性（从1开始计数，包含首次执行），你可以在异常捕获逻辑里判断是否达到最大重试次数：

class SomeJob < ApplicationJob
  queue_as :default
  MAX_RETRY_ATTEMPTS = 3
  retry_on StandardError, wait: :polynomially_longer, attempts: MAX_RETRY_ATTEMPTS

  rescue_from StandardError do |error|
    # 当执行次数等于最大重试次数时，说明这是最后一次尝试
    if executions >= MAX_RETRY_ATTEMPTS
      handle_permanent_failure(args, error)
    end
    # 重新抛出错误，让ActiveJob继续执行重试流程
    raise error
  end

  def perform(args)
    # 业务逻辑
  end

  private

  def handle_permanent_failure(args, error)
    # 自定义失败处理：更新用户记录、通知团队等
  end
end

方案3：基于SolidQueue实现死信队列（DLQ） #

SolidQueue原生支持死信队列配置，适合将耗尽重试的任务隔离到专门队列处理，符合分布式队列最佳实践：

1. 配置死信队列规则 #

在config/solid_queue.yml中为目标队列添加死信配置：

production:
  queues:
    default:
      dead_letter_queue: dead_letter
      max_attempts: 3 # 和你想要的重试次数一致

2. 创建死信处理Job #

专门处理从默认队列转发过来的失败任务：

class DeadLetterHandlerJob < ApplicationJob
  queue_as :dead_letter

  def perform(original_job_class, original_args, error_details)
    args = JSON.parse(original_args)
    # 执行失败处理逻辑
    User.find(args["user_id"]).update!(status: :api_failed)
    SlackNotifier.post("任务 #{original_job_class} 彻底失败，参数：#{args}，错误：#{error_details}")
  end
end

3. 调整原Job配置 #

去掉原Job的retry_on，让SolidQueue的全局重试规则接管：

class SomeJob < ApplicationJob
  queue_as :default

  def perform(args)
    # 业务逻辑
  end
end

方案4：使用after_failure全局回调 #

ActiveJob的after_failure回调会在任务最终失败时触发，你可以在里面判断是否因重试耗尽导致失败：

class SomeJob < ApplicationJob
  queue_as :default
  MAX_RETRY_ATTEMPTS = 3
  retry_on StandardError, wait: :polynomially_longer, attempts: MAX_RETRY_ATTEMPTS

  after_failure do |job, error|
    # 当执行次数等于配置的重试次数时，执行自定义逻辑
    if job.executions == MAX_RETRY_ATTEMPTS
      handle_permanent_failure(job.args, error)
    end
  end

  def perform(args)
    # 业务逻辑
  end

  private

  def handle_permanent_failure(args, error)
    # 自定义失败处理
  end
end

内容的提问来源于stack exchange，提问作者Hassen