Python 操作Redis集群 Python

【Python 操作Redis集群】Python 的 Redis 库是不支持集群操作的，推荐库：redis-py-cluster
安装

pip install redis-py-cluster

连接集群并操作set

from rediscluster import StrictRedisClusterclass RedisCluster(object):# 连接redis集群 def __init__(self, conn_list): self.conn_list = conn_list# 连接列表def connect(self): """ 连接redis集群 :return: object """ try: # 非密码连接redis集群 # redisconn = StrictRedisCluster(startup_nodes=self.conn_list) # 使用密码连接redis集群 redisconn = StrictRedisCluster(startup_nodes=self.conn_list, password='8Mbh8Ykz') return redisconn except Exception as e: print(e) print("错误,连接redis 集群失败") return Falseif __name__ == '__main__': redis_basis_conn = [{'host': '192.17.210.84', 'port': 7001}, {'host': '192.17.210.85', 'port': 7003}, {'host': '192.17.210.86', 'port': 7005}, {'host': '192.17.210.84', 'port': 7002}, {'host': '192.17.210.84', 'port': 7004}, {'host': '192.17.210.84', 'port': 7006}]res = RedisCluster(redis_basis_conn).connect() if not res: print("连接redis集群失败") else: print("连接redis集群成功")redis_conn = RedisCluster(redis_basis_conn).connect()# redis连接对象 parames = {500059684,500059713,500059714,500059670,500059675,500059677,500059678} for parame in parames: redis_conn.sadd('search_uids', parame)