备案控制台
开发者社区 数据库 文章 正文

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

2023-08-17 88
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 Redis 版，社区版 2GB
推荐场景：
搭建游戏排行榜
简介： Python Redis数据库新玩法：从零到高手掌握操作技巧

介绍

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，在实际项目中发挥更大的作用。

文章标签：
云数据库 Redis 版
NoSQL
Redis
数据库
存储
Python
关键词：
Python数据库
python云数据库 Redis 版
Python Redis
云数据库 Redis 版Python
Python redis数据库
相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务，基于高可靠双机热备架构及可无缝扩展的集群架构，满足高读写性能场景及容量需弹性变配的业务需求。 产品详情：https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验：数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引，您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接，领取免费ECS&RDS资源，30分钟完成数据库上云实战！https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
子午s
目录
相关文章
众所周知
|
6天前
|
存储 NoSQL Redis
在Python Web开发过程中，为什么Redis运行速度快
【5月更文挑战第15天】Redis在Python Web开发中运行速度快，原因包括：1) 丰富数据类型满足多样化需求；2) 简单数据模型提升查询效率；3) 单线程模型结合非阻塞I/O实现高效处理；4) 持久化机制保证数据安全；5) 二进制协议与管道技术优化网络通信。这些因素共同确保Redis能处理大量请求并保持高性能。
众所周知
25 1
长梦
|
6天前
|
缓存 NoSQL Redis
Python缓存技术（Memcached、Redis）面试题解析
【4月更文挑战第18天】本文探讨了Python面试中关于Memcached和Redis的常见问题，包括两者的基础概念、特性对比、客户端使用、缓存策略及应用场景。同时，文章指出了易错点，如数据不一致和缓存淘汰策略，并提供了实战代码示例，帮助读者掌握这两款内存键值存储系统的使用和优化技巧。通过理解其核心特性和避免常见错误，可以提升在面试中的表现。
长梦
31 2
傻啦嘿哟
|
6天前
|
存储 NoSQL MongoDB
MongoDB数据库转换为表格文件的Python实现
MongoDB数据库转换为表格文件的Python实现
傻啦嘿哟
39 0
众所周知
|
6天前
|
SQL 关系型数据库 数据库连接
使用 Python 访问数据库的基本方法
【5月更文挑战第12天】在Python中操作数据库涉及安装数据库驱动（如mysql-connector-python, psycopg2, pymongo）、连接数据库、执行查询/更新、处理结果集及关闭连接。使用ORM（如SQLAlchemy）可简化操作。通过上下文管理器（with语句）能更好地管理资源和错误。注意根据实际需求处理事务、错误和安全性，例如使用SSL连接。
众所周知
23 2
dulu~dulu
|
5天前
|
SQL 关系型数据库 数据库
Python——数据库操作
Python——数据库操作
dulu~dulu
16 2
是Yu欸
|
6天前
|
Oracle Java 关系型数据库
【服务器】python通过JDBC连接到位于Linux远程服务器上的Oracle数据库
【服务器】python通过JDBC连接到位于Linux远程服务器上的Oracle数据库
是Yu欸
17 6
景天科技苑
|
6天前
|
API 数据库 Python
Python web框架fastapi数据库操作ORM（二）增删改查逻辑实现方法
Python web框架fastapi数据库操作ORM（二）增删改查逻辑实现方法
景天科技苑
44 1
景天科技苑
|
6天前
|
关系型数据库 MySQL API
Python web框架fastapi数据库操作ORM（一）
Python web框架fastapi数据库操作ORM（一）
景天科技苑
71 2
景天科技苑
|
6天前
|
SQL 关系型数据库 MySQL
Python操作mysql数据库
Python操作mysql数据库
景天科技苑
19 4
龙大吉
|
6天前
|
缓存 NoSQL 关系型数据库
在Python Web开发过程中：数据库与缓存，MySQL和NoSQL数据库的主要差异是什么？
MySQL与NoSQL的主要区别在于数据结构、查询语言和可扩展性。MySQL是关系型数据库，依赖预定义的数据表结构，使用SQL进行复杂查询，适合垂直扩展。而NoSQL提供灵活的存储方式（如JSON、哈希表），无统一查询语言，支持横向扩展，适用于处理大规模、非结构化数据和高并发场景。选择哪种取决于应用需求、数据模型及扩展策略。
龙大吉
170 0

热门文章

最新文章

  • 1
    最佳实践｜如何使用c++开发redis module
  • 2
    使用Redis实例搭建网上商城的商品相关性分析程序
  • 3
    使用Redis进行Java缓存策略设计
  • 4
    Java语言开发的AI智慧导诊系统源码springboot+redis 3D互联网智导诊系统源码
  • 5
    Redis的安装（Linux版）
  • 6
    通过OOS实现定时备份Redis实例转储到OSS
  • 7
    软件体系结构 - 缓存技术（5）Redis Cluster
  • 8
    Redis奔溃了快看看有没开启持久化
  • 9
    Redis多级缓存指南：从前端到后端全方位优化！
  • 10
    Redis 实现延迟任务的深度解析
  • 1
    请简述Python中的垃圾回收机制。
    15
  • 2
    Python中如何实现二分查找？请提供代码示例。
    26
  • 3
    Python中如何实现列表去重？请提供至少两种方法
    21
  • 4
    Python中的装饰器：概念、用法和实例
    23
  • 5
    Python中的装饰器：概念、用法及实例
    19
  • 6
    使用Python实现图像处理中的边缘检测算法
    100
  • 7
    Python中如何实现字符串反转？请提供至少两种方法。
    26
  • 8
    在Python中，如何创建一个迭代器？
    22
  • 9
    请解释Python中的迭代器和生成器的区别？并分别举例说明。
    21
  • 10
    在Python中，如何使用装饰器重写类的方法？
    293

    • 相关课程

    更多
  • Python Web开发基础
  • Python开发基础入门
  • Python常用数据科学库
  • Python网络爬虫实战
  • Python完全自学手册图文教程
  • Python基础快速入门实战教程

    • 相关电子书

    更多
  • From Python Scikit-Learn to Sc
  • Data Pre-Processing in Python:
  • 双剑合璧-Python和大数据计算平台的结合

    • 相关实验场景

    更多
  • 用Python画圣诞树
  • 使用Python完成RDS数据开发及分析
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 云原生HTAP数据库，让你的交易和分析一库搞定
  • 快速体验PolarDB开源数据库
  • 手把手教你把IoT传感器数据存储到数据库
    • 下一篇
    2024年阿里云免费云服务器及学生云服务器申请教程参考