官方

• 文档 https://redis.io/docs/latest/develop/connect/clients/python/
• 仓库 https://github.com/redis/redis-py

安装库

pip install redis

普通连接

r = redis.Redis(host='10.0.0.5', port=6379, decode_responses=True)

• decode_responses 表示响应的结果是解码后的

指定密码

r = redis.Redis(host='10.0.0.5', port=6379, password='111111')

指定库

r = redis.Redis(host='10.0.0.5', port=6379, password='111111', db=5)

使用TLS连接Redis

import redis

r = redis.Redis(
    host="10.0.0.5", port=6379,
    username="default", # use your Redis user. More info https://redis.io/docs/latest/operate/oss_and_stack/management/security/acl/
    password="secret", # use your Redis password
    ssl=True,
    ssl_certfile="./redis_user.crt",
    ssl_keyfile="./redis_user_private.key",
    ssl_ca_certs="./redis_ca.pem",
)

通过地址池连接

import redis

# pool=redis.ConnectionPool(host='10.0.0.5', db=2, password='111111')
# pool = redis.ConnectionPool.from_url("redis://:[email protected]/4")
pool = redis.ConnectionPool.from_url("redis://:[email protected]/4?decode_responses=True&socket_timeout=10&encoding=utf-8")
r = redis.Redis(connection_pool=pool)

操作

键操作

值操作：字符串操作

Redis支持最基本的键值对形式存储

值操作：列表操作

Redis还提供了列表存储，列表内的元素可以重复，而且可以从两端存储

值操作：集合操作

Redis还提供了集合存储，集合中的元素都是不重复的

值操作：有序集合操作

有序集合比集合多了一个分数字段，利用它可以对集合中的数据进行排序

值操作：散列操作

Redis还提供了散列表的数据结构，我们可以用 name 指定一个散列表的名称，表内存储了各个键值对

pipeline

使用pipeline，同时一次性发送多个命令，服务器不用逐个返回结果，而是将所有结果一次性返回。

pipeline开启事务后，如果出现命令错误，执行失败，所有命令执行失败；如果个别命令有语法错误，正确命令执行，错误命令抛出异常。

import redis

with redis.Redis.from_url("redis://:[email protected]:6379/5") as c:
    print(type(c), c)
    print(c.keys("*"))
    p1 = c.pipeline(True)
    p1.hmset("a", {"a": 1, "b": 2, "c": 3})
    p1.hsetnx("a", "a", 22)
    p1.abc()
    results = p1.execute()
    print(results)
"""
<class 'redis.client.Redis'> Redis<ConnectionPool<Connection<host=10.0.0.5,port=6379,db=5>>>
[b'a']
Traceback (most recent call last):
  File "D:/pythonProject/test_bs4/Redis/t1.py", line 9, in <module>
    p1.abc()
AttributeError: 'Pipeline' object has no attribute 'abc'
"""

特别注意，如果我们需要事务处理的时候，可以考虑pipeline中开启，保证一系列操作完整操作。

订阅/发布

订阅

import time
import redis

with redis.Redis.from_url("redis://:[email protected]/4") as c:
    # 消费者
    # 需要先创建订阅对象
    p1 = c.pubsub()
    p1.subscribe("c1")
    # # 阻塞的方式接收消息
    for i in p1.listen():
        print(i,type(i))

    # 非阻塞的方式接收消息
    while True:
        msg = p1.get_message(ignore_subscribe_messages=True)
        if msg:
            print(msg)
        time.sleep(0.5)

发布

import redis

with redis.Redis.from_url("redis://:[email protected]/4") as c:
    print(type(c), c)
    # 生产者
    p = c.publish("c1", 11111)
    print("订阅的个数:", p)

哨兵模式变成

https://github.com/RedisLabs/redis-py#sentinel-support

通过哨兵获取主节点和从节点

• 返回的元组方式

from redis.sentinel import Sentinel

sentinels = Sentinel([("10.0.0.4", 26379)])

# mymaster2是集群的标识符
print(sentinels.discover_master("mymaster2"))
print(sentinels.discover_slaves("mymaster2"))

"""
('10.0.0.5', 6379)
[('10.0.0.4', 6379)]
"""

如果抛异常，无法访问Sentinel，请修改Sentinel的配置，增加 protected-mode no 。保护模式如果开启，只接受回环地址连接，拒绝外部链接，而且正常应该配置多个哨兵，避免一个哨兵出现独裁情况，如果配置多个哨兵，开启保护，也会拒绝其它sentinel的连接，从而导致哨兵配置无法生效。

• 返回Redis类的方式

from redis.sentinel import Sentinel

sentinels = Sentinel([("10.0.0.4", 26379)])

m_rd = sentinels.master_for("mymaster2")
s_rd = sentinels.slave_for("mymaster2")
print(m_rd, type(m_rd), s_rd, type(s_rd))

"""
Redis<SentinelConnectionPool<service=mymaster2(master)> <class 'redis.client.Redis'> Redis<SentinelConnectionPool<service=mymaster2(slave)> <class 'redis.client.Redis'>
"""

返回的Redis类可以直接用来连接redis

需要加入库号和密码

from redis.sentinel import Sentinel

sentinels = Sentinel([("10.0.0.4", 26379)])

# 通过源码可以看出，可以通过塞入库号和密码的方式来访问库
m_rd = sentinels.master_for("mymaster2", db=1, password="111111")
s_rd = sentinels.slave_for("mymaster2", db=1, password="111111")
print(m_rd, type(m_rd), s_rd, type(s_rd))
# 通过返回的类直接操作数据库
print(m_rd.keys())
print(s_rd.keys())
print(m_rd.get("a"))
print(s_rd.get("a"))

"""
Redis<SentinelConnectionPool<service=mymaster2(master)> <class 'redis.client.Redis'> Redis<SentinelConnectionPool<service=mymaster2(slave)> <class 'redis.client.Redis'>
[b's2', b'a', b's1', b's3', b'c', b'3', b'd']
[b'd', b'c', b's3', b'a', b's2', b'3', b's1']
b'2'
b'2'
"""