Amazon EventBridge: Guía sobre la arquitectura basada en eventos

Amazon EventBridge es un potente servicio de bus de eventos sin servidor que permite a los programadores crear arquitecturas basadas en eventos con una sobrecarga operativa mínima. 

En mi trabajo con sistemas nativos de la nube, he visto lo cruciales que son la capacidad de respuesta en tiempo real y la desacoplamiento de servicios para crear aplicaciones escalables y fáciles de mantener, y EventBridge ofrece precisamente eso.

¿Qué es Amazon EventBridge?

Antes de profundizar en la configuración, es importante comprender qué es EventBridge, por qué es importante y cómo encaja en el ecosistema más amplio de herramientas basadas en eventos de AWS.

Descripción general de Amazon EventBridge

Amazon EventBridgees un servicio de bus de eventos sin servidor y totalmente gestionado que permite a las aplicaciones comunicarse a través de eventos casi en tiempo real.

Simplifica la tarea de enrutar eventos entre productores de eventos (fuentes de cambio, como S3, DynamoDB o aplicaciones personalizadas) y consumidores de eventos (servicios que actúan sobre estos cambios, como Lambda, Step Functions o SNS).

Imagen que contiene un diagrama visual de los eventos de enrutamiento de Amazon EventBridge desde los productores a múltiples destinos. Fuente: AWS Blogs

EventBridge está diseñado pensando en la escalabilidad y la flexibilidad. 

Se escala automáticamente para gestionar millones de eventos por segundo y permite una lógica de enrutamiento compleja mediante reglas basadas en JSON.

Algunas de las capacidades clave incluyen:

• Integración nativa con más de 90 servicios de AWS (por ejemplo, EC2, CodePipeline, CloudTrail).
• Compatibilidad con fuentes de eventos SaaS externas, como Zendesk, Shopify y Datadog.
• Detección y registro de esquemas integrados, que detectan y documentan automáticamente las estructuras de eventos.
• Archivo y reproducción de eventos, para facilitar la depuración, auditoría o reprocesamiento de eventos pasados.

Esto convierte a EventBridge en una herramienta fundamental para crear arquitecturas en la nube desacopladas y resilientes.

EventBridge y la arquitectura basada en eventos

EventBridge se basa en el modelo de arquitectura basada en eventos (EDA).

En EDA, los servicios se comunican emitiendo y reaccionando a eventos, en lugar de realizar llamadas sincrónicas entre sí.

Por ejemplo, en lugar de que un servicio llame a la API de otro servicio para iniciar una tarea, simplemente emite un evento como «ImageUploaded», y otros servicios que están a la escucha de ese evento reaccionan en consecuencia.

La imagen siguiente ilustra esta configuración, en la que Amazon API Gateway actúa como punto de entrada seguro al bus de eventos central de EventBridge.

Imagen que muestra Amazon API Gateway como un punto de entrada seguro al bus central de EventBridge. Fuente: AWS Blogs

Ventajas de la arquitectura basada en eventos:

Imagen que muestra las ventajas de la arquitectura basada en eventos.

• Acoplamiento flexible: Los servicios son independientes y desconocen la existencia de los demás.
• Escalabilidad: Los sistemas pueden escalar componentes individuales de forma independiente.
• Tolerancia a fallos: Los fallos en una parte del sistema no se propagan a otras.
• Procesamiento asíncrono: Mejora la capacidad de respuesta y el rendimiento del sistema.

EventBridge sirve como columna vertebral de EDA en AWS, lo que te permite conectar microservicios, recursos en la nube e incluso sistemas de terceros sin necesidad de acoplarlos estrechamente.

> Si deseas adquirir una sólida comprensión del ecosistema impulsado por eventos de AWS, explora el curso Tecnología y servicios en la nube de AWS.

En qué se diferencia EventBridge de otras opciones basadas en eventos

AWS proporciona varias herramientas para la gestión de eventos y mensajes, pero EventBridge ofrece características únicas que lo distinguen de alternativas como SNS y SQS.

SNS (Servicio de notificación simple) 

SNS es ideal para mensajes pub/sub sencillos.

