python连接redis集群，安装redis-py-cluster模块

pip install redis-py-cluster

from rediscluster import RedisCluster

def redis_list(redis_str):
    '''
    集群处理
    :return:
    '''
    REDIS_NODES = []
    #redis_str = "99.99.3.12:7006,99.99.3.12:7004,99.99.3.12:7002,99.99.3.12:7005,99.99.3.12:7001,99.99.3.12:7003"
    # print("输入样例:99.99.3.12:7006,99.99.3.12:7004,99.99.3.12:7002")
    # redis_str=input("输入集群：")
    if "," in redis_str:
        lines = redis_str.split(',')
        for i in lines:
            line = i.split(":")
            REDIS_NODES.append({"host": line[0], "port": line[1]})
    else:
        line = redis_str.split(":")
        REDIS_NODES.append({"host": line[0], "port": line[1]})
    return REDIS_NODES


def redis_conn(redis_str):
    '''
    连接redis集群
    :return:
    '''
    REDIS_NODES=redis_list(redis_str)
    req = None
    try:
        req = RedisCluster(startup_nodes=REDIS_NODES, max_connections=1000, decode_responses=True)
    except Exception as e:
        print("conn error:{}".format(e))
    return req


if __name__ == '__main__':
    redis_str = "99.99.3.12:7006,99.99.3.12:7004,99.99.3.12:7002,99.99.3.12:7005,99.99.3.12:7001,99.99.3.12:7003"
    conn = redis_conn(redis_str)
    val = conn.hgetall("catering:mall:product:v1:productGp:[823882,1100000284]")
    print(val)