EventBridge est un service de données événementielles serverless entièrement géré qui sert de hub central pour l'intégration et le traitement des données à l'ère native de l'IA. Fondé sur la norme CloudEvents 1.0, il connecte les composants applicatifs via des événements afin de bâtir des architectures orientées événements (EDA) faiblement couplées et évolutives.
EventBridge ingère les événements provenant des services Alibaba Cloud, des applications personnalisées et des plateformes SaaS, puis les filtre, les transforme et les livre aux cibles sans code d'intégration. Cette architecture orientée événements (EDA), un modèle de conception où les composants communiquent en publiant et en répondant à des événements plutôt qu'en s'appelant directement, s'adapte naturellement à la croissance des charges de travail. Elle s'applique à l'orchestration de microservices, au traitement des données en temps réel et à l'exploitation et maintenance (O&M) automatisées.
Pour plus d'informations contextuelles, consultez :
Ressources principales
EventBridge propose trois types de ressources adaptés à différents modèles de traitement des événements :
|
Dimension |
Event bus |
Event stream |
Event house |
|
Fonction |
Routage et distribution des événements |
Collecte et transmission continues de données à grande échelle |
Stockage persistant et analyse par requête des événements |
|
Modèle de routage |
N:M (plusieurs-à-plusieurs) |
1:1 (un-à-un) |
-- |
|
Fonctionnalités clés |
Filtrage, transformation et livraison vers plusieurs cibles |
Débit élevé, faible latence et relecture de la consommation |
Requêtes SQL instantanées et stockage économique |
|
Scénarios typiques |
Découplage des microservices, intégration SaaS et O&M automatisée |
Collecte de journaux, agrégation de données IoT et ETL en temps réel |
Audit des événements, analyse des causes racines et rapports BI |
Event bus
Un event bus reçoit les événements et les distribue à une ou plusieurs cibles selon des règles d'événements configurables.
Les événements proviennent des services Alibaba Cloud, d'applications personnalisées ou de plateformes SaaS. Chaque règle d'événement définit une condition de filtrage et une ou plusieurs cibles de livraison, telles que Function Compute, ApsaraMQ for RocketMQ ou DingTalk. Lors du routage, la structure de l'événement est transformée pour correspondre au format attendu par chaque cible.
Fonctionnalités clés
Filtrage du contenu -- Faites correspondre les événements à leur charge utile à l'aide de règles d'événements.
Transformation des événements -- Remodelez les données d'événement pendant le routage pour les adapter au format attendu par chaque cible.
Livraison multi-cibles -- Livrez un seul événement à plusieurs services en aval simultanément.
Cas d'utilisation
Découplage des microservices -- Un service de commande publie un événement « Order Created ». Les services d'inventaire, de logistique et de récompenses s'y abonnent indépendamment, sans dépendances directes entre eux.
Intégration SaaS -- Lorsque les informations client changent dans Salesforce, la mise à jour se synchronise automatiquement avec un système CRM interne.
O&M automatisée -- CloudMonitor détecte une défaillance d'instance et déclenche un script de remédiation ou envoie une notification d'alerte.
Event stream
Un event stream fournit un canal de données à haut débit, en mode un-à-un (1:1), pour la collecte continue et le traitement en temps réel de données à grande échelle. Contrairement au routage plusieurs-à-plusieurs d'un event bus, un event stream est optimisé pour les données ordonnées et volumineuses, telles que les journaux, les métriques de surveillance et les événements de comportement utilisateur.
Fonctionnalités clés
Haut débit, faible latence -- Gérez des millions de transactions par seconde (TPS) en écriture comme en lecture.
Relecture de la consommation -- Retraitez les données en les extrayant à partir d'un point spécifique dans le passé.
Cas d'utilisation
Entrepôt de données en temps réel -- Collectez les journaux binaires (binlogs) des bases de données métier et les journaux d'application en temps réel, traitez-les avec Flink et écrivez les résultats dans un entrepôt de données.
Agrégation de données IoT -- Agrégez les données d'état provenant d'un grand nombre d'appareils et distribuez-les aux systèmes d'analyse en aval.
Analyse des flux de clics -- Capturez les données de comportement utilisateur depuis des sites web ou des applications en temps réel pour les systèmes de recommandation.
Event house
Un event house stocke de manière persistante toutes les données d'événements transitant par EventBridge et les rend disponibles pour des requêtes SQL à tout moment. Son architecture de stockage columnaire et hiérarchisé maintient les coûts de stockage bas tout en préservant les performances des requêtes, ce qui le rend adapté à la fois à la rétention à long terme et à l'analyse en temps réel.
Fonctionnalités clés
Requêtes SQL instantanées -- Exécutez des requêtes SQL standard directement sur les événements historiques sans déplacer les données vers un entrepôt de données séparé. Prend en charge l'agrégation multidimensionnelle, le filtrage et l'analyse.
Stockage lakehouse économique -- Architecture de stockage hiérarchisé optimisée pour la rétention à long terme de grands ensembles de données d'événements.
Cas d'utilisation
Analyse des causes racines -- Lorsqu'un système tombe en panne, interrogez la chaîne d'événements anormaux dans la fenêtre temporelle de la défaillance pour identifier la cause racine.
Rapports de business intelligence -- Connectez des outils tels que Quick BI à un event house pour générer des rapports en temps réel à partir des flux d'événements.
Audit des événements et conformité -- Conservez les enregistrements d'événements métier à long terme pour répondre aux exigences réglementaires et d'audit.
Choisir la ressource appropriée
|
Scénario |
Ressource |
Exemple |
|
Router les événements de nombreuses sources vers de nombreuses cibles |
Event bus |
Un événement de commande doit notifier simultanément les systèmes d'inventaire, de logistique et de récompenses |
|
Construire un pipeline à haut débit entre deux systèmes |
Event stream |
Synchroniser continuellement les journaux de modification de base de données vers un système d'analyse en aval |
|
Stocker et interroger les événements historiques |
Event house |
Analyser la distribution des événements de paiement échoués au cours du dernier mois |
Ces trois ressources fonctionnent conjointement. Un event bus reçoit et route les événements, un event stream fournit un canal à haut débit entre deux systèmes, et un event house stocke toutes les données historiques pour interrogation et analyse.
Scénarios d'IA
Le moteur de filtrage et de transformation intégré prétraite les données d'événements -- en nettoyant le bruit et en enrichissant les caractéristiques -- avant qu'elles n'atteignent un modèle d'IA. EventBridge route également les événements traités vers des plateformes d'apprentissage automatique et des bases de données vectorielles.
|
Scénario |
Ressource |
Fonctionnement |
|
Déclenchement d'inférence en temps réel |
Event bus |
Une image téléchargée sur OSS déclenche une fonction Function Compute qui appelle un modèle d'IA pour la reconnaissance |
|
Pipeline de données d'entraînement |
Event stream |
Collecter continuellement les données de comportement utilisateur comme source d'entrée en temps réel pour l'affinement du modèle |
|
Contexte de l'agent IA |
Event Store |
Servir de source de connaissances pour la génération augmentée par récupération (RAG), permettant à un agent IA d'interroger les événements métier historiques |
Concepts clés
|
Concept |
Définition |
|
Événement |
Un enregistrement de données représentant un changement d'état. C'est l'unité de base traitée par EventBridge. |
|
Source d'événement |
L'origine d'un événement -- un service Alibaba Cloud, une application personnalisée ou une plateforme SaaS. |
|
Cible d'événement |
La destination qui consomme un événement -- Function Compute, ApsaraMQ for RocketMQ, un endpoint HTTP ou un autre service. |
|
Event bus |
Le hub de routage qui reçoit, filtre, transforme et distribue les événements. |
|
Règle d'événement |
Une configuration qui définit quels événements faire correspondre et où les livrer. |
Pour des définitions détaillées, consultez Termes.
Avantages
Facturation
Pour plus de détails, consultez Présentation de la facturation.