Integración de eventos con Amazon EventBridge Pipes - Patrones de conexión entre origen y destino
Conecta directamente fuentes de eventos como SQS, DynamoDB Streams y Kinesis con destinos, intercalando filtrado y enriquecimiento en los patrones de diseño.
Patrones de conexión de Pipes
EventBridge Pipes conecta directamente una fuente de eventos con un destino, con pasos opcionales de filtrado, enriquecimiento y transformación de entrada. Las fuentes soportadas incluyen SQS, DynamoDB Streams, Kinesis Data Streams, Amazon MSK, Apache Kafka autogestionado y Amazon MQ. Los destinos incluyen Lambda, Step Functions, API Gateway, EventBridge, SQS, SNS, Kinesis, Firehose y más. A diferencia de las reglas de EventBridge que requieren que los eventos se publiquen en un bus, Pipes consume directamente de la fuente sin intermediarios.
Filtrado y enriquecimiento
El paso de filtrado descarta eventos que no coinciden con el patrón definido antes de procesarlos, reduciendo costos e invocaciones innecesarias. El paso de enriquecimiento permite llamar a Lambda, Step Functions, API Gateway o API Destination para agregar información al evento antes de enviarlo al destino. Por ejemplo, un evento de DynamoDB Streams puede enriquecerse con datos de una API externa antes de enviarse a SQS. La transformación de entrada permite reformatear el payload del evento para que coincida con el formato esperado por el destino, sin necesidad de código adicional.
Combinaciones de origen y destino
Las combinaciones más comunes incluyen: SQS → Lambda (procesamiento asíncrono con control de concurrencia), DynamoDB Streams → EventBridge (propagación de cambios de datos como eventos), Kinesis → Step Functions (orquestación de procesamiento de streaming), y DynamoDB Streams → SQS (desacoplamiento de procesamiento de cambios). Pipes reemplaza el patrón anterior de Lambda como pegamento entre servicios, eliminando código de infraestructura y reduciendo la latencia. Para transformaciones simples, Pipes con transformación de entrada es suficiente sin necesidad de Lambda.
Precios de Pipes
EventBridge Pipes cobra por solicitud procesada. Una solicitud se define como 64 KB de datos transferidos. El filtrado que descarta eventos no genera cargo por el destino, pero sí por la lectura de la fuente. El enriquecimiento con Lambda genera cargos adicionales de Lambda. Para fuentes como SQS, el polling de Pipes reemplaza el polling que haría Lambda directamente, por lo que el costo neto es similar pero con la ventaja de filtrado y transformación sin código.
Resumen
EventBridge Pipes simplifica la integración de eventos conectando directamente fuentes con destinos, con filtrado y enriquecimiento opcionales. Elimina la necesidad de funciones Lambda como pegamento entre servicios, reduciendo código, latencia y complejidad operativa. Para integraciones punto a punto entre servicios de AWS, Pipes es la opción más simple y eficiente.