logging_config.py

@@ -2,30 +2,29 @@ import logging
 import logging.handlers
 
 
-def setup_logging(name):
+def setup_logging():
     """ Создание логгера """
     logger = logging.getLogger()
     logger.setLevel(logging.DEBUG)
 
     """ Создание обработчика для записи логов в файл """
 
-    file_handler = logging.FileHandler(
-        filename=f"{name}.log",
-        mode='w'
-        #maxBytes=1024*1024,
-        #backupCount=5
+    file_handler = logging.handlers.RotatingFileHandler(
+        filename='mapping.log',
+        maxBytes=1024*1024,
+        backupCount=5
     )
     file_handler.setLevel(logging.DEBUG)
 
     """ Создание обработчика для вывода логов на консоль """
 
     console_handler = logging.StreamHandler()
-    console_handler.setLevel(logging.INFO)
+    console_handler.setLevel(logging.DEBUG)
 
     """ Форматтер для вывода в файл """
 
     file_formatter = logging.Formatter(
-        '%(asctime)s [%(levelname)s] [%(name)s] - %(message)s'
+        '%(asctime)s [%(levelname)s] [%(name)s] [%(request)s] [%(response)s] - %(message)s'
     )
 
     """ Форматтер для вывода на консоль """

mapping.py

@@ -11,17 +11,14 @@ import requests
 
 from logging_config import setup_logging
 
-logger = setup_logging(__name__)
+logger = setup_logging()
 
 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 """
@@ -92,8 +89,6 @@ 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')
@@ -115,8 +110,7 @@ def create_tasks_in_tracker(data):
             # 'completedAt': task['completedAt']
         }
 
-
-        logger.debug('Request: %s', json.dumps(payload))
+        # logger.debug('Запрос: %s', json.dumps(payload))
 
         response = requests.post(
             base_url,
@@ -131,8 +125,7 @@ def create_tasks_in_tracker(data):
                 'Ошибка при создании задачи в ЯндексТрекер:',
                 response.content,
             )
-
-        logger.debug('Response: %s', response.content)
+        # logger.debug('Ответ: %s', response.content)
 
         ya_imported_task_response = response.json()
         if task.get('parent'):