angelina/Mapping_ya_tracker
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: angelina:98c09a6f9cb3f0fe847e8a4bc48dcac516cd6327
Branches Tags
angelina:main
..
compare: angelina:9f7a57e8aaa8f67f2050040d443500fefcfbe7c7
Branches Tags
angelina:main

No commits in common. "98c09a6f9cb3f0fe847e8a4bc48dcac516cd6327" and "9f7a57e8aaa8f67f2050040d443500fefcfbe7c7" have entirely different histories.
98c09a6f9c ... 9f7a57e8aa

2 changed files with 10 additions and 18 deletions
Show Stats Expand all files Collapse all files

15
logging_config.py
View File

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

13
mapping.py
View File

@ -11,17 +11,14 @@ import requests
from logging_config import setup_logging from logging_config import setup_logging
logger = setup_logging(__name__) logger = setup_logging()
base_dir = os.path.dirname(os.path.realpath(__file__)) base_dir = os.path.dirname(os.path.realpath(__file__))
asana_data_json = os.path.join(base_dir, './data/data_asana.json') asana_data_json = os.path.join(base_dir, './data/data_asana.json')
users_data = os.path.join(base_dir, './data/users.mapping.asana2ya.csv') users_data = os.path.join(base_dir, './data/users.mapping.asana2ya.csv')
sys.stdin.reconfigure(encoding='utf-8')
sys.stdout.reconfigure(encoding='utf-8') sys.stdout.reconfigure(encoding='utf-8')
# ниже функция для случаев, когда не будет готового файла для импорта # ниже функция для случаев, когда не будет готового файла для импорта
# def get_data_from_asana(): # def get_data_from_asana():
# """ Получение данных из Asana """ # """ Получение данных из Asana """
@ -92,8 +89,6 @@ def create_tasks_in_tracker(data):
'X-Org-ID': '7095769', 'X-Org-ID': '7095769',
'Content-Type': 'appication/json', 'Content-Type': 'appication/json',
} }
datalen = len(data)
logger.info('Import started. Task count: %d', datalen)
for task in data: for task in data:
if task.get('assignee') and 'gid' in task['assignee']: if task.get('assignee') and 'gid' in task['assignee']:
ya_assignee = assignee.get(task['assignee']['gid'], 'dr.cyrill') ya_assignee = assignee.get(task['assignee']['gid'], 'dr.cyrill')
@ -115,8 +110,7 @@ def create_tasks_in_tracker(data):
# 'completedAt': task['completedAt'] # 'completedAt': task['completedAt']
} }
# logger.debug('Запрос: %s', json.dumps(payload))
logger.debug('Request: %s', json.dumps(payload))
response = requests.post( response = requests.post(
base_url, base_url,
@ -131,8 +125,7 @@ def create_tasks_in_tracker(data):
'Ошибка при создании задачи в ЯндексТрекер:', 'Ошибка при создании задачи в ЯндексТрекер:',
response.content, response.content,
) )
# logger.debug('Ответ: %s', response.content)
logger.debug('Response: %s', response.content)
ya_imported_task_response = response.json() ya_imported_task_response = response.json()
if task.get('parent'): if task.get('parent'):