mirror of
https://github.com/long2ice/fastapi-cache.git
synced 2026-03-25 13:07:53 +00:00
23 lines
572 B
Python
23 lines
572 B
Python
|
from typing import Tuple
|
||
|
|
|
||
|
|
from aioredis import Redis
|
||
|
|
|
||
|
|
from fastapi_cache.backends import Backend
|
||
|
|
|
||
|
|
|
||
|
|
class RedisBackend(Backend):
|
||
|
|
def __init__(self, redis: Redis):
|
||
|
|
self.redis = redis
|
||
|
|
|
||
|
|
async def get_with_ttl(self, key: str) -> Tuple[int, str]:
|
||
|
|
p = self.redis.pipeline()
|
||
|
|
p.ttl(key)
|
||
|
|
p.get(key)
|
||
|
|
return await p.execute()
|
||
|
|
|
||
|
|
async def get(self, key) -> str:
|
||
|
|
return await self.redis.get(key)
|
||
|
|
|
||
|
|
async def set(self, key: str, value: str, expire: int = None):
|
||
|
|
return await self.redis.set(key, value, expire=expire)
|