Amazon EventBridge Pipes Nuevo2022年〜
Un servicio que conecta fuentes de eventos a destinos con integración punto a punto
Qué hace
Amazon EventBridge Pipes conecta fuentes de eventos a destinos de forma punto a punto sin escribir código de integración. Admite filtrado, enriquecimiento y transformación de eventos entre el origen y el destino. Las fuentes incluyen colas SQS, flujos de DynamoDB, flujos de Kinesis y más. Los destinos incluyen funciones Lambda, Step Functions, API Gateway y servicios de terceros.
Casos de uso
Se utiliza para procesar mensajes de colas SQS y enviarlos a Step Functions, replicar cambios de tablas DynamoDB a otros servicios, procesar registros de flujos de Kinesis con enriquecimiento, y construir pipelines de eventos sin código de integración personalizado.
Analogía cotidiana
Piense en ello como una tubería de agua con filtros. El agua (eventos) fluye desde un tanque (origen) a través de filtros (filtrado/enriquecimiento) hasta su destino. No necesita construir la tubería usted mismo: solo conecte los extremos y configure los filtros.
¿Qué es EventBridge Pipes?
Amazon EventBridge Pipes es un servicio de integración punto a punto que conecta productores de eventos con consumidores. Mientras que el bus de eventos de EventBridge es adecuado para enrutamiento de eventos de muchos a muchos, Pipes está optimizado para conexiones uno a uno con filtrado y transformación opcionales. Esto reduce el código de integración y simplifica las arquitecturas basadas en eventos.
Fuentes, filtros y destinos
Pipes admite múltiples fuentes de eventos: colas SQS, flujos de DynamoDB, flujos de Kinesis, Apache Kafka administrado (MSK) y Kafka autogestionado. Puede filtrar eventos antes del procesamiento para reducir costos y complejidad. Los pasos de enriquecimiento opcionales pueden llamar a Lambda, Step Functions, API Gateway o destinos de EventBridge para agregar datos antes de la entrega al destino final.
Transformación y entrega
Pipes admite la transformación de la carga útil del evento entre el origen y el destino usando InputTransformer. Puede extraer campos específicos, reformatear datos y construir cargas útiles personalizadas sin código. La entrega al destino incluye reintentos integrados y manejo de colas de mensajes no entregados (DLQ) para un procesamiento confiable de eventos. Para más información sobre transformación y entrega, libros en Amazon también son útiles.
Aspectos a tener en cuenta
- 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