Python与Redis集群交互

第一步：安装依赖包

pip3 instal redis-py-cluster

第二步：创建文件redis_cluster.py，代码如下：

from rediscluster import *

if __name__ == '__main__':
try:
# 构建所有的节点，Redsi会使用CRC16算法，将键和值写到某个节点上。
startup_nodes = [
{'host': '192.168.183.130', 'port': '7000'},
{'host': '192.168.183.128', 'port': '7004'},
{'host': '192.168.183.130', 'port': '7001'},
{'host': '192.168.183.128', 'port': '7005'}
]
# 构建StrictRedisCluster对象
src = StrictRedisCluster(startup_nodes=startup_nodes, decode_responses=True)
# 设置键为name，值为宇智波鼬
result = src.set('name', '宇智波鼬')
print(result)
# 获取键为name对应的值
name = src.get('name')
print(name)
except Exception as e:
print(e)

第三步：运行文件

ubantu@ubantu-virtual-machine:~$ python3 redis_cluster.py
True
宇智波鼬