我有一个使用Sidekiq的应用程序. Web服务器进程有时会将工作放在Sidekiq上,但我不一定会让工作人员运行.是否有一个实用程序,我可以从Rails控制台调用它将从Redis队列中拉出一个作业并运行相应的Sidekiq工作程序?
解决方法
您可以使用Rails控制台中的Sidekiq :: Queue类来完成此操作.
要经营一份工作:
queue = Sidekiq::Queue.new # access the default queue job = queue.first # get the most recent job klass,method,args = YAML.load(queue.first.args[0]) # unserialize klass.send(method,*args) # run the code that the job would perform
请注意,这不会影响Sidekiq :: Stats.new处理的队列或统计信息.
> Sidekiq::Stats.new => #<Sidekiq::Stats:0x007fe7c74db8e8 @stats={:processed=>0,:Failed=>0,:scheduled_size=>0,:retry_size=>0,:dead_size=>0,:processes_size=>1,:default_queue_latency=>1056925.2464652061,:workers_size=>0,:enqueued=>1}>
要删除刚刚从队列前面戳过的作业:
> queue.first.delete => true > Sidekiq::Stats.new => #<Sidekiq::Stats:0x007fe7c74db8e8 @stats={:processed=>0,:enqueued=>0}>