get_cached_topic_followers-fix

cache/cache.py

@@ -139,27 +139,40 @@ async def get_cached_authors_by_ids(author_ids: List[int]) -> List[dict]:
     return authors
 
 
-# Get cached topic followers
 async def get_cached_topic_followers(topic_id: int):
-    # Attempt to retrieve cached data
+    """
-    cached = await redis.execute("get", f"topic:followers:{topic_id}")
+    Получает подписчиков темы по ID, используя кеш Redis.
-    if cached:
+    Если данные отсутствуют в кеше, извлекает из базы данных и кеширует их.
-        followers = json.loads(cached)
-        logger.debug(f"Cached followers for topic#{topic_id}: {len(followers)}")
-        return followers
 
-    # Load from database and cache results
+    :param topic_id: Идентификатор темы, подписчиков которой необходимо получить.
-    with local_session() as session:
+    :return: Список подписчиков темы, каждый элемент представляет собой словарь с ID и именем автора.
-        followers_ids = [
+    """
-            f[0]
+    try:
-            for f in session.query(Author.id)
+        # Попытка получить данные из кеша
-            .join(TopicFollower, TopicFollower.follower == Author.id)
+        cached = await redis.get(f"topic:followers:{topic_id}")
-            .filter(TopicFollower.topic == topic_id)
+        if cached:
-            .all()
+            followers = json.loads(cached)
-        ]
+            logger.debug(f"Cached followers for topic#{topic_id}: {len(followers)}")
-        await redis.execute("SET", f"topic:followers:{topic_id}", json.dumps(followers_ids))
+            return followers
-        followers = await get_cached_authors_by_ids(followers_ids)
+
-        return followers
+        # Если данные не найдены в кеше, загрузка из базы данных
+        async with local_session() as session:
+            result = await session.execute(
+                session.query(Author.id)
+                .join(TopicFollower, TopicFollower.follower == Author.id)
+                .filter(TopicFollower.topic == topic_id)
+            )
+            followers_ids = [f[0] for f in result.scalars().all()]
+
+            # Кеширование результатов
+            await redis.set(f"topic:followers:{topic_id}", json.dumps(followers_ids))
+
+            # Получение подробной информации о подписчиках по их ID
+            followers = await get_cached_authors_by_ids(followers_ids)
+            return followers
+    except Exception as e:
+        logger.error(f"Ошибка при получении подписчиков для темы#{topic_id}: {str(e)}")
+        return []
 
 
 # Get cached author followers