Как использовать Telethon в потоках?

Question

[neuro4live]

Здравствуйте! Мне необходимо используя flask написать приложение, которое будет пользователю отправлять сообщение в телеграмм. Для работы с телеграмом решил использовать библиотеку Telethon. При вызове функции отправки сообщения, программа выдает ошибку There is no current event loop in thread 'Thread-1'
В официальной документации есть пример, работы телесон с потоками

import asyncio
import threading

async def actual_work():
    client = TelegramClient(..., loop=loop)
    ...  # can use `await` here

def go():
    asyncio.run(actual_work())

threading.Thread(target=go).start()

В моём случае программа выдает такую-же ошибку... Знаю что лучше не использовать асинхронный код в потоках, но всё-же пожалуйста подскажите как решить данную проблему. Вот мой код, который я пытался использовать для запуска асинхронного кода в потоках. Заранее спасибо

from telethon import TelegramClient
import asyncio
import threading

loop=asyncio.new_event_loop()
api_id = 11111111
api_hash = '911111111111'
client = TelegramClient('puat_notification.session', api_id, api_hash, loop=loop)





async def send_message():

    await client.send_message('+7901111', '123')





def go():
    with client:
        asyncio.run(send_message())


threading.Thread(target=go).start()

Comments

[shurshur]

Если используется асинхронный фреймворк, то и flask лучше заменить на что-то асинхронное, а от тредов отказаться вообще.

Answer 1

[neuro4live]

Всем спасибо. Разобрался сам.
Может кому пригодится:

from telethon import TelegramClient
import asyncio
import threading







async def send_message():
    loop = asyncio.new_event_loop()
    api_id = 555
    api_hash = '555555555'
    client = TelegramClient('55555555.session', api_id, api_hash, loop=loop)
    async with client:
        await client.send_message('[phone]', '123')





def go():
    asyncio.run(send_message())


threading.Thread(target=go).start()