EventBridge es un servicio de datos de eventos serverless y totalmente administrado que funciona como concentrador central para la integración y el procesamiento de datos en la era nativa de la IA. Basado en el estándar CloudEvents 1.0, conecta los componentes de las aplicaciones mediante eventos para construir arquitecturas basadas en eventos (EDA) escalables y con bajo acoplamiento.
EventBridge ingiere eventos provenientes de servicios de Alibaba Cloud, aplicaciones personalizadas y plataformas SaaS; luego los filtra, transforma y entrega a los destinos sin necesidad de código de integración. Esta arquitectura basada en eventos (EDA) —un patrón de diseño donde los componentes se comunican mediante la publicación y respuesta a eventos en lugar de llamadas directas— escala de forma natural conforme crecen las cargas de trabajo. Es aplicable a la orquestación de microservicios, el procesamiento de datos en tiempo real y las operaciones y mantenimiento automatizadas.
Para obtener más información de contexto, consulte:
Recursos principales
EventBridge ofrece tres tipos de recursos para distintos patrones de procesamiento de eventos:
|
Dimension |
Event bus |
Event stream |
Event house |
|
Función |
Enrutamiento y distribución de eventos |
Recopilación y transmisión continua de datos a gran escala |
Almacenamiento persistente y análisis de consultas de eventos |
|
Patrón de enrutamiento |
N:M (muchos a muchos) |
1:1 (uno a uno) |
-- |
|
Capacidades principales |
Filtrado, transformación y entrega a múltiples destinos |
Alto throughput, baja latencia y reproducción de consumo |
Consultas SQL instantáneas y almacenamiento de bajo costo |
|
Escenarios típicos |
Desacoplamiento de microservicios, integración SaaS y operaciones y mantenimiento automatizadas |
Recopilación de registros, agregación de datos IoT y ETL en tiempo real |
Auditoría de eventos, análisis de causa raíz e informes de BI |
Bus de eventos
Un bus de eventos recibe eventos y los distribuye a uno o varios destinos según reglas de eventos configurables.
Los eventos provienen de servicios de Alibaba Cloud, aplicaciones personalizadas o plataformas SaaS. Cada regla de evento define una condición de filtro y uno o varios destinos de entrega, como Function Compute, ApsaraMQ for RocketMQ o DingTalk. Durante el enrutamiento, la estructura del evento se transforma para coincidir con el formato que espera cada destino.
Capacidades clave
Filtrado de contenido: coincide eventos según el contenido de su carga útil mediante reglas de eventos.
Transformación de eventos: adapta los datos del evento durante el enrutamiento para ajustarse al formato esperado por cada destino.
Entrega a múltiples destinos: envía un solo evento a varios servicios posteriores de manera simultánea.
Casos de uso
Desacoplamiento de microservicios: un servicio de pedidos publica un evento "Pedido creado". Los servicios de inventario, logística y recompensas se suscriben de forma independiente, sin dependencias directas entre ellos.
Integración SaaS: cuando la información del cliente cambia en Salesforce, la actualización se sincroniza automáticamente con un sistema CRM interno.
Operaciones y mantenimiento automatizadas: CloudMonitor detecta un error en una instancia y ejecuta un script de corrección o envía una notificación de alerta.
Flujo de eventos
Un flujo de eventos proporciona un canal de datos uno a uno (1:1) de alto throughput para la recopilación continua y el procesamiento en tiempo real de datos a gran escala. A diferencia del enrutamiento de muchos a muchos de un bus de eventos, el flujo de eventos está optimizado para datos ordenados y de gran volumen, como registros, métricas de monitoreo y eventos de comportamiento del usuario.
Capacidades clave
Alto throughput y baja latencia: gestiona millones de transacciones por segundo (TPS) tanto para escrituras como para lecturas.
Reproducción de consumo: reprocesa datos mediante la extracción desde un punto específico en el pasado.
Casos de uso
Data warehouse en tiempo real: recopila registros binarios (binlogs) de bases de datos empresariales y registros de aplicaciones en tiempo real, los procesa con Flink y escribe los resultados en un data warehouse.
Agregación de datos IoT: agrega datos de estado de una gran cantidad de dispositivos y los distribuye a sistemas de análisis posteriores.
Análisis de flujo de clics: captura datos de comportamiento del usuario desde sitios web o aplicaciones en tiempo real para sistemas de recomendación.
Event house
Un event house almacena de forma persistente todos los datos de eventos que pasan por EventBridge y los deja disponibles para consultas basadas en SQL en cualquier momento. Su arquitectura de almacenamiento escalonado y columnar mantiene bajos los costos de almacenamiento sin sacrificar el rendimiento de las consultas, lo que lo hace adecuado tanto para la retención a largo plazo como para el análisis en tiempo real.
Capacidades clave
Consultas SQL instantáneas: ejecuta consultas SQL estándar directamente sobre eventos históricos sin necesidad de mover datos a un data warehouse separado. Admite agregación multidimensional, filtrado y análisis.
Almacenamiento lakehouse de bajo costo: arquitectura de almacenamiento escalonado optimizada para la retención a largo plazo de grandes conjuntos de datos de eventos.
Casos de uso
Análisis de causa raíz: cuando falla un sistema, consulta la cadena de eventos anómalos dentro de la ventana de tiempo del error para identificar la causa raíz.
Informes de inteligencia empresarial: conecta herramientas como Quick BI a un event house para generar informes en tiempo real a partir de flujos de eventos.
Auditoría y cumplimiento de eventos: conserva registros de eventos empresariales a largo plazo para cumplir con los requisitos normativos y de auditoría.
Elija el recurso adecuado
|
Scenario |
Resource |
Example |
|
Enrutar eventos desde múltiples orígenes hacia múltiples destinos |
Bus de eventos |
Un evento de pedido necesita notificar simultáneamente a los sistemas de inventario, logística y recompensas |
|
Construir un pipeline de alto throughput entre dos sistemas |
Flujo de eventos |
Sincronizar continuamente registros de cambios de base de datos con un sistema de análisis posterior |
|
Almacenar y consultar eventos históricos |
Event house |
Analizar la distribución de eventos de pago fallidos durante el último mes |
Estos tres recursos funcionan en conjunto. Un bus de eventos recibe y enruta eventos, un flujo de eventos proporciona un canal de alto throughput entre dos sistemas, y un event house almacena todos los datos históricos para su consulta y análisis.
Escenarios de IA
El motor integrado de filtrado y transformación preprocesa los datos de eventos —elimina ruido y enriquece funciones— antes de que lleguen a un modelo de IA. EventBridge también enruta eventos procesados hacia plataformas de aprendizaje automático y bases de datos vectoriales.
|
Scenario |
Resource |
How it works |
|
Activación de inference en tiempo real |
Bus de eventos |
Una imagen cargada en OSS activa una función de Function Compute que llama a un modelo de IA para reconocimiento |
|
Pipeline de datos de entrenamiento |
Flujo de eventos |
Recopilar continuamente datos de comportamiento del usuario como fuente de entrada en tiempo real para el ajuste fino de modelos |
|
Contexto de agente de IA |
Event Store |
Funcionar como fuente de conocimiento para generación aumentada por recuperación (RAG), permitiendo que un agente de IA consulte eventos empresariales históricos |
Conceptos clave
|
Concept |
Definition |
|
Evento |
Registro de datos que representa un cambio de estado. Es la unidad básica que procesa EventBridge. |
|
Origen del evento |
Punto de origen de un evento: un servicio de Alibaba Cloud, una aplicación personalizada o una plataforma SaaS. |
|
Destino del evento |
Destino que consume un evento: Function Compute, ApsaraMQ for RocketMQ, un endpoint HTTP u otro servicio. |
|
Bus de eventos |
Concentrador de enrutamiento que recibe, filtra, transforma y distribuye eventos. |
|
Regla de evento |
Configuración que define qué eventos deben coincidir y a dónde se deben entregar. |
Para definiciones detalladas, consulte Terms.
Beneficios
Facturación
Para más detalles, consulte Billing overview.