multithread
This commit is contained in:
@@ -2,6 +2,8 @@
|
|||||||
|
|
||||||
# <IMPORTS>
|
# <IMPORTS>
|
||||||
import logging
|
import logging
|
||||||
|
import os
|
||||||
|
from pathlib import Path
|
||||||
from typing import Optional
|
from typing import Optional
|
||||||
from .database import DatabaseLogHandler, DatabaseManager
|
from .database import DatabaseLogHandler, DatabaseManager
|
||||||
from .settings import settings
|
from .settings import settings
|
||||||
@@ -23,8 +25,25 @@ def setup_logging(run_id: str, db_manager: Optional[DatabaseManager] = None):
|
|||||||
"""Настраивает систему логирования проекта."""
|
"""Настраивает систему логирования проекта."""
|
||||||
# <CORE_LOGIC>
|
# <CORE_LOGIC>
|
||||||
log_format = '[%(asctime)s] [%(levelname)s] :: %(message)s'
|
log_format = '[%(asctime)s] [%(levelname)s] :: %(message)s'
|
||||||
|
|
||||||
|
# <ACTION name="create_log_directory">
|
||||||
|
# Создаем директорию для логов, если она не существует.
|
||||||
|
os.makedirs(settings.log_dir, exist_ok=True)
|
||||||
|
# </ACTION>
|
||||||
|
|
||||||
|
# <ACTION name="configure_file_handler">
|
||||||
|
# Добавляем обработчик для записи логов в файл.
|
||||||
|
log_file_name = f"run_{run_id}.log"
|
||||||
|
file_handler = logging.FileHandler(settings.log_dir / log_file_name)
|
||||||
|
file_handler.setLevel(logging.INFO)
|
||||||
|
file_handler.setFormatter(logging.Formatter(log_format))
|
||||||
|
|
||||||
|
root_logger = logging.getLogger('')
|
||||||
|
root_logger.addHandler(file_handler)
|
||||||
|
# </ACTION>
|
||||||
|
|
||||||
logging.basicConfig(
|
logging.basicConfig(
|
||||||
level=logging.INFO,
|
level=logging.DEBUG,
|
||||||
format=log_format,
|
format=log_format,
|
||||||
datefmt='%Y-%m-%d %H:%M:%S',
|
datefmt='%Y-%m-%d %H:%M:%S',
|
||||||
force=True # Перезаписывает любую существующую конфигурацию
|
force=True # Перезаписывает любую существующую конфигурацию
|
||||||
|
|||||||
Reference in New Issue
Block a user