Puedes publicar un mensaje en un tema y enviarlo a varios suscriptores, por ejemplo, por correo electrónico, SMS o Lambda. 

Sin embargo, carece de funciones sofisticadas de enrutamiento y filtrado de eventos.

SQS (Servicio de cola simple)

SQS proporciona una cola fiable y escalable para el almacenamiento y procesamiento de mensajes. 

Los consumidores consultan la cola de mensajes, lo cual resulta útil para sistemas asíncronos y desacoplados, pero no admite el enrutamiento en tiempo real basado en push.

EventBridge

EventBridge combina lo mejor de ambos: enrutamiento en tiempo real, filtrado avanzado, validación de esquemas e integración SaaS. 

Está diseñado para sistemas complejos, a gran escala y basados en eventos que requieren reglas flexibles, múltiples objetivos y una integración perfecta entre servicios.

Eventos de CloudWatch

CloudWatch Events fue el precursor de EventBridge. 

EventBridge es su sustituto de última generación, que añade:

• Integración de socios SaaS
• Autobuses para eventos personalizados
• Descubrimiento y registro de esquemas
• Gestión mejorada de reglas y permisos

Si todavía utilizas CloudWatch Events, considera la posibilidad de migrar a EventBridge para disfrutar de funciones más completas.

A continuación, se muestra una comparación rápida de los diferentes servicios analizados :

Componentes principales y características clave de Amazon EventBridge

Para utilizar Amazon EventBridge de forma eficaz, es fundamental comprender sus componentes básicos. 

Estos componentes funcionan conjuntamente para permitir flujos de trabajo dinámicos y basados en eventos con una sobrecarga mínima de infraestructura. 

A continuación se ofrece un desglose detallado de cada componente, lo que hace y cómo puedes utilizarlo.

Autobuses para eventos

En el corazón de EventBridge se encuentra el bus de eventos, que actúa como conducto por el que fluyen todos los eventos. 

Un bus de eventos recibe eventos de servicios de AWS, aplicaciones personalizadas o proveedores de SaaS y, a continuación, los enruta a los destinos adecuados en función de reglas de coincidencia.

La imagen siguiente muestra la sección EventBridge Buses (Autobuses de EventBridge) en la consola de AWS.

Imagen que contiene una captura de pantalla de la consola de AWS que muestra la sección EventBridge Buses.

Tipos de autobuses para eventos

Estos son los tipos de buses de eventos disponibles en AWS:

Bus de eventos predeterminado:

• Provisionado automáticamente en todas las cuentas de AWS.
• Se utiliza principalmente para recibir eventos de servicios de AWS (como cambios de estado de EC2 o eventos de S3).
• También puedes enviar tus propios eventos personalizados al bus predeterminado si no se requiere ningún otro bus.

Autobuses para eventos personalizados:

• Creado por ti para dar soporte a diferentes dominios, servicios o cargas de trabajo.
• Ideal para aislar eventos de aplicaciones o separar entornos de desarrollo y producción.
• Permite un control más preciso sobre las políticas de acceso y el enrutamiento de eventos.

Ejemplo de caso de uso:

Crea buses de eventos independientes para diferentes dominios, como uno para operaciones de comercio electrónico y otro para análisis, a fin de mantener los flujos de eventos aislados y gestionables.

Creación de un bus de eventos personalizado:

aws events create-event-bus --name my-app-bus

Comprender las normas y los objetivos

Las reglas definen qué eventos deben enviarse a qué destinos. 

Utilizan la coincidencia de patrones JSON para filtrar los eventos entrantes en el bus y reenviarlos a uno o varios destinos.

Aspectos clave de las normas:

• Puedes filtrar por cualquier atributo del evento, como el origen, el campo « detail-type » (recurso de origen) o los campos anidados « detail » (recurso de destino).
• Varias reglas pueden coincidir con el mismo evento, lo que permite un comportamiento de distribución.
• Una sola regla puede tener varios objetivos, lo que permite que un evento active procesos paralelos.

Los objetivos compatibles incluyen:

• AWS Lambda
• Funciones paso a paso
• Flujos de datos Kinesis
• SNS, SQS
• Tareas ECS
• Pasarela API

