How to make friends with a continuously performing network monitoring function and a Telegram bot on aiogram?

Question

Python

Hello good people. Save my head.
We have a function to monitor the Internet connection:

import asyncio
import datetime
import logging
import socket


def send_ping_request(host="google.com", port=443, timeout=3):
    try:
        socket.setdefaulttimeout(timeout)
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.connect((host, port))
    except OSError as error:
        return False
    else:
        s.close()
        return True


def calculate_time(start, stop):
    time_difference = stop - start
    seconds = float(str(time_difference.total_seconds()))
    return str(datetime.timedelta(seconds=seconds)).split(".")[0]


logger = logging.getLogger("Testy")  # Создаем логгер
fileHandler = logging.FileHandler('logs.log')  # создаем хэндлер и формат для записи в файл
# fileFormat = logging.Formatter("[%(asctime)s]  %(message)s")
fileHandler.setLevel(logging.WARNING)  # устанавливаем уровень хэндлера и добавляем к логгеру
# fileHandler.setFormatter(fileFormat)
logger.addHandler(fileHandler)


async def mon_net_connection(ping_freq=2):  # поставить 20>
    await asyncio.sleep(1)
    motd = f"{str(datetime.datetime.now()).split('.')[0]} - Мониторинг сетевого подключения начат. \n" \
           f" Отправка запроса ping каждые {ping_freq} секунды "
    logger.warning(motd)
    print(motd)
    while True:
        if send_ping_request():
            await asyncio.sleep(ping_freq)
        else:
            down_time = datetime.datetime.now()
            fail_msg = f"{str(down_time).split('.')[0]} False - Сетевое соединение недоступно"
            print(fail_msg)
            logger.warning(fail_msg)
            await asyncio.sleep(1)

            while not send_ping_request():
                await asyncio.sleep(1)  # ждать секунду
            up_time = datetime.datetime.now()
            uptime_message = f"{str(up_time).split('.')[0]} - Сетевое подключение восстановлено"
            down_time = calculate_time(down_time, up_time)
            _m = f"Были вне сети: {down_time} "
            print(uptime_message)
            print(_m)
            logger.warning(uptime_message)
            logger.warning(_m)
            await asyncio.sleep(1)

asyncio.run(mon_net_connection())

And the standard telegram bot on aiogram:

from aiogram import executor
from loader import dp

from utils.notify_admins import on_startup_notify
from utils.set_bot_commands import set_default_commands
import handlers


async def on_startup(dispatcher):
    await set_default_commands(dispatcher)  # Устанавливаем дефолтные команды
    await on_startup_notify(dispatcher)  # Уведомляет админов про запуск

if __name__ == '__main__':
    executor.start_polling(dp, on_startup=on_startup)

How to run them, so that both monitoring and the bot with its handlers, etc. earned together and fun?

Answer 1

First, asyncio is about running coroutines in an infinite event loop. If another infinite loop is run in one of the coroutines, it will block it and break the asynchrony. Therefore, while Trueyou need to remove and entrust checks once a second to the event loop. Secondly, blocking should be avoided as much as possible in an asynchronous program, so a blocking send_ping_request should be rewritten with asynchronous socket facilities provided by asyncio.