### FastAPI 连接 Redis 示例教程 #### 使用 `Depends` 注入 Redis 连接 为了在 FastAPI 应用程序中连接到 Redis，可以利用依赖注入机制来管理 Redis 的生命周期。下面展示了如何定义一个异步的依赖项来获取 Redis 连接： ```python from fastapi import FastAPI, Depends import aioredis app = FastAPI() async def get_redis(): """创建并提供 Redis 客户端实例""" redis = await aioredis.create_redis_pool('redis://localhost') try: yield redis finally: redis.close() await redis.wait_closed() ``` 此代码片段中的 `get_redis()` 函数会在每次请求时被调用来建立新的 Redis 连接池，并确保当请求结束时关闭这些资源[^2]。 #### 初始化 Redis 连接于应用启动阶段 为了让应用程序能够在启动之初就准备好所需的外部服务连接，在 FastAPI 提供了事件钩子功能。可以通过监听 `"startup"` 事件来进行必要的初始化工作，比如验证 Redis 是否可用： ```python @app.on_event("startup") async def startup_event(): """执行应用启动前的任务""" global _global_redis_conn # 建立全局共享的 Redis 链接 _global_redis_conn = await aioredis.create_redis_pool( 'redis://localhost', encoding='utf8' ) # 测试链接有效性 pong = await _global_redis_conn.ping() if not pong: raise Exception("Failed to connect to Redis server.") print(f"Connected successfully! PING response was {pong}") ``` 这段脚本不仅实现了对 Redis 的初步配置，还加入了简单的健康检查逻辑以确认连接状态良好[^1]。 #### 结合中间件实现自动化的缓存控制 除了手动编写业务逻辑外，还可以借助第三方库简化开发流程。例如，`fastapi-redis-cache` 就是这样一个专为优化 API 性能设计的工具包。安装之后只需几行额外设置就能让指定路由具备高效的响应式缓存特性[^3]: ```python from fastapi_cache.decorator import cache from fastapi_cache.backends.redis import RedisBackend # 设置默认使用的后端存储引擎 backend = RedisBackend(_global_redis_conn) @cache(expire=60*5, backend=backend) @app.get("/cached-data/") def read_cached_data(): return {"message": "This data is cached!"} ``` 上述例子说明了怎样快速启用基于时间过期策略的数据缓存方案，使得频繁访问相同 URL 路径下的内容变得更加迅速流畅。