当前位置：首页 > 技术分析 > 正文内容

Python Redis数据库新玩法:从零到高手掌握操作技巧

ruisui884个月前 (03-10)技术分析12

介绍

Redis（Remote Dictionary Server）是一种高性能的开源内存数据库，它支持多种数据结构，如字符串、哈希、列表、集合、有序集合等，并提供了丰富的操作命令。Redis具有快速、可靠和灵活的特点，广泛应用于缓存、消息队列、会话存储、计数器等场景。本文将从入门到精通地介绍Python中操作Redis数据库的方法，带你掌握使用Redis进行数据存储和读取的技巧。

目录

  1. 安装和导入
  2. 连接Redis数据库
  3. 字符串操作
  4. 哈希操作
  5. 列表操作
  6. 集合操作
  7. 有序集合操作
  8. 发布订阅模式
  9. 事务操作
  10. 过期时间和持久化
  11. 性能优化
  12. 分布式锁
  13. Redis主从复制
  14. Redis哨兵
  15. Redis集群
  16. 总结

1. 安装和导入

首先，我们需要安装Redis数据库。可以从Redis官网下载安装包进行安装，或者使用包管理工具进行安装。 安装完成后，我们需要在Python中导入redis模块来操作Redis数据库：

import redis

2. 连接Redis数据库

在使用Redis之前，我们需要先建立与Redis服务器的连接。可以使用redis.Redis()方法创建一个Redis客户端对象，然后通过该对象进行数据的存储和读取。

import redis

# 建立与本地Redis服务器的连接
client = redis.Redis(host='localhost', port=6379, db=0)

# 存储数据
client.set('name', 'Alice')

# 读取数据
value = client.get('name')
print(value.decode())

在上述代码中，我们使用redis.Redis()方法创建了一个与本地Redis服务器的连接，并使用client.set()方法存储了一个键值对，然后使用client.get()方法读取了数据，并通过decode()方法将二进制数据转换为字符串输出。

3. 字符串操作

Redis的字符串数据结构是最基本的数据类型，可以用来存储字符串、整数、浮点数等。

存储和读取字符串

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储字符串
client.set('name', 'Alice')

# 读取字符串
value = client.get('name')
print(value.decode())

增加和减少整数

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储整数
client.set('counter', 10)

# 增加整数
client.incr('counter', 5)

# 读取整数
value = client.get('counter')
print(int(value))

设置过期时间

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储字符串，并设置过期时间为10秒
client.setex('name', 10, 'Alice')

# 读取字符串
value = client.get('name')
print(value.decode())

# 等待11秒后，再次读取数据
import time
time.sleep(11)
value = client.get('name')
print(value)  # 过期后返回None

在上述代码中，我们使用client.setex()方法存储了一个带有过期时间的键值对，过期时间为10秒。等待11秒后，再次读取数据，发现键已经过期，返回了None。

4. 哈希操作

哈希是一种键值对的集合，适合存储对象。

存储和读取哈希

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储哈希
client.hset('user', 'name', 'Alice')
client.hset('user', 'age', 30)

# 读取哈希
name = client.hget('user', 'name')
age = client.hget('user', 'age')
print(name.decode(), age.decode())

获取所有键值对

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储哈希
client.hset('user', 'name', 'Alice')
client.hset('user', 'age', 30)

# 获取所有键值对
data = client.hgetall('user')
for key, value in data.items():
    print(key.decode(), value.decode())

5. 列表操作

列表是一种有序的字符串列表，可以存储重复的值。

存储和读取列表

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储列表
client.lpush('fruits', 'apple', 'orange', 'banana')

# 读取列表
fruits = client.lrange('fruits', 0, -1)
for fruit in fruits:
    print(fruit.decode())

获取列表长度

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储列表
client.lpush('fruits', 'apple', 'orange', 'banana')

# 获取列表长度
length = client.llen('fruits')
print(length)

弹出元素

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储列表
client.lpush('fruits', 'apple', 'orange', 'banana')

# 弹出元素
fruit = client.lpop('fruits')
print(fruit.decode())

# 再次读取列表
fruits = client.lrange('fruits', 0, -1)
for fruit in fruits:
    print(fruit.decode())

6. 集合操作

集合是一种无序的、不重复的字符串集合。

存储和读取集合

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储集合
client.sadd('fruits', 'apple', 'orange', 'banana')

# 读取集合
fruits = client.smembers('fruits')
for fruit in fruits:
    print(fruit.decode())

