事件总线EventBridge：什么是事件总线EventBridge

事件总线（EventBus）

事件总线是 EventBridge 的核心路由资源，负责接收事件并分发到一个或多个目标。

基于 CloudEvents 1.0 标准，事件总线接收来自阿里云服务、自定义应用或 SaaS 的事件。通过配置事件规则（EventRule），可对事件进行过滤和转换，然后投递到函数计算、云消息队列 RocketMQ 版、钉钉等目标服务。

关键能力

• 内容过滤：通过事件规则筛选特定事件，忽略无关事件。

• 事件转换：在路由过程中修改事件结构，适配目标系统的数据格式。

• 多目标投递：一次事件发布，同时触发多个下游服务处理。

典型场景

• 微服务解耦：订单服务发布“订单创建”事件，库存、物流、积分服务各自独立订阅，互不感知。

• SaaS 集成：Salesforce 中客户信息更新时，自动同步到内部 CRM 系统。

• 自动化运维：云监控检测到实例异常事件，自动触发运维脚本或发送告警通知。

事件流（EventStreaming）

事件流是 EventBridge 的高吞吐数据传输资源，负责海量数据的持续采集与实时处理。

与事件总线的多对多路由不同，事件流提供点对点（1:1）的数据传输服务，专为高吞吐、有序性的数据场景设计。适合处理日志、监控指标、用户行为轨迹等连续数据流。

关键能力

• 高吞吐低延迟：支持百万级 TPS 的数据写入与读取。

• 回溯消费：支持从历史时间点重新拉取数据进行处理。

典型场景

• 实时数据仓库：将业务数据库的 Binlog 或应用日志实时采集，经 Flink 处理后写入数据仓库。

• IoT 数据采集：海量设备上报的状态数据，通过事件流统一汇聚后分发给下游分析系统。

• 点击流分析：实时捕捉用户在网站或 App 上的行为数据，供推荐系统使用。

事件仓（EventHouse）

事件仓是 EventBridge 的结构化事件存储与分析资源。开启事件仓后，所有通过 EventBridge 的事件数据会被持久化存储，可随时查询和分析。

事件仓采用列式存储和分层存储架构，在保证查询性能的同时降低存储成本。除了保留事件历史记录用于追溯和灾难恢复，还支持即时 SQL 查询，将事件数据转化为业务洞察。

关键能力

• 即时 SQL 查询：无需将数据搬运到数据仓库，直接对历史事件执行标准 SQL 查询，支持多维度聚合、过滤与分析。

• 低成本湖仓存储：采用分层存储架构，适合长期保留海量事件数据。

典型场景

• 智能运维与根因分析：系统故障时，通过 SQL 快速检索故障时间窗口内的异常事件链，定位根因。

• 业务智能报表：连接 Quick BI 等工具到事件仓，实时生成基于事件流的业务报表。

• 事件审计与合规：长期保留业务事件记录，满足审计与合规需求。

如何选择

根据场景选择合适的资源：

• 需要将事件从多个来源路由到多个目标时，使用事件总线。例如，一个订单事件需要同时通知库存、物流和积分系统。

• 需要在两个系统之间建立高吞吐数据管道时，使用事件流。例如，持续将数据库变更日志同步到下游分析系统。

• 需要存储和查询历史事件数据时，使用事件仓。例如，分析过去一个月内所有失败支付事件的分布。

说明：三者可组合使用。例如，事件总线接收事件并路由，事件流提供高吞吐通道，事件仓保存历史数据供查询分析。