利用python 迁移单个redis的

发布时间:2019-10-09 10:40:20编辑:auto阅读(31)

    环境的是python3 / pip3

    import sys
    
    import redis
    
    
    # 迁移hash
    def moveHash(cursor):
        cursor, data = r.hscan(key, cursor)
        for eachKey in data:
            rNew.hset(key, eachKey, data[eachKey])
        print(key, "---处理了---", len(data), '个')
        if cursor != 0:
            print(cursor, "批处理")
            moveHash(cursor)
        else:
            print(cursor, "处理完成了")
    
    
    # 迁移list
    def moveList():
        length = r.llen(key)
        if length == 0:
            print(key, "---list迁移结束---剩余长度", length)
        else:
            # 每次迁移一千个
            start = length - 1000;
            if start < 0:
                start = 0
            data = r.lrange(key, start, -1)
            pl = r.pipeline();
            for eachI in data:
                setAdd = r.sadd("ordernokey_move", eachI);
                if setAdd == 1:
                    pl.rpush("aaaaaaa", eachI)
                else:
                    print("迁移的key的值重复了", eachI)
            pl.execute()
            if start == 0:
                # 清空
                r.ltrim(key, 1, 0)
            r.ltrim(key, 0, start - 1)
            moveList()
    
    
    ############################
    
    
    key = sys.argv[1]
    
    print('输入的key是:' + key)
    # ip = '47.254.149.109'
    # password = 'Kikuu2018'
    
    ip1 = '115.236.170.78'
    password1 = 'kikuu2018'
    
    ip2 = '115.236.170.78'
    password2 = 'kikuu2018'
    
    # 连接redis
    r = redis.Redis(host=ip1, password=password1, port=6379, db=0,
                    decode_responses=True)
    
    # 连接redis  带接收的库
    rNew = redis.Redis(host=ip2, password=password2, port=6379, db=0,
                       decode_responses=True)
    
    keyType = r.type(key)
    
    if keyType == 'string':
        rNew.set(key, r.get(key))
        print("key=" + key + "迁移到新库")
    
    if keyType == 'hash':
        cursor = r.hlen(key)
        print(" key值长度是 + ", cursor)
        moveHash(0)
    
    if keyType == 'list':
        moveList()
    

关键字