FastStream: современный асинхронный Python фреймворк для работы с очередями⁠⁠

Сгоняли с автором на рыбалку: поговорили про FastStream, пожарили мясо, обсудили проблемы разработчиков при работе с очередями / брокерами сообщений.

FastStream – аналог FastAPI, но для работы с событиями в брокерах / очередях.

Пример:

Что делает данный код? Читает сообщения из first-topic, парсит из них поле user типа str, выполняет логику обработки, отправляет новое сообщение в another-topic. Просто? Удобно?

Что нам дает такой код?

- Декларативное описание, чего мы хотим. Не надо руками создавать коннекты и рулить потоком выполнения

- AsyncAPI документацию (аналог OpenAPI в вебе)

- Удобное тестирование

- Кучу других плюшек!

Внутри видео обсудили:

- Детали работы DI фастстрима

- Встроенное Observability

- Open Tracing

- Сообщество фреймворка (тут не будет проблемы "одного автора", сообщество живет!)

- Отличия от Celery: когда брать что?

Репозиторий: https://github.com/ag2ai/faststream

Документация: https://faststream.ag2.ai