专栏首页Devops专栏Python3交互redis cluster

Python3交互redis cluster

安装

pip install redis-py-cluster

示例代码

# pip install redis-py-cluster
from rediscluster import *

"""
redis 集群信息:
Using 3 masters:
192.168.196.131:7000
192.168.196.129:7003
192.168.196.131:7001
Adding replica 192.168.196.129:7004 to 192.168.196.131:7000
Adding replica 192.168.196.131:7002 to 192.168.196.129:7003
Adding replica 192.168.196.129:7005 to 192.168.196.131:7001
"""

if __name__ == '__main__':
    try:
        # 构建所有的节点,Redis会使⽤CRC16算法,将键和值写到某个节点上
        startup_nodes = [
            {'host': '192.168.196.131', 'port': '7000'},
            {'host': '192.168.196.129', 'port': '7003'},
            {'host': '192.168.196.131', 'port': '7001'},
        ]
        # 构建StrictRedisCluster对象
        src = StrictRedisCluster(startup_nodes=startup_nodes, decode_responses=True)
        # 设置键为key1、值为test-hello-world的数据
        result = src.set('key1', 'test-hello-world')
        print(result)
        # 获取键为name
        name = src.get('key1')
        print(name)
    except Exception as e:
        print(e)

运行如下:

封装类方法

# pip install redis-py-cluster
from rediscluster import *

"""
redis 集群信息:
Using 3 masters:
192.168.196.131:7000
192.168.196.129:7003
192.168.196.131:7001
Adding replica 192.168.196.129:7004 to 192.168.196.131:7000
Adding replica 192.168.196.131:7002 to 192.168.196.129:7003
Adding replica 192.168.196.129:7005 to 192.168.196.131:7001
"""

class redisClusterHelper():
    def __init__(self,startup_nodes):
        try:
            # 构建StrictRedisCluster对象
            self.src = StrictRedisCluster(startup_nodes=startup_nodes, decode_responses=True)
        except Exception as e:
            print(e)

    def set_key(self,key,value):
        return self.src.set(key, value)

    def get_key(self,key):
        return self.src.get(key)

if __name__ == '__main__':

    # 设置redis cluster集群的master节点
    startup_nodes = [
        {'host': '192.168.196.131', 'port': '7000'},
        {'host': '192.168.196.129', 'port': '7003'},
        {'host': '192.168.196.131', 'port': '7001'},
    ]

    # 创建redis cluster的连接
    rch = redisClusterHelper(startup_nodes)

    # 设置key值
    rch.set_key("test2","hello2")

    # 获取key值
    print(rch.get_key('test2'))

运行如下:

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Centos7 下 Openresty 从安装到入门

    根据官网的描述提供了不同的安装方式,例如:使用yum安装、源码编译安装等等。我目前暂时使用yum安装方式进行部署看看。

    Devops海洋的渔夫
  • python3 交互 memcached

    Devops海洋的渔夫
  • css3背景颜色渐变属性(Gradients)

    在项目中有很多地方可以用到背景色的渐变,例如:左侧菜单栏的背景色,顶部导航栏背景色等等。

    Devops海洋的渔夫
  • 数据结构?从HashMap的源码分析开始!

    首先,先看下inflateTable方法,这个是初始化HashMap里面的线性表的空间:

    大大大大大先生
  • QML文件读写控件(预览版)

    File组件通过source的属性来设置需要读写的文件,还可以通过访问/设置text的内容来读取/写入文件。

    Qt君
  • 数据科学家节选(1)

    【节选自即将由电子工业出版社出版的《数据科学家养成手册》第一章】 什么是科学家 从我们每个人上学前班的时候,我们就开始受到各种各样的启蒙教育,哪怕是捏橡皮泥、...

    刀刀老高
  • Java面试之CAS

    功能:判断内存某个位置的L值是否为预期值,如果是则更改为新的值,这个过程是原子的。

    乐心湖
  • Tensorflow简单CNN实现详解

    glob是python自己带的一个文件操作相关模块,用它可以查找符合自己目的的文件,就类似于Windows下的文件搜索,支持通配符操作,*,?,[]这三个通配符...

    DrawSky
  • Elasticsearch 5.x 安装与配置

    Elasticsearch官方建议使用 Oracle的JDK8 1、下载安装 [root@vnode0 opt]# tar -zxvf elasticsearc...

    程裕强
  • 浅谈GAIAWORLD独家自研技术背后的逻辑及意义

    我们认为区块链不仅是世界的操作系统,它本身就应该是一个自治世界!在此系统中,每个节点相互连接与交互,整个系统自治管理自己的行为,形成一个去中心化的自治的数字世界...

    GAIAWorld

扫码关注云+社区

领取腾讯云代金券