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

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

亚马逊EventBridge管道

亚马逊EventBridge管道将来源连接到目标。它减少在开发事件驱动架构时对专业知识和集成代码的需求,从而促进公司应用程序的一致性。要设置管道,请选择来源,添加可选筛选,定义可选扩展,然后选择事件数据的目标。

EventBridge管道可用于创建电子商务系统。假设您有一个包含客户元数据(例如送货地址)的 API。来源可能是收到的 Amazon SQS 订单消息。然后,管道将该数据发送到Amazon API Gateway API 增强版,后者返回该订单的客户信息。最后,管道将丰富的数据发送到Amazon Step Functions状态机,由状态机处理订单。

EventBridge管道接收来自各种来源的事件数据,对这些数据应用可选的过滤器和扩展,然后将其发送到目标。如果源对发送到管道的事件强制执行顺序,则该顺序将在发送到目标的整个过程中保持不变。更多有关来源的信息,请参阅 亚马逊 PiEventBridge pes 来源

过滤

EventBridge管道可以过滤给定源的事件,然后仅处理这些事件的子集。有关筛选的更多信息,请参阅 亚马逊 EventBridge 管道筛选

充实

通过 PipesEventBridge 的扩充步骤,可以在将源数据发送到目标之前对其进行增强。例如,您可能会收到不包含完整票证数据的 Ticket 创建的事件。使用扩展,您可以让 Lambda 函数调用get-ticket API 以获取完整的票证详细信息。然后,管道可以将该信息发送到目标

有关丰富事件数据的更多信息,请参阅亚马逊EventBridge管道活动丰富活动

目标

筛选和丰富事件数据后,您可以将其发送到特定目标,例如 Amazon Kinesis 直播或亚马逊CloudWatch日志组。有关可用目标的列表,请参阅亚马逊EventBridge管道的目标

您可以在数据增强之后以及将其发送到目标之前对其进行转换。有关更多信息,请参阅 亚马逊 EventBridge 管道输入转换