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

浅杰君_7690

浅杰君_7690

2026-10-26

168人浏览

原创

应使用 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:*"))保障一致性。

大量免费API接口:立即使用
涵盖生活服务API、金融科技API、企业工商API、等相关的API接口服务。免费API接口可安全、合规地连接上下游,为数据API应用能力赋能!

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

redis fastapi

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

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

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

2025.12.22

119

5

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

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

2026.02.06

554

18

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

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

2026.05.09

636

23

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

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

2026.06.16

539

12

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

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

2023.11.02

4629

19

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

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

2023.11.14

4195

11

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

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

2024.04.02

7872

6

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

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

2024.04.07

643

6

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

756

6

热门下载

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

精品课程

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

共0课时 | 0人学习