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

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

2023-08-17 143
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 Tair（兼容Redis），内存型 2GB
推荐场景：
通过缓存加速数据库访问
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，在实际项目中发挥更大的作用。

文章标签：
云数据库 Tair（兼容 Redis）
NoSQL
Redis
数据库
存储
Python
关键词：
Python数据库
Python Redis
python云数据库 Tair（兼容 Redis）
云数据库 Tair（兼容 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
目录
相关文章
技能实验室
|
1月前
|
关系型数据库 MySQL 数据库连接
python脚本：连接数据库，检查直播流是否可用
【10月更文挑战第13天】本脚本使用 `mysql-connector-python` 连接MySQL数据库，检查 `live_streams` 表中每个直播流URL的可用性。通过 `requests` 库发送HTTP请求，输出每个URL的检查结果。需安装 `mysql-connector-python` 和 `requests` 库，并配置数据库连接参数。
技能实验室
132 68
AIweker
|
16天前
|
关系型数据库 MySQL 数据库
Python处理数据库：MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库，包括安装必要的库、连接数据库、执行增删改查等基本操作，适合初学者快速上手。
AIweker
105 15
aliyun0641063962-48771
|
2月前
|
关系型数据库 MySQL 数据处理
探索Python中的异步编程：从asyncio到异步数据库操作
在这个快节奏的技术世界里，效率和性能是关键。本文将带你深入Python的异步编程世界，从基础的asyncio库开始，逐步探索到异步数据库操作的高级应用。我们将一起揭开异步编程的神秘面纱，探索它如何帮助我们提升应用程序的性能和响应速度。
aliyun0641063962-48771
77 3
古明地盆
|
2月前
|
存储 缓存 Shell
你知道 Python 其实自带了小型数据库吗
你知道 Python 其实自带了小型数据库吗
古明地盆
26 2
你知道 Python 其实自带了小型数据库吗
bruce_xiaowei
|
2月前
|
Web App开发 SQL 数据库
使用 Python 解析火狐浏览器的 SQLite3 数据库
本文介绍如何使用 Python 解析火狐浏览器的 SQLite3 数据库，包括书签、历史记录和下载记录等。通过安装 Python 和 SQLite3，定位火狐数据库文件路径，编写 Python 脚本连接数据库并执行 SQL 查询，最终输出最近访问的网站历史记录。
bruce_xiaowei
44 4
1919324350086154
|
2月前
|
SQL 机器学习/深度学习 数据采集
SQL与Python集成：数据库操作无缝衔接22.bijius.com
自动化数据预处理：使用Python库（如Pandas）自动清洗、转换和准备数据，为机器学习模型提供高质量输入。 实时数据处理：集成Apache Kafka或Amazon Kinesis等流处理系统，实现实时数据更新和分析。
1919324350086154
31 5
bruce_xiaowei
|
2月前
|
存储 关系型数据库 数据库
轻量级数据库的利器：Python 及其内置 SQLite 简介
轻量级数据库的利器：Python 及其内置 SQLite 简介
bruce_xiaowei
70 3
1919324350086154
|
2月前
|
SQL 机器学习/深度学习 数据库
SQL与Python集成：数据库操作无缝衔接
在开始之前，确保你已经安装了必要的Python库，如`sqlite3`（用于SQLite数据库）或`psycopg2`（用于PostgreSQL数据库）。这些库提供了Python与SQL数据库之间的接口。
1919324350086154
51 1
有路有乔-六月
|
2月前
|
SQL 关系型数据库 数据库
使用 PostgreSQL 和 Python 实现数据库操作
【10月更文挑战第2天】使用 PostgreSQL 和 Python 实现数据库操作
有路有乔-六月
191 1
bruce_xiaowei
|
3月前
|
数据采集 关系型数据库 MySQL
如何用Python+sqlalchemy创建数据库
如何用Python+sqlalchemy创建数据库
bruce_xiaowei
43 2

热门文章

最新文章

  • 1
    如何正确地使用Redis（附性能测试实验结果）
  • 2
    如何在阿里云服务器上安装Redis数据库
  • 3
    探讨 Redis 和 MySQL 的特点，并比较它们在不同方面的优势和限制
  • 4
    Redis之 redis.conf配置文件
  • 5
    队列工厂之RedisMQ
  • 6
    redis运维常用命令
  • 7
    redis 未授权访问漏洞和防范
  • 8
    Linux java mysql es redis 安装
  • 9
    如何实现基于Redis的在线人数统计功能？
  • 10
    Redis安装与配置指南：适用于Windows、Mac和Linux系统的详细教程
  • 1
    Python 密码学实用指南（全）（2）
    40
  • 2
    【python】习题 第10周
    62
  • 3
    【python】习题第8周
    60
  • 4
    【python】习题第7周（上）
    90
  • 5
    【python】习题 6-10周（下）
    59
  • 6
    【python】习题 6-10周（中）
    66
  • 7
    Python 入门指南（七）（4）
    49
  • 8
    【python】习题 1-5周（中）
    94
  • 9
    【python】习题 1-5周（上）
    52
  • 10
    Python 入门指南（七）（2）
    61

    • 相关课程

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

    • 相关电子书

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

    • 相关实验场景

    更多
  • 基于Redis实现在线游戏积分排行榜
  • 用Python画圣诞树
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 云原生HTAP数据库，让你的交易和分析一库搞定
  • 快速体验PolarDB开源数据库
  • 手把手教你把IoT传感器数据存储到数据库

    • 推荐镜像

    更多
  • python-release
  • nodejs-release
  • composer
    • 下一篇
    DataWorks售前咨询