本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
Amazon EventBridge 管道中的事件扩充
通过 EventBridge Pipes 的富集步骤,您可以在将数据从源发送到目标之前,对其进行增强。例如,您可能会收到票证已创建 事件,但其中不包含完整票证数据。使用富集,您可以使用 Lambda 函数调用 get-ticket
API,以获取完整的票证详情。然后,管道可以将该信息发送到目标。
在 EventBridge 中设置管道时,您可以配置以下富集:
API 目标
Amazon API Gateway
Lambda 函数
Step Functions 状态机
注意
EventBridge Pipes 仅支持快速工作流程作为富集。
EventBridge 同步调用富集是因为在调用目标之前,它必须等待富集的响应。
富集响应的大小上限为 6MB。
您还可以在发送数据进行增强之前,对从源接收到的数据进行转换。有关更多信息,请参阅 Amazon EventBridge Pipes 输入转换。
使用富集筛选事件
EventBridge Pipes 会将富集响应直接传递给配置的目标。其中包括支持批处理的目标的数组响应。有关批处理行为的更多信息,请参阅 Amazon EventBridge Pipes 批处理和并发。您还可以使用富集作为筛选器,使传递的事件数少于从源接收到的事件数。如果您不想调用目标,请返回一个空响应,例如 ""
、{}
或 []
。
注意
如果要使用空负载调用目标,请返回一个包含空 JSON [{}]
的数组。
调用富集
EventBridge 同步调用富集(调用类型设置为 REQUEST_RESPONSE
)是因为在调用目标之前,它必须等待富集的响应。
注意
对于 Step Functions 状态机,EventBridge 仅支持快速工作流程作为富集,因为它们可以同步调用。