O EventBridge é um service de dados de eventos serverless e totalmente gerenciado que atua como hub central para integração e processamento de dados na era nativa de IA. Baseado no padrão CloudEvents 1.0, ele conecta componentes de aplicação por meio de eventos para criar arquiteturas orientadas a eventos (EDAs) escaláveis e com baixo acoplamento.
O EventBridge ingere eventos de services da Alibaba Cloud, aplicações personalizadas e plataformas SaaS. Em seguida, filtra, transforma e entrega esses eventos aos destinos sem necessidade de código de integração. Essa arquitetura orientada a eventos (EDA) — padrão de design em que os componentes se comunicam publicando e respondendo a eventos, em vez de se chamarem diretamente — escala naturalmente conforme as cargas de trabalho aumentam. Ela se aplica à orquestração de microsserviços, ao processamento de dados em tempo real e à automação de operações e manutenção (O&M).
Para mais informações de contexto, consulte:
Recursos principais
O EventBridge oferece três tipos de recursos para diferentes padrões de processamento de eventos:
|
Dimensão |
Event bus |
Event stream |
Event house |
|
Função |
Roteamento e distribuição de eventos |
Coleta e transmissão contínuas de dados em grande escala |
Armazenamento persistente e análise de consultas de eventos |
|
Padrão de roteamento |
N:M (muitos para muitos) |
1:1 (um para um) |
-- |
|
Capacidades principais |
Filtragem, transformação e entrega para múltiplos destinos |
Alto throughput, baixa latência e replay de consumo |
Consultas SQL instantâneas e armazenamento de baixo custo |
|
Cenários típicos |
Desacoplamento de microsserviços, integração SaaS e O&M automatizado |
Coleta de logs, agregação de dados IoT e ETL em tempo real |
Auditoria de eventos, análise de causa raiz e relatórios de BI |
Event bus
Um event bus recebe eventos e os distribui para um ou mais destinos com base em regras de evento configuráveis.
Os eventos chegam de services da Alibaba Cloud, aplicações personalizadas ou plataformas SaaS. Cada regra de evento define uma condição de filtro e um ou mais destinos de entrega, como Function Compute, ApsaraMQ for RocketMQ ou DingTalk. Durante o roteamento, a estrutura do evento é transformada para corresponder ao formato esperado por cada destino.
Principais capacidades
Filtragem de conteúdo — Filtre eventos pelo conteúdo do payload usando regras de evento.
Transformação de eventos — Transforme os dados do evento durante o roteamento para adequá-los ao formato esperado por cada destino.
Entrega para múltiplos destinos — Entregue um único evento a vários services downstream simultaneamente.
Casos de uso
Desacoplamento de microsserviços — Um service de pedidos publica um evento "Pedido Criado". Os services de estoque, logística e recompensas assinam o evento independentemente, sem dependências diretas entre si.
Integração SaaS — Quando informações do cliente mudam no Salesforce, a atualização sincroniza automaticamente com um sistema CRM interno.
O&M automatizado — O CloudMonitor detecta falha na instância e aciona um script de correção ou envia notificação de alerta.
Event stream
Um event stream fornece um canal de dados um para um (1:1) de alto throughput para coleta contínua e processamento em tempo real de dados em grande escala. Ao contrário do roteamento muitos para muitos de um event bus, o event stream é otimizado para dados ordenados e de alto volume, como logs, métricas de monitoramento e eventos de comportamento do usuário.
Principais capacidades
Alto throughput e baixa latência — Processe milhões de transações por segundo (TPS) tanto para gravações quanto para leituras.
Replay de consumo — Reprocesse dados buscando informações a partir de um ponto específico no passado.
Casos de uso
Data warehouse em tempo real — Colete binary logs (binlogs) de bancos de dados comerciais e logs de aplicações em tempo real, processe-os com Flink e grave os resultados em um data warehouse.
Agregação de dados IoT — Agregue dados de status de um grande número de dispositivos e distribua-os para sistemas de análise downstream.
Análise de clickstream — Capture dados de comportamento do usuário de sites ou apps em tempo real para sistemas de recomendação.
Event house
Um event house armazena persistentemente todos os dados de eventos que passam pelo EventBridge e os disponibiliza para consultas baseadas em SQL a qualquer momento. Sua arquitetura de armazenamento em camadas e colunar mantém os custos baixos sem comprometer o desempenho das consultas, sendo adequada tanto para retenção de longo prazo quanto para análise em tempo real.
Principais capacidades
Consultas SQL instantâneas — Execute consultas SQL padrão diretamente em eventos históricos sem mover dados para um data warehouse separado. Oferece suporte a agregação multidimensional, filtragem e análise.
Armazenamento lakehouse de baixo custo — Arquitetura de armazenamento em camadas otimizada para retenção de longo prazo de grandes conjuntos de dados de eventos.
Casos de uso
Análise de causa raiz — Quando ocorre falha no sistema, consulte a cadeia de eventos anômalos dentro da janela de tempo da falha para identificar a causa raiz.
Relatórios de business intelligence — Conecte ferramentas como Quick BI a um event house para gerar relatórios em tempo real a partir de streams de eventos.
Auditoria e conformidade de eventos — Retenha registros de eventos comerciais a longo prazo para atender a requisitos regulatórios e de auditoria.
Escolha o recurso adequado
|
Cenário |
Recurso |
Exemplo |
|
Roteie eventos de muitas origens para muitos destinos |
Event bus |
Um evento de pedido precisa notificar os sistemas de estoque, logística e recompensas simultaneamente |
|
Crie um pipeline de alto throughput entre dois sistemas |
Event stream |
Sincronize continuamente logs de alterações de banco de dados com um sistema de análise downstream |
|
Armazene e consulte eventos históricos |
Event house |
Analise a distribuição de eventos de pagamento com falha no último mês |
Esses três recursos funcionam em conjunto. Um event bus recebe e roteia eventos, um event stream fornece um canal de alto throughput entre dois sistemas e um event house armazena todos os dados históricos para consulta e análise.
Cenários de IA
O mecanismo integrado de filtragem e transformação pré-processa os dados do evento — removendo ruído e enriquecendo recursos — antes que eles cheguem a um modelo de IA. O EventBridge também roteia eventos processados para plataformas de machine learning e bancos de dados vetoriais.
|
Cenário |
Recurso |
Como funciona |
|
Acionador de inferência em tempo real |
Event bus |
Uma imagem carregada no OSS aciona uma função do Function Compute que chama um modelo de IA para reconhecimento |
|
Pipeline de dados de treinamento |
Event stream |
Colete continuamente dados de comportamento do usuário como source de entrada em tempo real para ajuste fino do modelo |
|
Contexto de agente de IA |
Event Store |
Atue como source de conhecimento para geração aumentada por recuperação (RAG), permitindo que um agente de IA consulte eventos comerciais históricos |
Conceitos-chave
|
Conceito |
Definição |
|
Evento |
Registro de dados que representa uma mudança de estado. É a unidade básica processada pelo EventBridge. |
|
Origem do evento |
Procedência de um evento — um service da Alibaba Cloud, uma aplicação personalizada ou uma plataforma SaaS. |
|
Destino do evento |
Local que consome um evento — Function Compute, ApsaraMQ for RocketMQ, um endpoint HTTP ou outro service. |
|
Event bus |
Hub de roteamento que recebe, filtra, transforma e distribui eventos. |
|
Regra de evento |
Configuração que define quais eventos devem ser correspondidos e para onde devem ser entregues. |
Para definições detalhadas, consulte Terms.
Benefícios
Faturamento
Para obter detalhes, consulte Billing overview.