Amazon EventBridge Pipes - Amazon EventBridge
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

Amazon EventBridge Pipes

Amazon EventBridge Pipes 可将源与目标连接起来。管道用于在支持的目标之间进行点对点集成,并支持高级转换和富集。开发事件驱动架构时,它可减少对专业知识和集成代码的需求,实现公司应用程序的一致性。要设置管道,请选择源、添加可选筛选、定义可选富集,然后为事件数据选择目标。

注意

您也可以使用事件总线路由事件。事件总线非常适合在事件驱动的服务之间进行多对多事件路由。有关更多信息,请参阅亚马逊 EventBridge 活动巴士

EventBridge Pipes 的工作原理

概括地说,EventBridge Pipes 的工作原理如下:

  1. 您在账户中创建一个管道。这包括:

    • 指定一个支持的事件源,您希望管道从中接收事件。

    • (可选)配置筛选器,使管道仅处理从源接收到的事件的一部分。

    • (可选)配置一个富集步骤,在将事件数据发送到目标之前对其进行增强。

    • 指定一个支持的目标,您希望管道向其发送事件。

  2. 事件源开始向管道发送事件,管道处理事件,然后发送到目标。

    • 如果您配置了筛选器,管道会评估事件,仅在事件与该筛选器匹配时才将其发送到目标。

      您只需为符合筛选条件的事件付费。

    • 如果您配置了富集,管道会在将事件发送到目标之前对事件执行此富集。

      如果对事件进行批处理,富集会保持批次中事件的顺序。

EventBridge Pipes 概览,显示了从源到筛选和富集,再到目标的过程。

例如,管道可以用来创建电子商务系统。假设您有一个 API,其中包含客户信息(例如送货地址)。

  1. 您可以使用以下项创建管道:

    • Amazon SQS 收到订单消息队列,作为事件源。

    • EventBridge API 目标,作为富集

    • Amazon Step Functions 状态机,作为目标

  2. 然后,当 Amazon SQS 收到订单消息出现在队列中时,该消息将发送到您的管道。

  3. 管道将该数据发送到 EventBridge API 目标进行富集,后者会返回该订单的客户信息。

  4. 最后,管道将富集的数据发送到处理订单的 Amazon Step Functions 状态机。