From 68d0142bd7e0316598cbcf9707858b46bd2cc888 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=94=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= Date: Wed, 22 Jun 2022 23:30:33 +0300 Subject: [PATCH] =?UTF-8?q?=D0=A0=D0=B5=D1=84=D0=B0=D0=BA=D1=82=D0=BE?= =?UTF-8?q?=D1=80=D0=B8=D0=BD=D0=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Убрал ненужные импорты --- config_object.py | 6 +++++- request_builder.py | 7 ++++--- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/config_object.py b/config_object.py index 87f40ab..f8f68c8 100644 --- a/config_object.py +++ b/config_object.py @@ -1,10 +1,12 @@ """Модуль с объектами для работы с конфигами nginx""" -import asyncio import os + import aiofiles class ConfigObject: + """Объект для хранения настроек для хоста.""" + def __init__(self, host: str, conf_body: str, path: str): self.host = host self.conf_body = conf_body.replace( @@ -35,6 +37,8 @@ class ConfigObject: class ConfigFactory: + """Фабрика, чтобы проще было строить однотипные объекты.""" + def __init__(self, path_to_template: str, path_to_configs_dir: str): self.templ = self.__read_config_template_file(path_to_template) self.path = path_to_configs_dir diff --git a/request_builder.py b/request_builder.py index 6651ad0..93f40c0 100644 --- a/request_builder.py +++ b/request_builder.py @@ -1,6 +1,5 @@ """Модуль для конструирования и обработки запросов.""" import asyncio -from typing import Dict, List, NewType import aiohttp from aiohttp import ClientResponse @@ -9,6 +8,7 @@ from loguru import logger from app_config import AppConfig + class RequestBulder: """Конструктор запросов. @@ -22,9 +22,10 @@ class RequestBulder: send_request(url: str, json_body: dict) Асинхронный метод для отправки запроса. Может принимать пустой json_body. """ + def __init__(self, cfg: AppConfig) -> None: """Инициализация. Объект сесси `aiohttp.ClientSession` - создается здесь. """ + создается здесь.""" self.cfg = cfg _conn = aiohttp.TCPConnector(limit=cfg.requests_count) self.session = aiohttp.ClientSession(connector=_conn) @@ -75,7 +76,7 @@ class RequestBulder: await asyncio.sleep(self.cfg.frequency_sec) except ServerDisconnectedError: logger.error(f"Сервер отклонил подключение {_url}") - return dict() + return {} async def wait(self) -> None: """Ждет frequency_sec время."""