如何使用Sidekiq将捕获到错误的任务移入Dead队列？

可以实现该需求，你可以在rescue_from块内调用Sidekiq原生接口将当前任务直接送入死信队列，同时终止后续重试流程。

以下是修改后的可运行代码示例：

# 引入Sidekiq内置的API模块，无需额外安装依赖
require 'sidekiq/api'

class MyJob < ApplicationJob
  queue_as :default
  sidekiq_options retry: 5

  rescue_from MyError do |error|
    # 核心逻辑：将当前任务直接加入死信队列
    Sidekiq::DeadSet.new.kill(self.job_id)
    # 可选：记录错误日志方便后续排查问题
    Rails.logger.error "任务#{self.job_id}触发自定义错误MyError，已移入死信队列，错误信息：#{error.message}"
    # 可选：彻底中断任务处理流程，避免其他全局捕获逻辑继续执行
    throw :abort
  end

  def perform(document)
    # 你的业务执行逻辑
  end
end

如果你只是需要针对特定错误跳过重试、直接进死信队列，不需要在错误捕获时做额外自定义操作，可以不用手动写rescue_from逻辑，直接通过Sidekiq的重试配置实现，这种方式更符合原生设计：

class MyJob < ApplicationJob
  queue_as :default
  # 配置：MyError类型的错误不重试，直接送入死信队列，其他错误仍然重试5次
  sidekiq_options retry: {
    attempts: 5,
    exclude: [MyError]
  }

  def perform(document)
    # 你的业务执行逻辑
  end
end

注意事项 #

• 死信队列的任务默认保留30天，到期后会自动清理，你可以在Sidekiq Web UI中手动查看、重试或删除死信任务
• 手动调用kill方法时要确保传入的是当前任务的正确job_id，避免误操作其他正在运行的任务
• 如果使用配置排除特定错误的方式，触发排除列表内的错误时，Sidekiq会自动终止重试流程，不需要额外写代码处理

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