使用sidekiq的api清空队列的任务
sidekiq里有提供操作队列的api，首先引入 require 'sidekiq/api'
获取所有队列：Sidekiq::Queue.all
获取默认队列：Sidekiq::Queue.new# the "default" queue
按名称获取队列：Sidekiq::Queue.new("mailer")
清空队列的所有任务：Sidekiq::Queue.new.clear
按条件来删除队列的任务：
1
2
3
4
5
queue=Sidekiq::Queue.new("mailer")
queue.each do |job|
job.klass# => 'MyWorker' job.args# => [1, 2, 3]
job.delete if job.jid=='abcdef1234567890'
end
直接操作redis来删除队列里的任务
首先获取配置文件config，再连接redis，这里使用了redis的Gem包
1
2
redis= Redis.new(:host => config['host'], :port => config['port'],
:db=> config['db'],:password => config['password'])
由于queues用的是set类型的数据，所以要用srem来删除相应的数据 redis.srem(‘queues’, ‘队列的名称’) # 这种情况会直接删除该名称的队列
job lifecycle