Imagen que contiene iconos de servicios de AWS para destinos compatibles.

El siguiente ejemplo muestra cómo definir una regla de evento y vincularla a una función Lambda como destino:

aws events put-rule \
  --name "ImageUploadRule" \
  --event-pattern file://event-pattern.json \
  --event-bus-name my-app-bus

aws events put-targets \
  --rule "ImageUploadRule" \
  --targets "Id"="1","Arn"="arn:aws:lambda:region:account-id:function:ImageProcessor"

Patrón de evento de muestra (event-pattern.json):

{
  "source": ["myapplication.upload"],
  "detail-type": ["Image Uploaded"]
}

Tuberías

EventBridge Pipes simplifica la conexión entre fuentes (como DynamoDB Streams) y destinos (como SQS o Lambda) sin necesidad de código personalizado.

La imagen siguiente muestra la sección EventBridge Pipes en la consola de AWS.

Imagen que contiene una captura de pantalla de la consola de AWS que muestra la sección EventBridge Pipes.

Características principales de Pipes:

• Filtrado: Utiliza patrones de eventos para restringir los eventos que fluyen a través de la tubería.
• Enriquecimiento: Añade contexto invocando una función Lambda para enriquecer el evento antes de su entrega.
• Transformación: Convierte la forma del evento utilizando transformadores de entrada.

Cuándo utilizar tuberías:

• Conectar flujos de datos (por ejemplo, Kinesis o DynamoDB) a consumidores posteriores.
• Integración de los servicios de AWS con diferentes formatos de eventos.

Programador

EventBridge Scheduler permite ejecutar tareas basadas en el tiempo, lo que resulta perfecto para automatizar operaciones como copias de seguridad diarias, sincronizaciones de datos cada hora o la activación de flujos de trabajo según una programación.

La imagen siguiente muestra la sección Programador de EventBridge en la consola de AWS.

Imagen que contiene una captura de pantalla de la consola de AWS que muestra la sección EventBridge Scheduler.

Las características principales incluyen:

• Ejecuciones únicas o recurrentes
• Compatibilidad con expresiones cron o expresiones basadas en la frecuencia.
• Control sobre las zonas horarias, las ventanas de inicio/fin y la lógica de reintento.

Crear un evento programado:

aws scheduler create-schedule \
  --name "DailyETLJob" \
  --schedule-expression "rate(1 day)" \
  --flexible-time-window '{"Mode":"OFF"}' \
  --target '{"Arn":"arn:aws:lambda:region:account-id:function:RunETL", "RoleArn":"arn:aws:iam::account-id:role/SchedulerExecutionRole"}'

Esta programación invoca la función Lambda « RunETL » todos los días.

Registro de esquemas y repeticiones de eventos

Schema Registry ayuda a los programadores a comprender y documentar la estructura de los eventos. 

Detecta automáticamente los esquemas de los servicios de AWS y las aplicaciones personalizadas, y los almacena en un registro.

Las ventajas del Registro de esquemas incluyen:

• Generación de enlaces de código fuertemente tipados en Java, Python y TypeScript.
• Mejora de la coherencia y reducción de los errores de análisis sintáctico en aplicaciones basadas en eventos.

Las repeticiones de eventos te permiten archivar eventos en el bus y reproducirlos más tarde. 

Esto es valioso para:

• Depuración de flujos de trabajo fallidos
• Repetición de eventos tras la corrección de un error
• Recuperación de datos perdidos o procesamiento retrasado

Imagen que contiene un diagrama conceptual que ilustra los eventos de enrutamiento de EventBridge. Fuente: AWS Blogs

Habilitar el archivo de eventos:

aws events create-archive \
  --archive-name "MyApplicationArchive" \
  --event-source-arn "arn:aws:events:region:account-id:event-bus/my-application-bus" \
  --retention-days 7

Reproduce eventos archivados:

aws events start-replay \
  --replay-name "MyReplay" \
  --source-arn "arn:aws:events:region:account-id:archive/MyApplicationArchive" \
  --destination "arn:aws:events:region:account-id:event-bus/my-application-bus"

