Vous implémentez CQRS et Event Sourcing pour un système de commande à haut débit. Les commandes stockent les événements dans un flux en append-only par agrégat dans Azure Cosmos DB. Vous devez créer plusieurs modèles de lecture (commandes consultables dans Azure SQL et un cache chaud) et également publier un sous-ensemble d'événements à des consommateurs externes pour l'analyse avec capacité de relecture. Quels sont les deux composants que vous devriez utiliser ?

Le processeur de flux de modifications Azure Cosmos DB est idéal pour projeter des événements dans des modèles de lecture, car il fournit un flux en temps quasi réel des modifications, et les fonctions Azure peuvent traiter ces événements de manière idempotente pour maintenir la cohérence des modèles de lecture (Azure SQL, Redis). Publier des événements sélectionnés vers Azure Event Hubs permet aux consommateurs externes d'analyser les données et de prendre en charge la relecture, ce qui est crucial pour l'analyse historique ou la récupération d'erreurs. Écrire directement dans Azure SQL Database ou utiliser des files d'attente de stockage comme magasin d'événements principal ne convient pas pour l'Event Sourcing à haut débit. Désactiver l'idempotence est risqué, car le flux de modifications garantit une livraison "au moins une fois", nécessitant une gestion de l'idempotence pour éviter les duplications.