1234567891011121314151617181920212223242526272829303132333435363738 |
- #!/usr/bin/env ruby
- require 'redis'
- redis_master = Redis.new(host: "localhost", port: 6379)
- redis_slave = Redis.new(host: "172.31.8.119", port: 12322)
- puts "###################################################################################"
- puts "# Setting"
- begin
- # Check to see connection is valid before pipelining
- redis_master.ping
- # Pipeline for efficiency
- redis_master.pipelined do
- (1..100).each do |x|
- puts "adding key #{x} => mague "
- redis_master.set("#{x}", "mague")
- end
- end
- rescue Exception => e
- puts "ERROR: master #{e.message}"
- exit! 1
- end
- puts "###################################################################################"
- puts "# Fetching"
- begin
- (1..100).reverse_each do |x|
- puts "Fetching: #{x} => #{redis_slave.get(x)}"
- end
- rescue Exception => e
- puts "ERROR: slave: #{e}"
- exit! 1
- end
|