如何手动为使用ActiveJob的Sidekiq任务设置指定执行/重试次数

ActiveJob场景语法 #

ActiveJob结合Sidekiq适配器时，可直接通过set方法传递retry参数覆盖类定义的全局重试配置，优先级高于类中声明的sidekiq_options：

• 异步入队执行：MyJob.set(retry: 2).perform_later(*args)
• 同步立即执行（适配控制台调试、RSpec测试场景）：MyJob.set(retry: 2).perform_now(*args)

原生Sidekiq Worker场景语法 #

如果没有使用ActiveJob封装，直接使用原生Sidekiq Worker，可通过以下两种方式指定重试次数：

1. 手动入队时通过Sidekiq::Client传递参数：

Sidekiq::Client.push(
  'class' => MyWorker,
  'args' => [arg1, arg2],
  'retry' => 2
)

2. RSpec测试场景下可直接通过Sidekiq测试API模拟重试流程，无需等待重试间隔：

it "验证重试逻辑正确性" do
  MyWorker.perform_async(*args)
  # 模拟2次重试执行
  2.times { MyWorker.drain }
  # 补充自定义断言逻辑
end

注意事项 #

Sidekiq的retry参数定义的是最大重试次数，不包含首次执行。例如设置retry: 2代表任务首次执行失败后最多重试2次，总执行次数为3次；如果需要总执行次数固定为2次，设置retry: 1即可。

如果你的业务逻辑依赖当前执行次数计数，可通过内置属性直接获取：

• ActiveJob场景：通过任务实例的executions属性获取当前执行次数（首次执行返回1，第一次重试返回2，以此类推）
• 原生Sidekiq Worker场景：可通过作业元数据获取重试计数，也可以和你现有的失败重启传参逻辑保持一致，手动传递执行次数标识即可。

内容的提问来源于stack exchange，提问作者Cyril Duchon-Doris