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

logs-fix

Browse Source
This commit is contained in:
Untone 2024-01-28 12:03:41 +03:00
parent 08845152d1
commit 38645d063a
1 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
services/viewed.py
View File

@ -51,7 +51,7 @@ class ViewedStorage:
"""Подключение к клиенту Google Analytics с использованием аутентификации""" """Подключение к клиенту Google Analytics с использованием аутентификации"""
self = ViewedStorage self = ViewedStorage
async with self.lock: async with self.lock:
if os.path.exists(GOOGLE_KEYFILE_PATH): if os.path.exists(GOOGLE_KEYFILE_PATH) and GOOGLE_GA_VIEW_ID:
self.analytics_client = get_service() self.analytics_client = get_service()
logger.info(f' * Постоянная авторизация в Google Analytics {self.analytics_client}') logger.info(f' * Постоянная авторизация в Google Analytics {self.analytics_client}')
@ -68,7 +68,7 @@ class ViewedStorage:
_views_stat_task = asyncio.create_task(self.worker()) _views_stat_task = asyncio.create_task(self.worker())
# logger.info(views_stat_task) # logger.info(views_stat_task)
else: else:
logger.info(' * Пожалуйста, добавьте ключевой файл Google Analytics') logger.info(' * Пожалуйста, добавьте ключевой файл Google Analytics  и задайте ')
self.disabled = True self.disabled = True
@staticmethod @staticmethod
@ -80,7 +80,7 @@ class ViewedStorage:
precounted_views = json.load(file) precounted_views = json.load(file)
self.views_by_shout.update(precounted_views) self.views_by_shout.update(precounted_views)
logger.info( logger.info(
f' * {len(precounted_views)} предварительно подсчитанных просмотров shouts успешно загружены.' f' * {len(precounted_views)} публикаций с просмотрами успешно загружены.'
) )
except Exception as e: except Exception as e:
logger.error(f'Ошибка загрузки предварительно подсчитанных просмотров: {e}') logger.error(f'Ошибка загрузки предварительно подсчитанных просмотров: {e}')
@ -89,8 +89,8 @@ class ViewedStorage:
async def update_pages(): async def update_pages():
"""Запрос всех страниц от Google Analytics, отсортированных по количеству просмотров""" """Запрос всех страниц от Google Analytics, отсортированных по количеству просмотров"""
self = ViewedStorage self = ViewedStorage
if not self.disabled and bool(GOOGLE_GA_VIEW_ID): logger.info(' ⎧ Обновление данных просмотров от Google Analytics ---')
logger.info(' ⎧ Обновление данных просмотров от Google Analytics ---') if not self.disabled:
try: try:
start = time.time() start = time.time()
async with self.lock: async with self.lock:
@ -137,11 +137,8 @@ class ViewedStorage:
end = time.time() end = time.time()
logger.info(' ⎪ Обновление страниц заняло %fs ' % (end - start)) logger.info(' ⎪ Обновление страниц заняло %fs ' % (end - start))
except Exception as error:
except Exception: logger.error(error)
import traceback
traceback.print_exc()
@staticmethod @staticmethod
async def get_shout(shout_slug) -> int: async def get_shout(shout_slug) -> int: