redis数据迁移

阿里工具redis-shaockhttps://github.com/alibaba/RedisShake/releases

• tar包下载下来之后直接解压，重点在于修改配置文件，注意行号

  43 source.address = 10.189.64.45:7001
  44 # password of db/proxy. even if type is sentinel.
  45 source.password_raw = 123456
  
  
  87 target.address = 10.189.64.45:7033
  88 # password of db/proxy. even if type is sentinel.
  89 target.password_raw = 123456

• 执行

  ./redis-shake.linux64 -type=rump -conf=redis-shake.conf

脚本方式

由于笔者公司的redis对Keys命令做了重命名，所以没有采用上面的方式

#coding=utf-8
import redis
redis_from = redis.StrictRedis(host='10.189.64.45', port=7001, db=0,password=123456)
redis_to = redis.StrictRedis(host='10.189.64.45', port=7033, db=0,password=123456)
if __name__ == '__main__':
    cnt = 0
    for k in redis_from.execute_command('163REDISKEYS', '*'):
        data_type = redis_from.type(k)
        print(data_type)
        if data_type == b'string':
            v = redis_from.get(k)
            redis_to.set(k, v)
        elif data_type == b'list':
            values = redis_from.lrange(k, 0, -1)
            redis_to.lpush(k, values)
        elif data_type == b'set':
            values = redis_from.smembers(k)
            redis_to.sadd(k, values)
        elif data_type == b'hash':
            keys = redis_from.hkeys(k)
            for key in keys:
                value = redis_from.hget(k, key)
                redis_to.hset(k, key, value)
        else:
            print ('not known type')
        cnt = cnt + 1
    print ('total', cnt)

• redis

• 运维

扫一扫，分享到微信