Вы реализуете CQRS и Event Sourcing для высокопроизводительной системы заказов. Команды сохраняют события в потоке только для добавления (append-only stream) для каждого агрегата в Azure Cosmos DB. Вам необходимо создать несколько моделей чтения (поисковые заказы в Azure SQL и горячий кэш), а также публиковать подмножество событий для внешних потребителей для аналитики с возможностью повторного воспроизведения (replay capability). Какие два компонента следует использовать?

Для создания моделей чтения из потока событий Azure Cosmos DB идеально подходит процессор канала изменений Azure Cosmos DB. Он позволяет запускать Azure Functions для обработки событий и проецирования их в другие хранилища данных, такие как Azure SQL Database и Azure Cache for Redis. Идемпотентные upsert-операции важны для обеспечения согласованности при повторной обработке событий. Для публикации событий внешним потребителям и аналитики с возможностью повторного воспроизведения Azure Event Hubs является подходящим выбором. Он поддерживает высокую пропускную способность и настраиваемый срок хранения, что позволяет как обработку в реальном времени, так и повторное воспроизведение событий. Запись команд напрямую в Azure SQL Database или использование Azure Storage Queues в качестве основного хранилища событий не соответствуют принципам Event Sourcing. Отключение идемпотентности рискованно, так как канал изменений может доставлять события несколько раз.