Estos componentes (autobuses de eventos, reglas, tuberías, programador y registro de esquemas) forman conjuntamente una plataforma completa y flexible para crear y gestionar arquitecturas robustas basadas en eventos en AWS. 

Cada uno desempeña un papel único en la desacoplamiento de servicios, la mejora de la escalabilidad y la aceleración del desarrollo de aplicaciones.

Creación de aplicaciones basadas en eventos con EventBridge

Una vez completada la configuración básica, es el momento de aplicar Amazon EventBridge en flujos de trabajo de aplicaciones reales. 

Configuración de EventBridge en tu aplicación

A continuación se explica cómo emitir eventos personalizados desde tu aplicación utilizando la CLI de AWS:

aws events put-events --entries '[
  {
    "Source": "myapplication.media",
    "DetailType": "ImageUploaded",
    "Detail": "{\"bucket\": \"my-bucket-name\", \"key\": \"image.jpg\"}",
    "EventBusName": "default"
  }
]'

Explicación:

• Source: El nombre o dominio del servicio emisor.
• DetailType: El tipo de evento emitido.
• Detail: La carga útil, codificada como una cadena JSON.
• EventBusName: El autobús que recibirá y distribuirá el evento.

Puedes integrar esta lógica directamente en tus funciones Lambda, servicios de backend o cargas de trabajo en contenedores mediante SDK (por ejemplo, Boto3, AWS SDK para JavaScript).

Enrutamiento de eventos entre servicios de AWS

El enrutamiento de eventos entre servicios de AWS permite integraciones perfectas, como la activación de funciones Lambda desde acciones de S3 a través de EventBridge.

Ejemplo de situación: Conecta Amazon S3 a una función Lambda a través de EventBridge.

Paso 01: Crea un bucket S3 y sube un objeto.

Paso 02: Habilita las notificaciones de eventos S3 a través de EventBridge:

• Ve al bucket de S3.
• Activa la opción «EventBridge» en Notificaciones de eventos.

Paso 03: Crea una regla de EventBridge que coincida con el patrón del evento:

{
  "source": ["aws.s3"],
  "detail-type": ["Object Created"],
  "detail": {
    "bucket": {
      "name": ["my-bucket"]
    }
  }
}

Paso 04: Adjunta una función Lambda como destino de la regla para procesar el objeto cargado.

Este patrón te permite ampliar el procesamiento posteriormente añadiendo otros destinos, como Step Functions o SNS para notificaciones.

Ejemplo práctico: Flujo de trabajo para subir y cambiar el tamaño de imágenes

Podemos seguir un proceso típico basado en eventos:

01: El usuario sube una imagen a S3.

02: S3 emite un evento al bus EventBridge predeterminado.

03: EventBridge encuentra una regla para s3:ObjectCreated:* y la enruta a una función Lambda.

04: Lambda cambia el tamaño de la imagen, la guarda en unbucket de S3 diferente y registra el resultado.

Este patrón es poderoso porque:

• Es escalable (es decir, puede procesar miles de eventos por segundo).
• Es modular (es decir, puedes sustituir la función de redimensionamiento de imágenes sin tocar otros componentes).
• Permite el paralelismo (es decir, puedes enviar el mismo evento a los canales de análisis o notificación simultáneamente).

Añadir reglas para la escalabilidad y la flexibilidad

Puedes distribuir fácilmente los eventos adjuntando varios objetivos a una sola regla:

aws events put-targets --rule image-uploaded \
  --targets '[
    {"Id": "resizeLambda", "Arn": "arn:aws:lambda:region:account-id:function:ResizeImage"},
    {"Id": "notifySNS", "Arn": "arn:aws:sns:region:account-id:ImageUploadedTopic"}
]'

Esto permite que tu aplicación procese el evento, notifique a los usuarios y actualice los registros, todo en paralelo, sin acoplar esas tareas entre sí.

Optimización del rendimiento y garantía de seguridad

Optimiza el rendimiento y la seguridad mediante el diseño de patrones de eventos precisos que minimizan el procesamiento innecesario y reducen el riesgo.

Diseño de patrones de eventos eficientes

