ActiveJob没有出现在Sidekiq队列中

问题描述 投票:0回答:1

ActiveJob分配似乎没有出现在sidekiq队列中..但是这些工作仍然被执行。

这是我在config/environments/production.rb中的active_job设置

  config.active_job.queue_adapter     = :sidekiq
  config.active_job.queue_name_prefix = "faces_#{Rails.env}"

我的sidekiq.yml通过Capistrano装载。

---
:concurrency: 5
:queues:
  - default

production:
  :concurrency: 20
  :queues:
    - faces_production_default

当我开始排队作业并检查它是否存在时的示例输出。

2.6.3 :001 > require 'sidekiq/api'
 => true 
2.6.3 :002 > Sidekiq::Queue.new('faces_production_default').count
 => 0 
2.6.3 :003 > stats = Sidekiq::Stats.new
 => #<Sidekiq::Stats:0x0000000004dd80e8 @stats={:processed=>48, :failed=>0, :scheduled_size=>1, :retry_size=>0, :dead_size=>0, :processes_size=>2, :default_queue_latency=>0, :workers_size=>0, :enqueued=>0}> 
2.6.3 :004 > stats.queues
 => {"default"=>0, "faces_production_default"=>0, "mailers"=>0} 
2.6.3 :005 > FaceParserJob.set(wait: 5.minutes).perform_later(200)
Enqueued FaceParserJob (Job ID: 9848e560-dbf5-4fc0-a3c3-6b8f00164a8a) to Sidekiq(faces_production_default) at 2019-04-28 15:16:25 UTC with arguments: 200
 => #<FaceParserJob:0x0000000004f19b00 @arguments=[200], @job_id="9848e560-dbf5-4fc0-a3c3-6b8f00164a8a", @queue_name="faces_production_default", @priority=nil, @executions=0, @scheduled_at=1556464585.1313956, @provider_job_id="43d2c83a305411bfda6626b1"> 
2.6.3 :006 > Sidekiq::Queue.new('faces_production_default').count
 => 0  

事情是,如果我在5分钟内监控sidekiq.log,它确实执行了这项工作。我究竟做错了什么?

ruby-on-rails redis sidekiq rails-activejob
1个回答
1
投票

作业只有在“启动”时才被放入队列,直到那时 - 它在预定的队列中等待,你可以用

Sidekiq::ScheduledSet.new.size
© www.soinside.com 2019 - 2024. All rights reserved.