bulk-delete resque-scheduler entries

resque_scheduler_delete.rb

require 'redis'
require 'time'

SET = "resque:delayed_queue_schedule"
BUCKET_PREFIX = "resque:delayed"
CHUNK_SIZE = 200

r = Redis.new

range = [0, Time.parse("December 2 2014 15:00").to_i]

buckets = r.zrangebyscore(SET, *range)
puts "#{buckets.size} buckets to remove"
removed = 0

format = ->(ts) { "#{BUCKET_PREFIX}:#{ts}" }

buckets.each_slice(CHUNK_SIZE) do |chunk|
  if ENV['DELETE']
    r.del(chunk.map(&format))
  end
  puts "#{(removed += chunk.size)} / #{buckets.size}"
end

if ENV['DELETE']
  r.zremrangebyscore(SET, *range)
end

puts "done"