本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
亚马逊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 管道输入转换。