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