Event-Driven архитектура на FastAPI: через паттерн Pub/Sub

В мире разработки программного обеспечения постоянно появляются новые подходы к построению систем. Event-Driven архитектура выступает одним из наиболее перспективных решений для создания гибких и масштабируемых приложений. В данной статье мы расскажем о реализации Event-Driven архитектуры (EDA) с использованием FastAPI и паттерна Publish/Subscribe. Рассмотрим основные концепции, компоненты и практические примеры кода для создания масштабируемой системы обмена сообщениями.

https://habr.com/ru/articles/907632/

#eventdriven #python #fastapi #программирование #kafka #обработка_событий #топики #pub_sub #брокер_сообщений

Как читать сообщения, если никто из брокеров не предоставил удобный интерфейс

Пишите вы себе EDA на основе Apache Kafka , и ваши сервисы тщательно логируют все свои действия, процесс отлажен и работает годами. Вдруг один из сервисов отчитался в логах, что отправил событие в брокер, но другой по какой-то его не прочитал. Как понять, кто виноват? Как правило, брокер сообщений между сервисами – черная коробка, которая работает, что называется «As Is». Разработчики подключают зависимости, вешают аннотации консюмеров и продюсеров , оно заводится и все рады. Но что они там подключили и как это работает никто не видит. Так давайте же посмотрим, как мы можем открыть этот чёрный ящик на примере наиболее популярных брокеров сообщений.

https://habr.com/ru/companies/axenix/articles/886042/

#kafka #брокер_сообщений #activemq_artemis #rabbitmq #nats #conductor #offset_explorer #kafka_ui #brok #esb

Брокер сообщений на Rust

Всем привет. Написал бессерверный брокер сообщений, кому интересно прошу под кат.

https://habr.com/ru/articles/887232/

#messagebroker #serverless #брокер_сообщений

Телеграм-бот для бронирования столов на вебхуках: FastAPI, Aiogram Dialog, FastStream и RabbitMQ в единой экосистеме

В этой статье мы создадим функционального Telegram-бота для бронирования столиков в ресторане «Binary Bites» с использованием современных Python-инструментов. Бот будет работать через вебхуки, взаимодействовать с брокером сообщений RabbitMQ и поддерживать фоновое выполнение задач с помощью FastStream и APScheduler. Проект объединит FastAPI, SQLAlchemy, Alembic, Uvicorn и другие библиотеки, обеспечивая гибкость и масштабируемость. Готовый бот позволит пользователям бронировать столики, просматривать и отменять брони, а администраторам — управлять заказами.

https://habr.com/ru/companies/amvera/articles/882878/

#fastapi #rabbitmq #брокер_сообщений #aiogrram #aiogram_dialog #faststream #телеграм_бот #telegram_bot #telegram_bots #sqlalchemy_20

RabbitMQ в dBrain: опыт внедрения в платформу контейнеризации

В статье рассматриваем, как RabbitMQ интегрирован в dBrain, какие операторы использовались для управления кластерами, а также с какими проблемами разработчики столкнулись в процессе внедрения.

https://habr.com/ru/companies/dbraincloud/articles/875366/

#брокер_сообщений #rabbitmq #kafka #микросервисы #высоконагруженные_проекты #контейнеризация #платформа #кластеры #брокер #сообщения

Скажем нет «Превращению», или анализ Kafka

Бывало ли вам интересно, какие баги может таить исходный код проектов, которыми пользуются большие компании по всему миру? Не упустите шанс познакомиться с интересными ошибками, которые нашёл статический анализатор PVS-Studio в исходном коде Open Source проекта Apache Kafka.

https://habr.com/ru/companies/pvs-studio/articles/851066/

#Java #программирование #статический_анализ #ошибки #kafka #kafka_apache #apache #apache_kafka #брокер_сообщений #pvsstudio

FastStream — новый убийца Celery?

FastStream - это относительно новая блестящая игрушка в руках Python'истов, которая создана специально для работы с брокерами сообщений. В Python сложилось устойчивое убеждение, что если мы работаем с MQ - то нам нужен Celery , но он слегка устарел. Именно поэтому люди пытаются выкинуть "деда" и затащить вместо него любой новый многообещающий MQ-инструмент. Кроме того, культ Celery настолько силен в умах, что практически все новые библиотеки для работы с MQ пытаются стать его "убийцей" и заменой. Однако, это не совсем верно. Существует огромный пласт проектов, которым нужен не фреймворк для менеджмента задач, а просто "голый" функционал Kafka / RabbitMQ / NATS /whatever для межсервисного взаимодействия. И все эти проекты вынуждены довольствоваться "сырыми" python-клиентами к своим брокерам, а всю обвязку вокруг этих клиентов писать самостоятельно. FastStream целится как раз в эту нишу. В рамках статьи я хочу убедить вас, что не Celery мы едины, и для альтернативных инструментов найдется место под солнцем. А также рассмотрим фичи FastStream , которые он привносит в застоявшийся мир MQ-инструментов.

https://habr.com/ru/articles/822505/

#python #faststream #open_source #микросервисы #брокер_сообщений #webразработка #kafka #rabbit #nats #redis

Как работать с MassTransit и RabbitMQ: реализуем RPC с Saga и без

Привет, Хабр! Меня зовут Евгений, я backend-разработчик SimbirSoft. В этой статье я разберу два варианта решения нетривиальной задачи создания RPC через брокер сообщений RabbitMQ и библиотеку MassTransit. Подробно разберём подключение MassTransit и работу с Saga. Тема будет полезна как для начинающих, так и опытных backend-разработчиков .NET. 🚌 Поехали!

https://habr.com/ru/companies/simbirsoft/articles/815021/

#брокер_сообщений #rabbitmq #amqp #saga #микросервисы