Как реализовать расчет определенных индикаторов торговли в реальном времени?

И вообще,позволит ли мне это сделать GIL в таком количестве?

Как реализовать расчет определенных индикаторов торговли в реальном времени?

Согласен, не совсем правильно задал вопрос, если совсем упростить, мне надо создать 2260 тасков функции get_natr в main() и ее уже я запускаю получая loop -> loop.run_until_complete, но программа просто завершается, если я пытаюсь это сделать просто проходя по каждому тикеру в цикле

for ticker in tickers:
    asyncio.create_task(get_natr())

Как запустить aiogram webhook и aio-pika в одном event loop?

Justa Gain, прошу прощения, создавал таск не в теле on_startup, видимо по этой причине и не работало, еще раз спасибо большое!

Как запустить aiogram webhook и aio-pika в одном event loop?

Justa Gain, я только вчера пробовал через create_task запускать эту функцию, как с помощью loop'а, так и напрямую, в том числе и в теле on_startup. Только сейчас заработало, честно, не знаю почему, спасибо!

Как запустить aiogram webhook и aio-pika в одном event loop?

Justa Gain, нашел вот такое решение, не знаю, насколько оно верное, однако получилось подружить RabbitMQ и Aiogram в одном runtime. Спасибо за наводку на то, что в on_startup можно прописать что-то помимо установки вебхука.

def start_background_loop(side_loop: asyncio.AbstractEventLoop) -> None:
    asyncio.set_event_loop(side_loop)
    side_loop.run_forever()

async def on_startup(dp):
    await bot.set_webhook(config.tg_bot.webhook_url)

    new_loop = asyncio.new_event_loop()
    t = Thread(target=start_background_loop, args=(new_loop,), daemon=True)
    t.start()

    asyncio.run_coroutine_threadsafe(orders_queue(), new_loop)

if __name__ == "__main__":
        loop.create_task(main(dp, config))

        executor.start_webhook(
            dp,
            config.tg_bot.webhook_path,
            on_startup=on_startup,
            on_shutdown=on_shutdown,
            skip_updates=True
        )

Как запустить aiogram webhook и aio-pika в одном event loop?

Я ещё не пробовал использовать потоки, помимо create_task и прочего, если я передам сюда текущий loop, это поможет запустить вебхук и aio-pika параллельно? asyncio.run_coroutine_threadsafe()

(прямо сейчас не могу проверить, будет здорово, если у кого то есть ответ на этот новый вопрос)