Как создать 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, не умею, простите

[Aragorn]

kefirich, да отстаньте от него. С ним лучше не общаться, это местный душнила

[Everything_is_bad]

Aragorn, я правильно понимаю, что ты не способен аргументировано отвечать, но способен тырить чужое, выдавать ответы чатгпт за свои и оскорблять?

[Aragorn]

Everything_is_bad,

не способен аргументировано отвечать

А мне задавали какие-то вопросы?

тырить чужое

Можете привести конкретный пример с ссылочкой?

ответы чатгпт за свои

Это бывает раз в сто лет и только потому, что я проверил их.

оскорблять

Чем я вас оскорбил? Тем, что посоветовал не общаться с вами? Тогда вам встречный вопрос - вы не оскорбляете пользователей почти ежедневно в своих комментариях? Не переходите на личности?

[Everything_is_bad]

Aragorn,

Можете привести конкретный пример с ссылочкой?

твоя статья на хабре, ее конечно удалили, но ты теперь нагло будешь врать что это не было?

Это бывает раз в сто лет и только потому, что я проверил их.

нет, это было кучу раз, ты тупо копипастил ответ и выдал за свой, и делал это даже после того как тебе сказали что так не надо, конечно же всё это удалено.

Чем я вас оскорбил

это местный душнила

только не говорили что это не оскорбление.

вы не оскорбляете пользователей почти ежедневно в своих комментариях

я не оскорбляю, я явно указываю на недостатки, почему некоторые считают, что если их не похвалили, это оскорбление.

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. Строить сложные конструкции с несколькими долгоживущими корутинами методом проб и ошибок - это слишком муторно.

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

Comments

[kefirich]

Спасибо за помощь. А могу ли я сделать систему загрузки фоновых заданий в __init__ функции?
Мне не удобно и не хочется работать с когами.

[Vindicar]

kefirich, ну взгляни на мой ответ. По идее, если конструирование объекта происходит внутри асинхронной функции, твой код должен работать. Если не работает, ты можешь схитрить: в __init__() ты только регистрируешь фоновые задачи (складываешь в список ссылку на метод + параметры, например), а потом отдельным методом своего бота проходишь по этому списку и запускаешь зарегистрированные задачи.
Тогда ты можешь конструировать бота в синхронном коде, а метод запуска задач выполнять либо в on_ready() (с поправкой на возможные неоднократные вызовы), либо в теле async def main().

[kefirich]

Vindicar, спасибо!