如何通过 Python 连接 Redis 数据库

已编辑 6 几天前 通过 ExtremeHow 编辑团队

RedisPython数据库开发连接编程应用程序接口设置集成服务器

Redis 是一种开源的内存数据结构存储。它主要用作数据库、缓存和消息代理。其主要特点包括支持多种数据结构，如字符串、哈希、列表、集合等。由于其多平台兼容性，Redis 已成为开发人员在执行高性能任务时的首选。让我们学习如何一步步将 Python 应用程序连接到 Redis 数据库，确保对初学者的简单性，并提供足够的基础使您对其有深刻的理解。

Redis 简介

Redis 代表远程字典服务器。最初由 Salvatore Sanfilippo 开发，Redis 不断发展，为数据操作提供了一个独特的平台。使用 Redis 的主要优点之一是它可以将数据存储在内存中，而不是依赖磁盘存储，从而提高读写操作的速度。

要有效使用 Redis，通常需要运行一个 Redis 服务器来存储数据，并通过客户端与其交互。客户端向 Redis 服务器发送命令，服务器处理这些命令并发送回响应。

设置 Redis

在将 Python 连接到 Redis 之前，您必须安装 Redis。安装可能因操作系统而异。在基于 Unix 的系统中，您通常可以使用软件包管理器，例如 Ubuntu 上的 apt-get 或 macOS 上的 brew。对于 Windows，您可以选择使用 Docker 容器或 Windows Subsystem for Linux (WSL)。在官方 Redis 网站上提供了详细的 Redis 安装指南。

Python 和 Redis：redis-py 库

Python 是一种多功能的编程语言，可以使用流行的 redis-py 库连接到 Redis。该库提供强大的方法和操作，使您可以直接从 Python 与 Redis 进行交互。要使用它，您首先需要安装 redis-py，这可以通过 Python 的包管理器 pip 轻松完成。

pip install redis

安装完成后，下一步是开始从 Python 脚本或应用程序连接到 Redis。

将 Python 连接到 Redis

在本地或远程设置 Redis 服务器并安装 redis-py 后，就可以建立连接。以下是使用 Python 连接到 Redis 数据库的简单指南：

1. 首先，将 Redis 库导入到您的 Python 脚本中。

import redis

2. 接下来，创建与 Redis 服务器的连接。Redis 库为您提供了 StrictRedis 类，用于建立连接。

# 启动与本地运行的 Redis 服务器的连接
r = redis.StrictRedis(host='localhost', port=6379, db=0)

在此示例中，host 是服务器的 IP 地址（或域名），port 是 Redis 正在监听的端口号，db 是数据库索引。默认的 Redis 配置使用数据库 0，但 Redis 支持从 0 开始的多个数据库。

3. 或者，如果您的应用程序将创建许多 Redis 连接，可以使用连接池。连接池对于更好的效率和 Redis 连接管理是有益的。

# 利用连接池
pool = redis.ConnectionPool(host='localhost', port=6379, db=0)
r = redis.StrictRedis(connection_pool=pool)

使用连接池允许您的应用程序更有效地处理多个 Redis 连接，因为您的应用程序的每个实例都可以重用活动连接。

4. 最后，验证连接。可以通过使用已建立的连接发送一个简单的 ping 命令来实现。

# ping Redis 服务器
response = r.ping()
print("Connected!" if response else "Connection failed.")

这个小测试将在成功连接时返回 True，确认您的 Python 脚本现已与 Redis 服务器交互。

使用 Redis 数据类型

Redis 支持许多数据类型，如字符串、列表、哈希、集合和有序集合。让我们看看如何直接从 Python 使用这些数据类型。

字符串

字符串是 Redis 中最简单的数据类型，通常表示键值对。您可以使用 Python Redis 连接来设置和获取字符串值。

# 在 Redis 中设置字符串
r.set('name', 'PythonCoder')
# 从 Redis 获取字符串
name = r.get('name')
print(name.decode('utf-8'))

在这里，`set` 将值 `PythonCoder'` 分配给键 `name'`，而 `get` 命令则获取它。

列表

Redis 列表维护有序元素集合。您可以使用诸如 `lpush` 和 `rpop` 之类的命令来添加和检索列表中的元素。

# 创建 Redis 列表
r.lpush('programming_languages', 'Python')
r.lpush('programming_languages', 'Java')
r.lpush('programming_languages', 'JavaScript')
# 检索列表中的元素
print(r.rpop('programming_languages').decode('utf-8'))

哈希

哈希是字符串字段与字符串值之间的映射，适合表示对象。

# 设置哈希字段
r.hset('user:1000', 'username', 'PCode')
r.hset('user:1000', 'password', 'pass123')
# 获取哈希字段
username = r.hget('user:1000', 'username')
print(username.decode('utf-8'))

集合

Redis 集合是唯一字符串的集合。当您需要确保没有重复时，它们很有用。

# 添加到 Redis 集合
r.sadd('countries', 'USA')
r.sadd('countries', 'Canada')
r.sadd('countries', 'Mexico')
# 检索所有集合成员
countries = r.smembers('countries')
print([country.decode('utf-8') for country in countries])

有序集合

类似于集合，但具有定义顺序的唯一分数参数。

# 添加元素到有序集合
r.zadd('rankings', {'Python': 1, 'JavaScript': 3, 'Java': 2})
# 检索有序集合成员
rankings = r.zrange('rankings', 0, -1)
print([rank.decode('utf-8') for rank in rankings])

实现错误处理

在涉及网络连接或外部数据库的任何任务中，错误处理都是必不可少的。Redis-py 会引发异常，可以捕获并适当地处理这些异常。

try:
    r.set('key', 'value')
except redis.ConnectionError:
    print("Failed to connect to Redis.")
except Exception as e:
    print(f"An error occurred: {str(e)}")

结论

通过 Python 连接到 Redis 并利用 redis-py 库为数据管理提供了强大的功能。借助 Redis 的速度和 Python 的灵活性，您可以针对您的需求构建强大的应用程序。本指南涵盖了设置环境、安装所需软件包以及通过各个示例与 Redis 交互。探索 Python 和 Redis 的全部潜力，提升您的应用程序的性能和可靠性。

  分享本文

如果你发现文章内容有误, 您可以 请求更新