获取集合大小

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储集合
client.sadd('fruits', 'apple', 'orange', 'banana')

# 获取集合大小
size = client.scard('fruits')
print(size)

判断元素是否在集合中

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储集合
client.sadd('fruits', 'apple', 'orange', 'banana')

# 判断元素是否在集合中
print(client.sismember('fruits', 'apple'))
print(client.sismember('fruits', 'watermelon'))

7. 有序集合操作

有序集合是一种有序的、不重复的字符串集合，每个元素都有一个分数，可以根据分数进行排序。

存储和读取有序集合

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储有序集合
client.zadd('fruits', {'apple': 1, 'orange': 2, 'banana': 3})

# 读取有序集合
fruits = client.zrange('fruits', 0, -1, withscores=True)
for fruit, score in fruits:
    print(fruit.decode(), score)

获取元素排名和分数

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储有序集合
client.zadd('fruits', {'apple': 1, 'orange': 2, 'banana': 3})

# 获取元素排名和分数
rank = client.zrank('fruits', 'banana')
score = client.zscore('fruits', 'banana')
print(rank, score)

获取分数在范围内的元素

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储有序集合
client.zadd('fruits', {'apple': 1, 'orange': 2, 'banana': 3})

# 获取分数在范围内的元素
fruits = client.zrangebyscore('fruits', 1, 2, withscores=True)
for fruit, score in fruits:
    print(fruit.decode(), score)

8. 发布订阅模式

Redis支持发布订阅模式，可以将消息发布给多个订阅者。

发布消息

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 发布消息
client.publish('channel', 'Hello, subscribers!')

订阅消息

import redis

class Subscriber(redis.client.PubSub):

    def on_message(self, message):
        print('Received message:', message['data'].decode())

client = redis.Redis(host='localhost', port=6379, db=0)
subscriber = Subscriber()

# 订阅消息
subscriber.subscribe('channel')
client.publish('channel', 'Hello, subscribers!')  # 这里将收到消息

9. 事务操作

Redis支持事务操作，可以将多个命令放在一个事务中进行执行。

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 开启事务
with client.pipeline() as pipe:
    try:
        # 监听键值变化
        pipe.watch('counter')

        # 事务开始
        pipe.multi()

        # 执行多个命令
        pipe.incr('counter')
        pipe.incr('counter')
        pipe.incr('counter')

        # 执行事务
        pipe.execute()
    except redis.exceptions.WatchError:
        print('Counter value changed during transaction, transaction aborted.')

在上述代码中，我们使用client.pipeline()创建了一个事务管道，并使用pipe.watch()方法监听了一个键，然后在pipe.multi()和pipe.execute()之间执行了多个命令。如果在事务执行期间，被监听的键的值发生了变化，
redis.exceptions.WatchError异常将会被抛出，表示事务被中止。

10. 过期时间和持久化

设置过期时间

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 存储字符串，并设置过期时间为10秒
client.setex('name', 10, 'Alice')

持久化

Redis支持将数据持久化到磁盘中，以防止数据丢失。

RDB持久化

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 执行保存操作
client.save()

AOF持久化

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 执行保存操作
client.bgsave()

11. 性能优化

在大规模使用Redis时，需要考虑性能优化的问题。

使用连接池

import redis

# 建立与本地Redis服务器的连接池
pool = redis.ConnectionPool(host='localhost', port=6379, db=0)
client = redis.Redis(connection_pool=pool)

使用管道

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 使用管道执行多个命令
with client.pipeline() as pipe:
    pipe.set('name', 'Alice')
    pipe.get('name')
    results = pipe.execute()
    print(results)

使用批量操作

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 使用批量操作
client.mset({'name': 'Alice', 'age': 30})
data = client.mget('name', 'age')
print(data)

12. 分布式锁

分布式锁是在分布式系统中实现并发控制的一种机制。

import redis

client = redis.Redis(host='localhost', port=6379, db=0)

# 获取锁
lock = client.lock('my_lock')

# 阻塞方式获取锁
with lock:
    print('Lock acquired.')

    # 非阻塞方式获取锁
if lock.acquire(blocking=False):
    print('Lock acquired.')
else:
    print('Failed to acquire lock.')

13. Redis主从复制

Redis支持主从复制，可以将主节点的数据复制到从节点。

import redis

# 创建主节点连接
master = redis.Redis(host='localhost', port=6379, db=0)

# 创建从节点连接
slave = master.slaveof()

# 查看从节点信息
info = slave.info()
print(info)

14. Redis哨兵

