discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

redis cached

Browse Source
This commit is contained in:
tonyrewin 2022-11-17 22:53:58 +03:00
parent f764577136
commit 9cfad11df2
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
services/search.py
View File

@ -1,5 +1,6 @@
import asyncio import asyncio
import json
from base.redis import redis
from orm.shout import Shout from orm.shout import Shout
from resolvers.zine import load_shouts_by from resolvers.zine import load_shouts_by
@ -16,9 +17,15 @@ class SearchService:
@staticmethod @staticmethod
async def search(text, limit, offset) -> [Shout]: async def search(text, limit, offset) -> [Shout]:
cached = redis.execute("GET", text)
if not cached:
async with SearchService.lock: async with SearchService.lock:
by = { by = {
"title": text, "title": text,
"body": text "body": text
} }
return await load_shouts_by(None, None, by, limit, offset) payload = await load_shouts_by(None, None, by, limit, offset)
redis.execute("SET", text, json.dumps(payload))
return payload
else:
return json.loads(cached)