讲师中心 微信公众号
AI工具推荐 视频效率加速

FastAPI怎么连接Redis并实现数据缓存

浅杰君_7690

浅杰君_7690

发布时间:2026-10-26 07:18:02

|

168人浏览过

|

来源于php中文网

原创

应使用 redis.asyncio.Redis 配合 ConnectionPool.from_url() 初始化异步连接池,开启 decode_responses=True,设置 max_connections=20、socket_connect_timeout=5、socket_timeout=5 和 retry_on_timeout=True,并传入含密码和DB编号的 Redis URL。

fastapi怎么连接redis并实现数据缓存

直接结论:用 redis.asyncio.Redis + ConnectionPool.from_url() 初始化连接池,再通过自定义装饰器拦截请求、构造 key、序列化写入,不依赖 fastapi-cache 更可控,尤其在需要按 query、header、用户身份差异化缓存时。

怎么初始化 Redis 连接池(async)

FastAPI 是异步框架,必须用支持 async 的客户端。redis-py 4.0+ 的 redis.asyncio 模块是官方推荐方案,别再用同步的 redis.Redis 或已弃用的 aioredis v1。

关键点:

  • ConnectionPool.from_url() 是连接工厂,负责复用连接;直接传 URL 比拆解 host/port 更简洁且兼容密码、DB 编号
  • decode_responses=True 必须开启,否则所有 get() 返回 bytes,每次都要手动 .decode("utf-8")
  • max_connections=20 是安全起点,高并发场景下可调到 50–100,但需匹配 Redis maxclients 配置
  • 超时参数不能省:socket_connect_timeout=5 和 socket_timeout=5 防止单个慢请求拖垮整个服务

示例代码片段:

import redis.asyncio as redis

pool = redis.ConnectionPool.from_url(
    "redis://:mypassword@localhost:6379/0",
    max_connections=20,
    decode_responses=True,
    socket_connect_timeout=5,
    socket_timeout=5,
    retry_on_timeout=True,
)

redis_client = redis.Redis(connection_pool=pool)

为什么缓存装饰器要自己写,而不是用 fastapi-cache

第三方封装如 fastapi-cache 在简单场景下开箱即用,但一旦涉及以下需求,就会卡住:

  • key 要包含 Authorization 头哈希值(区分用户级缓存)
  • 同一接口对 Accept: application/msgpack 和 application/json 返回不同序列化格式
  • 需要对 Pydantic v2 的 BaseModel 自动调用 .model_dump() 而非 dict()
  • 缓存未命中时想记录日志或触发指标上报

自己写装饰器核心就三步:生成 key → await redis.get(key) → 命中则反序列化返回,否则执行原函数 + 序列化写入。控制权全在你手上。

缓存 key 怎么构造才不出错

常见错误是 key 只含路径,导致 GET /items?id=100 和 GET /items?id=200 共享同一个缓存,或者不同用户的请求互相污染。

redis-tools
redis-tools

按类别查找Redis命令、检测服务器连接、监控键数量和内存占用,支持离线速查表。

下载

正确做法是组合以下要素并做确定性哈希:

  • request.method(GET/POST 区分)
  • request.url.path(不含 query)
  • tuple(sorted(request.query_params.items()))(避免 str(query_params) 顺序不一致)
  • 可选:对 request.headers.get("authorization") 做 hashlib.sha256().hexdigest(),用于用户隔离
  • 可选:request.headers.get("accept"),适配多格式响应

最终拼接后走 md5(...).hexdigest() 得到固定长度 key,防止超长 key 触发 Redis 的 key too long 警告。

示例片段:

from hashlib import md5

sorted_q = tuple(sorted(request.query_params.items()))
user_hash = hashlib.sha256(request.headers.get("authorization", "").encode()).hexdigest()
key = f"fastapi:{method}:{path}:{md5((str(sorted_q) + user_hash).encode()).hexdigest()}"

序列化返回值要注意什么

