Блокируется бот во время выполнения функции, как исправить?

Question

[theurus]

Есть бот на aiogram который умеет выполнять несколько разных функций по командам.

Пока выполняется одна команда для одного юзера, для всех остальных бот не отвечает. Как сделать работу без таких блокировок? Сами функции независимые, и могут выполнятся параллельно.

from aiogram import Bot, Dispatcher, types, executor
import cfg

bot = Bot(token=cfg.token)
dp = Dispatcher(bot)

@dp.message_handler(commands=['cmd1',])
async def send_welcome(message: types.Message):
    a=0.0
    for _ in range(500000000):
        a += 0.01
    result = f'f1 done\n\n{a}'
    await message.reply(result)

@dp.message_handler(commands=['cmd2',])
async def send_welcome(message: types.Message):
    a=0.0
    for _ in range(5000):
        a += 0.1
    result = f'f2 done\n\n{a}'
    await message.reply(result)

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

Comments

[Модератор]

Не надо ставить как можно больше тэгов. Лучше оставить один, но конкретный, с которым проблема.
См.п.3.1 Регламента. Также обратите внимание на п.3.6

[RimMirK]

commands=['cmd2',]

лист и без "," лист, это не тюпл

>>> [1]
[1]
>>> [1,]
[1]
>>> (1)
1
>>> (1,)
(1,)

[RimMirK]

Justa Gain, согласен, но как-то больно смотреть на["menu",]

[RimMirK]

Justa Gain, в многострочных да, всегда в конце запятую ставлю

Answer 1

[Александр Нестеров]

Сами функции независимые, и могут выполнятся параллельно.

С чего это вдруг? Они не асинхронные и запущенны не в отдельном потоке.

как исправить

Если функции ваши - перепишите асинхронно.
Если из библиотеки - запускайте асинхронно с помощью asyncio.

Comments

[theurus]

могут выполнятся параллельно - никак не взаимодействуют друг с другом и не имеют общих ресурсов

можно мне их как то по простому запускать не изучая asyncio?

просто запустить как asyncio.run(func(arg)) или как?

[Александр Нестеров]

theurus,

можно мне их как то по простому запускать не изучая asyncio?

Можно, через run_in_executor.
Но скажу сразу: Без понимания принципов асинхронного программирования в целом, и asyncio в частности (про хорошее понимание python я вообще молчу), писать бота, используя асинхронную библиотеку - затея безнадежная. С большой долей вероятности вы будете сталкиваться с подобными ситуациями постоянно.

[theurus]

Александр Нестеров, вариант от bing ai вроде работает как надо

import cfg
import telebot
import threading
import time
import random

bot = telebot.TeleBot(cfg.token)

@bot.message_handler(commands=["cmd1"])
def task(message):
    bot.send_message(message.chat.id, "Хорошо, я начинаю выполнять задание.")
    thread = threading.Thread(target=do_task, args=(message.chat.id,))
    thread.start()

def do_task(chat_id):
    t = random.randint(1,5)
    time.sleep(t)
    bot.send_message(chat_id, f"Я закончил задание за {t} секунд.")

bot.polling()

[theurus]

Justagain, в вопросе у меня был тег питон но бот-модератор решил что он тут лишний. мне все равно какая библиотека, telebot с тредами справляется не хуже

[theurus]

Justagain, вопрос по aiogram остался открытым. никто не показал как это сделать на нём

[theurus]

Justagain, тебе трудно показать несколько строк? посмотри на то что показал bing ai

[theurus]

Justagain, да, мне трудно прочитать документацию к асинкио и аиограму. это занимает много времени и ничего мне не даёт. но я попытался вчера
бот на telebot уже работает. никаких дополнительных вопросов к нему у меня нет

[theurus]

Justagain, возвращаемся к вопросу трудно ли тебе несколько строк на знакомую тему показать. мне например не трудно

[theurus]

Justa Gain, видимо отвечали так же как здесь. я весь гугол перерыл прежде чем спрашивать

[theurus]

Александр Нестеров, а так правильно? вроде работает, первая команда не блокирует вторую. выглядит как то странно

import asyncio
from aiogram import Bot, Dispatcher, types, executor
import cfg

bot = Bot(token=cfg.token)
dp = Dispatcher(bot)


async def func(n):
    a=0.0
    for _ in range(n):
        await asyncio.sleep(0.0000000000001)
        a += 0.01
    return f'f1 done\n\n{a}'


@dp.message_handler(commands=['cmd1',])
async def send_welcome(message: types.Message):
    result = await func(10000000000000)
    await message.reply(result)

@dp.message_handler(commands=['cmd2',])
async def send_welcome2(message: types.Message):
    a=0.0
    for _ in range(5000):
        a += 0.1
    result = f'f2 done\n\n{a}'
    await message.reply(result)

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