diff --git a/logging_config.py b/logging_config.py index cbb1e3d..5b693c3 100644 --- a/logging_config.py +++ b/logging_config.py @@ -2,29 +2,30 @@ import logging import logging.handlers -def setup_logging(): +def setup_logging(name): """ Создание логгера """ logger = logging.getLogger() logger.setLevel(logging.DEBUG) """ Создание обработчика для записи логов в файл """ - file_handler = logging.handlers.RotatingFileHandler( - filename='mapping.log', - maxBytes=1024*1024, - backupCount=5 + file_handler = logging.FileHandler( + filename=f"{name}.log", + mode='w' + #maxBytes=1024*1024, + #backupCount=5 ) file_handler.setLevel(logging.DEBUG) """ Создание обработчика для вывода логов на консоль """ console_handler = logging.StreamHandler() - console_handler.setLevel(logging.DEBUG) + console_handler.setLevel(logging.INFO) """ Форматтер для вывода в файл """ file_formatter = logging.Formatter( - '%(asctime)s [%(levelname)s] [%(name)s] [%(request)s] [%(response)s] - %(message)s' + '%(asctime)s [%(levelname)s] [%(name)s] - %(message)s' ) """ Форматтер для вывода на консоль """ diff --git a/mapping.py b/mapping.py index a3068dc..eb768ff 100644 --- a/mapping.py +++ b/mapping.py @@ -11,14 +11,17 @@ import requests from logging_config import setup_logging -logger = setup_logging() +logger = setup_logging(__name__) base_dir = os.path.dirname(os.path.realpath(__file__)) asana_data_json = os.path.join(base_dir, './data/data_asana.json') users_data = os.path.join(base_dir, './data/users.mapping.asana2ya.csv') +sys.stdin.reconfigure(encoding='utf-8') sys.stdout.reconfigure(encoding='utf-8') + + # ниже функция для случаев, когда не будет готового файла для импорта # def get_data_from_asana(): # """ Получение данных из Asana """ @@ -88,6 +91,8 @@ def create_tasks_in_tracker(data): 'X-Org-ID': '7095769', 'Content-Type': 'appication/json', } + datalen = len(data) + logger.info('Import started. Task count: %d', datalen) for task in data: if task.get('assignee') and 'gid' in task['assignee']: ya_assignee = assignee.get(task['assignee']['gid'], 'dr.cyrill') @@ -109,7 +114,7 @@ def create_tasks_in_tracker(data): # 'completedAt': task['completedAt'] } - logger.debug('Запрос: %s', json.dumps(payload)) + logger.debug('Request: %s', json.dumps(payload)) response = requests.post( base_url, @@ -124,7 +129,7 @@ def create_tasks_in_tracker(data): 'Ошибка при создании задачи в ЯндексТрекер:', response.content, ) - logger.debug('Ответ: %s', response.content) + logger.debug('Response: %s', response.content) # asana_data = get_data_from_asana() file = open(asana_data_json, "r", encoding="utf8")