Evita patrones amplios o generales que provoquen ejecuciones innecesarias. En su lugar, filtra los eventos con precisión:

{
  "source": ["myapplication.service"],
  "detail-type": ["ImageUploaded"],
  "detail": {
    "bucket": ["media-uploads"]
  }
}

Esto reduce los costes, mejora la latencia y garantiza que solo se procesen los eventos relevantes.

Implementación de controles de seguridad robustos

La seguridad es fundamental en cualquier arquitectura sin servidor. Sigue estas pautas:

• Utiliza el privilegio mínimo de IAM: Concede solo los permisos necesarios para publicar o consumir eventos.
• Activar cifrado: EventBridge admite el cifrado en reposo mediante AWS KMS.
• Implementar DLQ (colas de mensajes no entregados) para entregas fallidas:

"DeadLetterConfig": {
  "Arn": "arn:aws:sqs:region:account-id:my-dlq"
}

Los DLQ capturan los eventos no entregables, lo que te permite diagnosticarlos y volver a procesarlos más tarde.

> Si deseas profundizar en la seguridad de las aplicaciones en la nube y la gestión de permisos de AWS, echa un vistazo al curso AWS Security and Cost Management.echa un vistazo al curso Seguridad y gestión de costes de AWS.

Gestión de costes y cuotas de servicio

Para gestionar eficazmente los costes y el rendimiento, es importante comprender el modelo de precios de EventBridge y supervisar periódicamente las cuotas del servicio.

Comprender la estructura de precios

Se te factura por:

• Evento publicado (en dólares por millón de eventos)
• Evento reproducido
• Uso de tubos
• Tareas programadas

El nivel gratuito incluye 100 000 eventos al mes, lo cual es generoso para la mayoría de los casos de uso de desarrollo y producción a pequeña escala.

Supervisión y ajuste de las cuotas de servicio

Realiza un seguimiento y solicita aumentos utilizando:

aws service-quotas list-service-quotas --service-code events

Cuotas clave a supervisar:

• Reglas por evento bus
• Objetivos por regla
• Invocaciones por segundo

Ampliar tu uso de forma responsable garantiza que tu sistema siga siendo fiable a medida que aumenta la carga.

Configuraciones avanzadas y alternativas de EventBridge

Para arquitecturas basadas en eventos más complejas, debes considerar las características avanzadas de EventBridge y patrones alternativos para mejorar el control, la seguridad y la flexibilidad de la programación.

Distribución de eventos entre cuentas

Habilita el uso compartido seguro de eventos entre cuentas de AWS:

{
  "Statement": [{
    "Effect": "Allow",
    "Principal": {"AWS": "arn:aws:iam::123456789012:root"},
    "Action": "events:PutEvents",
    "Resource": "arn:aws:events:region:account-id:event-bus/shared-bus"
  }]
}

Utiliza AWS CloudTrail para auditar el uso y garantizar el cumplimiento normativo.

Funciones avanzadas del programador de EventBridge

Ve más allá de la programación básica con:

• Estrategias de reintento flexibles
• Cumplimiento del plazo
• Compatibilidad con expresiones cron o rate()

Ejemplo de expresión cron:

Activa un flujo de trabajo todos los lunes a las 9:00 a. m.:

--schedule-expression "cron(0 9 ? * MON *)"

Cuándo considerar alternativas

En función de tus necesidades, es posible que desees considerar otros servicios de AWS que se adapten mejor a casos de uso específicos. 

Aquí tienes algunos ejemplos:

Conclusión

Amazon EventBridge es un componente básico para aplicaciones modernas y nativas de la nube, que te permite crear sistemas escalables y poco acoplados, responder a eventos en tiempo real en plataformas AWS y SaaS, e integrar flujos de trabajo con una sobrecarga mínima de infraestructura. 

Para tener éxito con EventBridge, céntrate en diseñar dominios modulares basados en eventos, aplicar las prácticas recomendadas de privilegios mínimos y colas de mensajes no entregados, y supervisar continuamente el uso, las cuotas y los costes.

Si deseas profundizar tus conocimientos sobre AWS, ¡explora el programa de cursos AWS Cloud Practitioner!