Python进阶学习_连接操作Redis数据库

安装导入第三方模块Redis

pip3 install redis

import redis

操作String类型

"""
redis 基本命令 String
set(name, value, ex=None, px=None, nx=False, xx=False)
在 Redis 中设置值，默认，不存在则创建，存在则修改。
参数：
    ex - 过期时间（秒）
    px - 过期时间（毫秒）
    nx - 如果设置为True，则只有name不存在时，当前set操作才执行
    xx - 如果设置为True，则只有name存在时，当前set操作才执行
redis 取出的结果默认是字节，我们可以设定 decode_responses=True 改成字符串。
"""
redis = redis.Redis(host="116.62.13.104", port=6379, decode_responses=True)
#  python-k1 代表key； hello 代表 value；  ex代表seconds；px代表ms
redis.set("python-k1","hello",ex=120)
# 获取值的第一种方式   使用  redis.get("key")
print(redis.get("python-k1"),type(redis.get("python-k1")))
# 获取值的第二种方式  直接使用  redis['key']
print(redis['python-k1'],type(redis['python-k1']))

连接池

redis-py 使用 connection pool 来管理对一个 redis server 的所有连接，避免每次建立、释放连接的开销。

"""
连接池
redis-py 使用 connection pool 来管理对一个 redis server 的所有连接，避免每次建立、释放连接的开销。
默认，每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池，然后作为参数 Redis，这样就可以实现多个 Redis 实例共享一个连接池。
"""
pool = redis.ConnectionPool(host='116.62.13.104', port=6379, decode_responses=True)
redis = redis.Redis(connection_pool=pool)

完整代码

# author: LiuShihao
# data: 2020/12/3 2:59 下午
# youknow: 各位老铁,我的这套代码曾经有人出价三个亿我没有卖,如今拿出来和大家分享,不求别的,只求大家免费的小红心帮忙点一点,这里谢过了。
# desc: Python操作Redis
"""
    通过 get()、set() 操作redis字符型数据；
    通过 hset()、hget() 操作redis哈希类型数据
    通过 json.dumps() 和 json.loads() 可以实现python中的字典数据的序列化和反序列化；
"""
import redis
import traceback

# redis = redis.Redis(host="116.62.13.104", port=6379, decode_responses=True)
"""
连接池
redis-py 使用 connection pool 来管理对一个 redis server 的所有连接，避免每次建立、释放连接的开销。
默认，每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池，然后作为参数 Redis，这样就可以实现多个 Redis 实例共享一个连接池。
"""
pool = redis.ConnectionPool(host='116.62.13.104', port=6379, decode_responses=True)
redis = redis.Redis(connection_pool=pool)

"""
redis 基本命令 String
set(name, value, ex=None, px=None, nx=False, xx=False)
在 Redis 中设置值，默认，不存在则创建，存在则修改。
参数：
    ex - 过期时间（秒）
    px - 过期时间（毫秒）
    nx - 如果设置为True，则只有name不存在时，当前set操作才执行
    xx - 如果设置为True，则只有name存在时，当前set操作才执行
redis 取出的结果默认是字节，我们可以设定 decode_responses=True 改成字符串。

    # 获取值的第一种方式   使用  redis.get("key")
    print(redis.get("python-k1"),type(redis.get("python-k1")))
    # 获取值的第二种方式  直接使用  redis['key']
    print(redis['python-k1'],type(redis['python-k1']))
"""

# 获取所有的key名
def findAllKeys():
    keyList = redis.keys()
    for item in keyList:
        print(item)
# 获取所有的键值对
def findAllKeyAndValue():
    # keyAndValue = []
    keyList = redis.keys()
    for item in keyList:
        print(item)
        value = redis[item]
        # d=dict(item=value)
        d= {item:value}
        print(d)
        # keyAndValue.append(d)


if __name__ == '__main__':
    # redis.set('PK2','PV2')
    # value = redis.get('PK2')
    # print('值：',value)
    findAllKeyAndValue()
    # print("键值对：",keyAndValue)

Bug redis.exceptions.ResponseError

报错信息：

redis.exceptions.ResponseError: MISCONF Redis is configured to save RDB snapshots, but it is currently not able to persist on disk. Commands that may modify the data set are disabled, because this instance is configured to report errors during writes if RDB snapshotting fails (stop-writes-on-bgsave-error option). Please check the Redis logs for details about the RDB error.

报错原因：
强制把redis快照关闭了导致不能持久化的问题。
解决方法：
在linux下通过redis-cli连接redis进行数据库操作：

redis-cli


config set stop-writes-on-bgsave-error no