This commit is contained in:
parent
23514ca5a4
commit
8de91a8232
14
cache/precache.py
vendored
14
cache/precache.py
vendored
|
@ -80,13 +80,19 @@ async def precache_data():
|
||||||
try:
|
try:
|
||||||
key = "authorizer_env"
|
key = "authorizer_env"
|
||||||
# cache reset
|
# cache reset
|
||||||
value = await redis.execute("HGET", key)
|
value = await redis.execute("HGETALL", key)
|
||||||
await redis.execute("FLUSHDB")
|
await redis.execute("FLUSHDB")
|
||||||
logger.info("redis: FLUSHDB")
|
logger.info("redis: FLUSHDB")
|
||||||
if value is not None:
|
|
||||||
await redis.execute("HSET", key, value)
|
|
||||||
logger.info(f"redis hash '{key}' was successfully restored")
|
|
||||||
|
|
||||||
|
# Преобразуем словарь в список аргументов для HSET
|
||||||
|
if value:
|
||||||
|
flattened = []
|
||||||
|
for field, val in value.items():
|
||||||
|
flattened.extend([field, val])
|
||||||
|
|
||||||
|
await redis.execute("HSET", key, *flattened)
|
||||||
|
logger.info(f"redis hash '{key}' was restored")
|
||||||
|
|
||||||
with local_session() as session:
|
with local_session() as session:
|
||||||
# topics
|
# topics
|
||||||
q = select(Topic).where(Topic.community == 1)
|
q = select(Topic).where(Topic.community == 1)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user