Un EventBridge Pipe utilise une file d'attente Amazon SQS comme source et publie chaque événement source sur un bus d'événements EventBridge. Une fonction Lambda dans le pipe recherche le statut du flux de chaque événement dans une base de données et ajoute ce statut à l'événement. L'entreprise souhaite que les événements ne soient publiés sur le bus d'événements que lorsque le statut du flux est « ready ». Que devraient-ils faire ?

L'ajout d'une étape de filtrage directement dans le pipe EventBridge est la solution la plus efficace. Cette étape permet de filtrer les événements avant qu'ils n'atteignent le bus d'événements, garantissant ainsi que seuls les événements pertinents (avec le statut "ready") sont publiés. Modifier la fonction Lambda pour qu'elle ne renvoie que les événements "ready" est une option, mais elle est moins optimale car la fonction Lambda serait toujours invoquée pour tous les événements, ce qui pourrait entraîner des coûts inutiles. Ajouter un filtre sur chaque règle EventBridge est inefficace car tous les événements seraient publiés sur le bus, puis filtrés par chaque règle, augmentant le trafic sur le bus et la complexité de gestion. Utiliser un transformateur d'entrée ne permet pas de supprimer des événements du flux ; il modifie la structure de l'événement.