Un EventBridge Pipe utiliza una cola de Amazon SQS como origen y publica cada evento de origen en un bus de eventos de EventBridge. Una función Lambda en el pipe busca el estado del stream de cada evento en una base de datos y añade ese estado al evento. La empresa solo quiere que los eventos se publiquen en el bus de eventos cuando el estado del stream sea 'ready'. ¿Qué deberían hacer?

La opción correcta es añadir un paso de filtro al pipe que coincida con los eventos donde el estado del stream sea igual a 'ready'. EventBridge Pipes permite configurar filtros directamente en el pipe, antes de que el evento llegue al destino. Esto asegura que solo los eventos que cumplen la condición ('ready') sean publicados en el bus de eventos, optimizando el procesamiento y evitando el envío de eventos innecesarios. Modificar la función Lambda para que devuelva solo los eventos de los streams cuyo estado sea 'ready' es incorrecto porque la función Lambda en EventBridge Pipes está diseñada para enriquecer el evento, no para filtrarlo y detener su procesamiento. Si la función Lambda no devuelve un evento, el pipe lo considera un error. Añadir un filtro en cada regla de EventBridge que se suscriba al bus es ineficiente, ya que todos los eventos (incluidos los no deseados) seguirían llegando al bus de eventos, aumentando los costos y la complejidad de la gestión de reglas. Usar un input transformer en la salida del pipe para descartar eventos no es una funcionalidad de filtrado. Los input transformers se utilizan para reestructurar la carga útil del evento antes de enviarla al destino, no para descartar eventos por completo.