Я подключаюсь к URL веб-сокета, который отправляет мне ок. 1000 сообщений в 1 секунду. Однако для обработки и сохранения этих сообщений моей функции требуется 2 секунды. Какова лучшая практика для обработки этого в Python?
Я изучил Asyncio, однако это не кажется правильным, и новые входящие сообщения не догоняют обработку / сохранение в функцию DB.
Я ценю любые предложения, как с этим справиться.