FastAPI 学习之路（五十五）操作Redis

之前我们分享了操作关系型数据库，具体文章，
   FastAPI 学习之路（三十二）创建数据库
   FastAPI 学习之路（三十三）操作数据库
    FastAPI 学习之路（三十四）数据库多表操作

     这次我们分享的是非关系型数据库--Redis。
起首，我们需要安装对应的依赖
   pip install aioredis==1.3.1
  接下来，我们去导入创建对应的链接

1. from starlette.requests import Request
2. from fastapi import FastAPI, Query
3. from aioredis import Redis, create_redis_pool
6. app = FastAPI()
9. async def create_redis() -> Redis:
10.     return await create_redis_pool(f"redis://:@10.30.10.36/0?encoding=utf-8")
13. @app.on_event("startup")
14. async def startup_event():
15.     app.state.redis = await create_redis()
16.     print("init redis success")
19. @app.on_event("shutdown")
20. async def shutdown_event():
21.     app.state.redis.close()
22.     await app.state.redis.wait_closed()
23.     print("redis closed")

复制代码

这里我们就用到了上一篇中分享的startup和shutdown事件。接下来，我们去创建一个api操作redis，看是否能够生效：
 

1. @app.get("/test", summary="test redis")
2. async def test_redis(request: Request, num: int = Query(123, title="参数num")):
3.     """
4.     等待redis写入，await异步变同步
5.     如果不关心结果可以不用await，但是这里下一步要取值
6.     必须得先等存完值，然后再取
7.     """
8.     await request.app.state.redis.set("test", num)
9.     # 等待读取
10.     value = await request.app.state.redis.get("test")
11.     print(value, type(value))
12.     return {"value": value}

复制代码

部署后请求接口

然后我们看下redis是否存储乐成

可以看到，redis存储了结果，接口也正常返回了数据。这只是一个简单的demo，后续可以用来缓存，也可以用来存储token。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。