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

debug:get_cached_topic_followers
Some checks failed
Deploy on push / deploy (push) Failing after 10s
Details

Browse Source
This commit is contained in:
Untone 2024-08-09 07:14:33 +03:00
parent 4a7b305ad4
commit 1c9f6f30d9
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cache/cache.py vendored
View File

@ -155,6 +155,7 @@ async def get_cached_topic_followers(topic_id: int):
logger.debug(f"Cached followers for topic#{topic_id}: {len(followers)}") logger.debug(f"Cached followers for topic#{topic_id}: {len(followers)}")
return followers return followers
logger.debug("[get_cached_topic_followers] >>>>>>>>>>> ")
# Если данные не найдены в кеше, загрузка из базы данных # Если данные не найдены в кеше, загрузка из базы данных
async with local_session() as session: async with local_session() as session:
result = await session.execute( result = await session.execute(
@ -163,12 +164,14 @@ async def get_cached_topic_followers(topic_id: int):
.filter(TopicFollower.topic == topic_id) .filter(TopicFollower.topic == topic_id)
) )
followers_ids = [f[0] for f in result.scalars().all()] followers_ids = [f[0] for f in result.scalars().all()]
logger.debug(followers_ids)
# Кеширование результатов # Кеширование результатов
await redis.set(f"topic:followers:{topic_id}", json.dumps(followers_ids)) await redis.set(f"topic:followers:{topic_id}", json.dumps(followers_ids))
# Получение подробной информации о подписчиках по их ID # Получение подробной информации о подписчиках по их ID
followers = await get_cached_authors_by_ids(followers_ids) followers = await get_cached_authors_by_ids(followers_ids)
logger.debug(followers)
return followers return followers
except Exception as e: except Exception as e:
logger.error(f"Ошибка при получении подписчиков для темы#{topic_id}: {str(e)}") logger.error(f"Ошибка при получении подписчиков для темы#{topic_id}: {str(e)}")