如何按作业类、队列名称和参数查询 Sidekiq 队列？

Question

在再次入队之前，我必须检查是否已将相同的作业添加到队列中。

目前我使用此代码，但效率非常低，因为它将所有对象加载到内存中。有没有办法像普通的活动记录一样查询？

理想情况下，我会喜欢

Sidekiq::Queue.where(job_class: "SyncJob", queue_name:"high", arguments: [1,2,3])

当前代码：

def list_queued_jobs(job_class, queue_name,  arguments)
  found_jobs = []
  queues = Sidekiq::Queue.all
  queues.each do |queue|
    queue.each do |job|
      job.args.each do |arg|
        if arg['job_class'].to_s == job_class.to_s && arg['queue_name'] == queue_name && ActiveJob::Arguments.deserialize(arg['arguments']) == arguments
          found_jobs << job
        end
      end
    end
  end
  return found_jobs
end

Answer 1

没有开箱即用的解决方案，但有一种更简单的方法可以确定作业是否已排队 (true/false)：

def in_queues?(job_class, queue_name,  arguments = [])
  Sidekiq::Queue.new(queue_name).any? do |job|
    job_class == job.klass && job.args == arguments
  end
end

请记住，sidekiq 参数以数组的形式呈现。例如，如果你这样称呼你的工作：

SyncJob.perform_async([1, 2, 3])

然后您检查它是否已按如下方式排队：

in_queues?("SyncJob", "high", [[1, 2, 3]])

Answer 2

检查现有作业称为“唯一作业”。 Sidekiq Enterprise 提供此功能，一些 3rd 方 gem 也提供此功能。

实现和使用您描述的代码是一个非常坏主意。