1. 首先安装啊
pip install redis-py-cluster
2. 开始使用集群操作咯
RedisConf.nodelist = [{'host':'10.2**.1**.**', 'port':'6379'}, {'host':'10.**5.*2.**2', 'port':'6379'}]
from redisclusterimport RedisCluster
# redis集群操作
class SxRedis:
"""
使用举例： print(f"检查返回值：{SxRedis().connect().get('IM:ACCOUNT:RED_PAPER_ORDER:594233041325531137:red_13b8242875966000')}")
"""
def __init__(self):
self.conn_list = RedisConf.nodelist# 连接列表
self.sxredis =self.connect()
def connect(self):
"""
连接redis集群
:return: object
"""
try:
# 使用密码连接redis集群
redisconn = RedisCluster(startup_nodes=self.conn_list, decode_responses=True, password='sdjsx')
return redisconn
except Exception as e:
print("错误,连接redis 集群失败")
raise e
# 来看看使用举例
if __name__ =='__main__':
pass
print(f"检查返回值：{SxRedis().connect().get('ipush_invalid_token_619699241471844353')}")
# print(f"检查返回值：{SxRedis().connect()..hgetall('IM:ACCOUNT:RED_PAPER_ORDER:530868770131025921')}")
# print(f"检查返回值：{SxRedis().connect().delete('ipush_invalid_token_619699241471844353')}")
『『需自动化项目源码\交流学习添加v：ct-xiaozhou
免费提供的。行业变迁，多个好友多点可能性。非机构』』
