Una EventBridge Pipe utilizza una coda Amazon SQS come origine e pubblica ogni evento di origine su un bus di eventi EventBridge. Una funzione Lambda nella pipe cerca lo stato del flusso di ogni evento da un database e aggiunge tale stato all'evento. L'azienda desidera che gli eventi vengano pubblicati sul bus di eventi solo quando lo stato del flusso è pronto. Cosa dovrebbero fare?

L'opzione corretta è aggiungere un passaggio di filtro alla pipe. Le EventBridge Pipes supportano il filtraggio degli eventi dopo l'arricchimento, consentendo di specificare condizioni basate sui dati arricchiti. In questo caso, dopo che la funzione Lambda ha aggiunto lo stato del flusso all'evento, un filtro può essere configurato per inoltrare al bus di eventi solo gli eventi con stato del flusso = ready. Questo è il modo più efficiente e diretto per raggiungere l'obiettivo. Modificare la Lambda per restituire solo gli eventi con stato "ready" non è l'approccio ideale perché la Lambda dovrebbe concentrarsi sull'arricchimento dei dati, non sul filtraggio. Aggiungere un filtro su ogni regola EventBridge che si iscrive al bus sposta la logica di filtraggio a valle e richiede la duplicazione della configurazione, rendendola meno gestibile. Utilizzare un input transformer sull'output della pipe non è la funzione corretta; gli input transformer modificano la struttura dell'evento, non lo filtrano in base al contenuto.