0

Пишу ТГ бота на aiogram, python. Столкнулся с проблемой, мне нужно запустить отдельный процесс с помощью multiprocessing Procces(). Но как передать в аргумент target асинхронную функцию? Это часть функции телеграмм бота

 elif #Нужное условие#:
    p = mp.Process(target=sc.main #файл импортирован как sc# , args=(user_data['query'], user_data['max_subs'], user_data['req_amount'],
                                         user_id, message, kb_client))
    p.start()
await state.finish()

Это сама функция

async def main(query, max_subs, req_amount, user_id, message, kb_client):
#Куча не нужных переменных#
file_d = f"handlers/Scraper/data/{user_id}_data.csv"

get_data(#куча не нужных аргументов#)


file = open(file_d, "rb")
await message.answer(file, reply_markup=kb_client)
os.remove(file_d)

multiprocessing.current_process().close()

Если что без message.answer() все отлично работает. Возможно есть вариант запуска message.answer() без await чтобы не делать функцию асинхронной. Пожалуйста, любое решение, очень нужно!

2
  • Не уверен что помогу. Но есть вариант без multiprocessing Procces(). ru.stackoverflow.com/questions/1417441/…. Работа отдельной асинхронной функции. Мне помогло. 17 июн 2022 в 8:32
  • @Дмитрий Попробовал сделать в функции main(); loop = asyncio.get_event_loop() loop.run_until_complete(send_file(file=file, message=message, kb_client=kb_client)), где send_file() - функция которая посылает файл (await message.answer()). Выдает ошибку - RuntimeError: this event loop is already running.
    – Gibue
    17 июн 2022 в 11:12

1 ответ 1

0

Нашел решение, но оно не совсем красивое. Сделал отдельную функцию которая будет отправлять результат при нажатии на кнопку. Так же она будет проверять выполняется ли еще запрос с помощью

for proc in proc_l:
    if proc.name == message.from_user.id:
    await message.answer("Ваш запрос еще выполняется")

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.