安装
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