Как запустить async def с помощью библиотеки threading?

Question

[Xacker_Name]

Хай, у меня есть функция:

async def rassilkaaaas(_text_):
	y = 0
	n = 0
	p = 0
	for i in sql.execute(f"SELECT ID FROM users"):
		id_user = i[0]
		await asyncio.sleep(0.5)
		try:
			await bot.send_message(id_user, _text_)
			y = y + 1
			p = p + 1
		except:
			n = n + 1
			p = p + 1 
	await bot.send_message(admin, f'✅✅✅Рассылка завершена✅✅✅\nВсего юзеров {p}\n✅Получили сообщение - {y}\n❌Не получили сообщение - {n}', reply_markup=bb.adminka)

При попытке вызвать её так:

async def rassilkaaaa(_text_):
	t1 = Thread(target=rassilkaaaas, args=(_text_,))
	t1.start()
	t1.join()

Вылезает ошибка:

Enable tracemalloc to get the object allocation traceback

Comments

[Xacker_Name]

Dr. Bacon, чтобы отправка сообщения работала в aiogram'e

[Влад Григорьев]

Xacker_Name, ни к чему мешать async и threading

[Сергей Горностаев]

Вопрос звучит как "Хочу покататься на лошади, как загнать её для этого в лодку?"

Answer 1

[alekssamos]

asyncio.run(rassilkaaaas(_text_))
# А, нет.
asyncio.create_taskrassilkaaaas(_text_))

Вот так

Comments

[y7o4ka]

asyncio.create_task(rassilkaaaas(_text_))
Хотя я бы, с учётом ожидания в полсекунды между отправкой сообщений в рассылке, отправлял статус о выполнении сразу, а затем изменял его по мере отправки сообщений