Redis哨兵用于监控Redis主从复制的状态，以实现高可用性。

import redis

# 创建哨兵连接
sentinel = redis.StrictRedis(host='localhost', port=26379, db=0)

# 获取主节点连接
master = sentinel.sentinel_get_master_addr_by_name('mymaster')
print(master)

15. Redis集群

Redis支持集群模式，可以将数据分布在多个节点上。

from rediscluster import StrictRedisCluster

# 创建集群节点连接
startup_nodes = [{'host': 'localhost', 'port': '7000'}, {'host': 'localhost', 'port': '7001'}]
client = StrictRedisCluster(startup_nodes=startup_nodes)

# 存储数据
client.set('name', 'Alice')

# 读取数据
value = client.get('name')
print(value.decode())

16. 总结

本文介绍了Python中操作Redis数据库的方法，包括连接Redis数据库、字符串操作、哈希操作、列表操作、集合操作、有序集合操作、发布订阅模式、事务操作、过期时间和持久化、性能优化、分布式锁、Redis主从复制、Redis哨兵和Redis集群。掌握这些知识，你将能够灵活运用Redis数据库来处理数据，提高系统的性能和可靠性。希望本文能帮助你学习和使用Redis，在实际项目中发挥更大的作用。

扫描二维码推送至手机访问。

版权声明：本文由ruisui88发布，如需转载请注明出处。

本文链接：http://www.ruisui88.com/post/2657.html

标签: python连接redis数据库
分享给朋友：
返回列表

上一篇：Python教程——24.Redis 数据库

下一篇：python3将mysql数据库数据库缓存到redis应用场景

“Python Redis数据库新玩法:从零到高手掌握操作技巧” 的相关文章

vue 3 学习笔记 (八)——provide 和 inject 用法及原理

在父子组件传递数据时，通常使用的是 props 和 emit，父传子时，使用的是 props，如果是父组件传孙组件时，就需要先传给子组件，子组件再传给孙组件，如果多个子组件或多个孙组件使用时，就需要传很多次，会很麻烦。像这种情况，可以使用 provide 和 inject 解决这种问题，不论组件嵌套...

GitLab-合并请求

描述合并请求可用于在您对项目进行的其他人员之间交换代码，并轻松与他们讨论更改。合并请求的步骤步骤1-在创建新的合并请求之前，GitLab中应该有一个创建的分支。您可以参考本章来创建分支-步骤2-登录到您的GitLab帐户，然后转到“ 项目”部分下的项目 -步骤3-单击“ 合并请求”选项卡，然后单击“...

身体越柔软越好?刻苦拉伸可能反而不健康 | 果断练

坐下伸直膝盖，双手用力向前伸，再用力……比昨天前进了一厘米，又进步了！ 这么努力地拉伸，每个人都有自己的目标，也许是身体健康、线条柔美、放松肌肉、体测满分，也可能为了随时劈个叉，享受一片惊呼。 不过，身体柔软，可以享受到灵活的福利，也可能付出不稳定的代价，并不是越刻苦拉伸越好。太硬或者太软，都不安全...

摄影后期必看 | PS插件camera raw 16.4教程 | 范围蒙版

范围蒙版Camera Raw 【蒙版】模块中提供了三个范围蒙版工具，可以通过特定的范围来创建蒙版。此次新增的【范围蒙版】大大加强了acr插件对局部调整的能力。点击下拉小箭头可以看到【颜色范围】，可用于快速选择想要编辑的颜色。快捷键：Shift + C【明亮度范围】，可用于快速选择想要调整的明亮度。快...

「干货」FPGA设计中深度约束技巧及调试经验总结

今天跟大家分享的内容很重要，也是我们调试FPGA经验的总结。随着FPGA对时序和性能的要求越来越高，高频率、大位宽的设计越来越多。在调试这些FPGA样机时，需要从写代码时就要小心谨慎，否则写出来的代码可能无法满足时序要求。另外，最近跟网友聊天时，有谈到公众号寿命的问题，我觉得网络交换FPGA公众号应...

vue.js 双向绑定如何理解，有什么好处!#云南小程序开发

Vue.js 的双向数据绑定是借助于 JavaScript 的一些特性，如对象的属性 getter 和 setter 以及 Vue 的依赖追踪系统实现的。简单来说，双向数据绑定就是数据与视图间的双向通信，也就是说数据的改变会马上反映到视图中，视图的改变也会立刻改变数据。具体来说，当你改变了数据时，视...

蜀ICP备2024111239号-14