これは、既存の resque ジョブを sidekiq に移行するために使用したコードです。これは Rails コンソールで使用できます。
['low', 'high', 'critical'].each do |queue|
p [1, queue]
old_queue = "resque:queue:#{queue}"
new_queue = "queue:#{queue}"
# $redis.ltrim new_queue, 0, 0 # can optionally clear out new queue, in case of multiple runs
vals = $redis.lrange(old_queue, 0, -1)
p [2, queue]
$redis.pipelined do
vals.each do |val|
$redis.lpush(new_queue, val)
end
end
end
次のように設定することもできます。
Sidekiq.configure_server do |config|
config.redis = { :namespace => 'resque' }
end
Sidekiq.configure_client do |config|
config.redis = { :namespace => 'resque' }
end
そしてそれは箱から出してすぐに動作します。しかし、これなしで展開した後、両方の形式で保留中のジョブがあったため、最初に貼り付けたコードを使用して移行する必要がありました。