连接redis集群

cooolr 于 2021-06-11 发布

安装

pip install redis-py-cluster

连接集群

from rediscluster import RedisCluster

r = RedisCluster(startup_nodes=[{"host": "192.168.1.101", "port": 6381},{"host": "192.168.1.102", "port": 6379}], password='123456')

检查连接

r.ping()

兼容连接

import redis
from rediscluster import RedisCluster

def get_redis_client_connection():
    if "startup_nodes" not in config.redis_config:
        if "%" in config.redis_config:
            r = redis.Redis.from_url(config.redis_config, decode_components=True)
        else:
            if type(config.redis_config) == dict:
                r = redis.Redis(**config.redis_config)
            else:
                r = redis.Redis.from_url(config.redis_config)
    else:
        r = RedisCluster(**config.redis_config)
    return r