Amazon EventBridge Pipes 新服务2022年〜
将事件源与目标进行点对点连接的服务
它能做什么
Amazon EventBridge Pipes 是一项无需编写代码即可将事件源与目标进行点对点连接的服务。它从 SQS 队列、Kinesis 流、DynamoDB Streams 等源获取事件,经过过滤和转换后传递到目标。无需编写 Lambda 函数即可实现事件驱动集成。
使用场景
适用于将 DynamoDB 变更连接到 Step Functions 工作流、将 SQS 队列消息转发到 API Gateway、过滤 Kinesis 流数据后传递给 Lambda 等简化事件源间连接的场景。
日常类比
可以将其比作邮局的自动分拣机。收到的邮件 (事件) 按目的地自动分拣 (过滤),必要时更换信封 (转换),然后投递到正确的收件地址 (目标)。
什么是 EventBridge Pipes
EventBridge Pipes 是一项直接连接事件源和目标的集成服务。以往从事件源获取数据并传递给其他服务需要编写 Lambda 函数,而使用 Pipes 只需在控制台配置即可构建连接。可选择性地添加过滤、丰富和转换步骤。
管道构成
Pipes 的管道由源、过滤器、丰富和目标 4 个步骤组成。源可从 SQS、Kinesis、DynamoDB Streams、MSK 等中选择。过滤器通过事件模式排除不需要的事件。丰富是使用 Lambda 或 Step Functions 加工数据的可选步骤。目标可从 15 种以上的 AWS 服务中选择。 有关管道构成的设计模式和运维方法,也可参阅 Amazon 上的技术书籍。
入门指南
在 EventBridge 控制台选择「创建管道」,指定源和目标。根据需要设置过滤模式,通过输入转换器调整传递给目标的数据格式。启用管道后,事件将自动从源获取并传递到目标。
注意事项
- Pipes is designed for point-to-point connections. If you need fan-out to multiple targets, use EventBridge rules instead
- Using Lambda in the enrichment step incurs additional Lambda execution charges