[大数据]python3-redis集群写入和查询

本文参考多位大佬博客希望大佬们看到多多包涵。
一、项目背景：
????????接口需要验签，验签需要redis中的key值和token，单使用接口依赖返回token不能顺利完成接口自动化
二、数据准备
????????需要写入redis的数据：
????????name = 'INZONEZB_TOKEN_0dc8f225-63b7-4147-82c6-ce6dd436f9ss'#哈希值（token名称）
????????customerId = '"dbc9d88b-cc5b-421c-a369-08eb3939c13f"'
????????key = '"0d8b1f62-9445-4cd3-b863-2bcaa05c8bd7"'

????????????????需要写入redis数据如下：

? ? ? ? ? ? ? ? ?redis集群：

{"host": "19.160.160.28", "port": 6001}, {"host": "19.160.160.28", "port": 6002}

密码为空：password=''

三、需求分析

? ? ? ? 1.连接redis

? ? ? ? 2.写入数据

? ? ? ? 3.读取数据

四、代码实现

? ? ? ? 1.连接redis

from rediscluster import RedisCluster

r = RedisCluster(
    startup_nodes=[{"host": "19.160.160.28", "port": 6001}, {"host": "19.160.160.28", "port": 6002}],
    password='')

r.ping()#检查连接

????????2.写入数据

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

from rediscluster import RedisCluster
from self import self

# 测试环境redis集群
r = RedisCluster(
    startup_nodes=[{"host": "19.160.160.28", "port": 6001}, {"host": "19.160.160.28", "port": 6002}],
    password='')


class redis_operate:

    def redis_insert(self, name, customerId, key):
        # redis写入
        r.hmset(name,
                {'customerId': customerId})
        r.hmset(name,
                {'key': key})

????????3.读取数据

def redis_query(self, name):
    res = r.hgetall(name)
    return res

完整代码如下：

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

from rediscluster import RedisCluster
from self import self

# 测试环境redis集群
r = RedisCluster(
    startup_nodes=[{"host": "19.160.160.28", "port": 6001}, {"host": "19.160.160.28", "port": 6002}],
    password='')


class redis_operate:

    def redis_insert(self, name, customerId, key):
        # redis写入
        r.hmset(name,
                {'customerId': customerId})
        r.hmset(name,
                {'key': key})

    def redis_query(self, name):
        res = r.hgetall(name)
        return res
        # print(res)


if __name__ == '__main__':
    name = 'INZONEZB_TOKEN_0dc8f225-63b7-4147-82c6-ce6dd436f9ss'

    customerId = '"dbc9d88b-cc5b-421c-a369-08eb3939c13f"'
    key = '"0d8b1f62-9445-4cd3-b863-2bcaa05c8bd7"'
    # redis_operate.redis_insert(self, name, customerId, key)
    dd = redis_operate.redis_query(self, name)
    # dd = sign_obtain.mdjimi(res)
    print(dd)

五、使用redis桌面校验

?

注意事项：若写入不成功或报错，检查安装的redis依赖包的版本，我用的redis2.10.6

?

愿你出走半生，归来仍是少年