在 Sidekiq 中跟踪各种异步后台作业的运行时间

Question

假设我将几个作业推送到 sidekiq 队列，以便立即异步执行。我有日志消息告诉我整个过程何时开始和完成

start = Time.zone.now
puts "Starting jobs"

1000.times.each do
  SomeWorker.perform_async(some_arg_id)
end

end_time = Time.zone.now
runtime = end_time - start
puts "Finished jobs - that took #{runtime} seconds"

这当然有一个非常大的缺陷 - 当所有内容都被推送到队列时，它会输出作业已经完成，而不是当作业实际完成时。

我正在寻找一种方法来跟踪一批作业的完成情况。我不想每隔 X 秒轮询一次以查看队列是否为空。让队列中的最后一个作业更新数据库或使用完成时间记录似乎也很麻烦，因为不能保证它们以任何顺序完成。

是否有解决此问题的最佳做法？

谢谢！

Answer 1

嗯，最好的方法似乎是使用 Sidekiq Pro：https://github.com/mperham/sidekiq/wiki/Batches

您可以通过编程方式获取 Batch 的状态。

除了使用 pro 或手动轮询队列大小之外，我看不到任何其他方式。