Как создать task в __init__ asyncio?

Question

[kefirich]

У меня есть дискорд бот. Я сделал логику запуска. Когда я пытаюсь запустить task в __init__, то появляется ошибка:

AttributeError: loop attribute cannot be accessed in non-async contexts. Consider using either an asynchronous main function and passing it to asyncio.run or using asynchronous initialisation hooks such as Client.setup_hook

Основной файл:

def __init__(self, *args, **kwargs):
		discord.Client.__init__(self, *args, **kwargs, intents=discord.Intents.all())
		self.token = kwargs.get('token')
		self.mongo_url = kwargs.get('mongo_url')
		self.mongo_name = kwargs.get('mongo_name')
		self.redis_url = kwargs.get('redis_url')
		self.db = Db(self.mongo_url, self.mongo_name, self.redis_url)
		self.plugin_manager = PluginManager(self)
		self.plugin_manager.load_all()
		self.loop = asyncio.get_event_loop()

	def run(self, *args):
		print('Running...')
		asyncio.run(self.start(*args))

Файл с ошибкой:

def __init__(self, bot):
		self.bot = bot
		self.db = bot.db
		self.commands = {}
		self.bg_tasks = {}

		for name, member in inspect.getmembers(self):
		# registering commands
			if hasattr(member, '_is_command'):
				self.commands[member.__name__] = member
			# registering bg_tasks
			if hasattr(member, '_bg_task'):
				self.bg_tasks[member.__name__] = member
				self.bot.loop.create_task(member())
		print("Registered {} commands / {} bg tasks".format(
			len(self.commands),
			len(self.bg_tasks)
		))

Я понимаю, что асинхронные функции нельзя запускать в __init__.
Я не понимаю asyncio.

Comments

[Everything_is_bad]

Я не понимаю asyncio.

ну так исправь эту проблему, начни изучать и понимать, тебе про это уже говорили.

[kefirich]

Everything_is_bad, если вы не тоже не знаете, то пожалуйста, не пишите

[Everything_is_bad]

kefirich, я знаю, но не буду за тебе выполнять задание, с этим вообще на фриланс. И не нужно мне указывать писать или не писать, ты пришел на открытый ресурс.

ЗЫ а ты текст ошибок тоже не читаешь?

[kefirich]

Everything_is_bad, откуда такая агрессия на меня?

[Everything_is_bad]

kefirich, где ты увидел агрессию?

[kefirich]

Everything_is_bad, в ваших сообщениях. если вы не хотите помочь, то не надо

[Everything_is_bad]

kefirich, ты не хочешь разбираться с asyncio, не вижу даже смысла тебе помогать.

[kefirich]

Everything_is_bad, Я РАЗБИРАЮСЬ. Я НЕ ПОНИМАЮ ЧТО НУЖНО ИСПРАВИТЬ ЧТОБЫ ВСЕ РАБОТАЛО. ВЫ В СВОЕМ НАЧАЛЕ МНОГО ПОНИМАЛИ? я нет

[Everything_is_bad]

kefirich,

а ты текст ошибок тоже не читаешь?

or using asynchronous initialisation hooks such as Client.setup_hook

[kefirich]

Everything_is_bad, не умею, простите

Answer 1

[Vindicar]

Тебе довольно прямо сказано: "AttributeError: loop attribute cannot be accessed in non-async contexts."
Иными словами, атрибут Bot.loop (ссылку на рабочий цикл asyncio) можно читать, только если ты находишься внутри async def функции, прямо или косвенно.
Причина простая - asyncio.run() или эквивалентная функция как раз создаёт и запускает рабочий цикл asyncio (обычно называемый event loop или просто loop). Если рабочий цикл ещё не создан, то что должен вернуть атрибут Bot.loop? На этот вопрос просто нет правильного ответа. Поэтому доступ к атрибуту блокируется.

И насчёт решения тоже подсказано: "Consider using either an asynchronous main function and passing it to asyncio.run or using asynchronous initialisation hooks such as Client.setup_hook". Иными словами, тебе нужно сделать так, чтобы твой код, обращающийся к Bot.loop, выполнялся в асинхронной (async def) функции. Это можно сделать двумя способами.

Первый: вынести твой код из конструктора (который не может быть асинхронным) в отдельный метод. Например, Bot (и его предок Client) позволяют вызвать асинхронный метод on_ready() при запуске бота. Тут есть много оговорок - в частности, on_ready() может быть вызван неоднократно, если есть проблемы с соединением. Это нужно иметь ввиду.

Второй: завернуть вызов всего твоего конструктора в асинхронный метод. Упрощённо, вместо

import discord
from discord.ext import commands

intents = discord.Intents.default()
intents.members = True
intents.message_content = True

bot = commands.Bot(command_prefix='!', intents=intents)
# ...
bot.run('token')

можешь попробовать что-то вроде

import discord
from discord.ext import commands


async def main():
    # асинхронная функция может быть выполнена ТОЛЬКО внутри рабочего цикла
    # значит, рабочий цикл уже точно существует и выполняется
    intents = discord.Intents.default()
    intents.members = True
    intents.message_content = True
    # конструктор сам по себе не асинхронный, но он выполняется в асинхронном контексте
    bot = commands.Bot(command_prefix='!', intents=intents)  
    # ...
    # мы уже в асинхронной функции, поэтому используем await start() вместо run()
    await bot.start('token')  # main() не завершит работу, пока бот не завершит работу


if __name__ == '__main__':
    asyncio.run(main())  # создаём рабочий цикл. он будет работать, пока main() не завершит работу

Но я соглашусь с Everything_is_bad - сначала разберись, как работает asyncio. Строить сложные конструкции с несколькими долгоживущими корутинами методом проб и ошибок - это слишком муторно.

Ну и очень большой вопрос от меня: ты, я вижу, мастеришь систему плагинов. Чем тебя не устроили коги?