FastAPI 路由函数返回的不是纯 dict,可能是 BaseModel、datetime、UUID、甚至 StreamingResponse。直接 json.dumps() 会报错。

安全做法:

  • 统一用 json.dumps(obj, default=str),把不可序列化对象转成字符串(如 datetime.isoformat())
  • Pydantic v2 推荐先调 obj.model_dump() 再 json 序列化,不要 json.dumps(obj)
  • 性能敏感场景可用 msgpack.packb(obj, default=str),体积更小、解析更快,但需客户端支持 msgpack
  • 绝对不要用 pickle.dumps():有反序列化执行任意代码风险,且跨语言/跨 Python 版本不兼容

缓存降级也得考虑:Redis 连接失败时,应捕获 redis.ConnectionError 或 redis.TimeoutError,跳过缓存直接执行原逻辑,避免雪崩。

最易被忽略的是 TTL 设置粒度——全局统一 CACHE_TTL=300 看似省事,但热点新闻和用户配置项的更新频率完全不同。建议按接口路径分级设置,比如 /api/v1/news 用 60 秒,/api/v1/user/profile 用 3600 秒,并配合主动清理(如用户修改资料后 delete_pattern("fastapi:*user:*"))保障一致性。

热门AI工具

更多
WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

超级简历WonderCV

一款AI办公效率工具,主要用于免费求职简历模版下载制作,应届生职场人必备简历制作神器,适合需要提升相关任务效率的用户。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

相关专题

更多
Python FastAPI异步API开发_Python怎么用FastAPI构建异步API
Python FastAPI异步API开发_Python怎么用FastAPI构建异步API

Python FastAPI 异步开发利用 async/await 关键字,通过定义异步视图函数、使用异步数据库库 (如 databases)、异步 HTTP 客户端 (如 httpx),并结合后台任务队列(如 Celery)和异步依赖项,实现高效的 I/O 密集型 API,显著提升吞吐量和响应速度,尤其适用于处理数据库查询、网络请求等耗时操作,无需阻塞主线程。

119

2025.12.22

Python 微服务架构与 FastAPI 框架
Python 微服务架构与 FastAPI 框架

本专题系统讲解 Python 微服务架构设计与 FastAPI 框架应用,涵盖 FastAPI 的快速开发、路由与依赖注入、数据模型验证、API 文档自动生成、OAuth2 与 JWT 身份验证、异步支持、部署与扩展等。通过实际案例,帮助学习者掌握 使用 FastAPI 构建高效、可扩展的微服务应用,提高服务响应速度与系统可维护性。

554

2026.02.06

Python Web框架FastAPI 全栈开发教程合集
Python Web框架FastAPI 全栈开发教程合集

以 FastAPI 为核心,讲解现代 Python Web API 的高效开发方式,涵盖路由定义与路径参数/查询参数/请求体绑定、Pydantic 模型的数据校验与序列化、依赖注入(Depends)系统的分层设计、中间件与 CORS 配置、OAuth2 + JWT 认证流程、后台任务(BackgroundTasks)、WebSocket 实时通信、SQLAlchemy 异步 ORM 集成、自动生成 OpenAPI/Swagger 交互文

636

2026.05.09

Python FastAPI异步微服务与高性能接口设计
Python FastAPI异步微服务与高性能接口设计

本专题聚焦 Python FastAPI 框架在高性能接口与微服务开发中的应用,讲解异步请求处理、依赖注入机制、路由设计、数据库异步操作以及接口性能优化策略。结合实际项目案例,帮助开发者构建高并发、低延迟的现代化后端服务架构。

539

2026.06.16

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4629

2023.11.02

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4195

2023.11.14

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

7892

2024.04.02

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

643

2024.04.07

Gradle插件开发入门教程
Gradle插件开发入门教程

本专题介绍Gradle插件开发的基本流程,涵盖插件类编写、自定义任务注册、扩展参数设计和插件应用方法,帮助你理解插件如何组织构建逻辑,减少多个项目之间的重复配置。

60

2026.10.22

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn