Pipe EventBridge używa kolejki Amazon SQS jako źródła i publikuje każde zdarzenie źródłowe w magistrali zdarzeń EventBridge. Funkcja Lambda w potoku wyszukuje status strumienia każdego zdarzenia z bazy danych i dołącza ten status do zdarzenia. Firma chce, aby zdarzenia były publikowane w magistrali zdarzeń tylko wtedy, gdy status strumienia jest gotowy. Co powinni zrobić?

Dodanie kroku filtrującego do potoku jest najefektywniejszym rozwiązaniem, ponieważ pozwala na odrzucenie niechcianych zdarzeń na wczesnym etapie przetwarzania, zanim zostaną opublikowane w magistrali zdarzeń. Zmniejsza to niepotrzebne obciążenie magistrali i koszty związane z przetwarzaniem zdarzeń. Modyfikacja funkcji Lambda, aby zwracała tylko zdarzenia o statusie „ready”, jest możliwa, ale mniej optymalna, ponieważ funkcja nadal przetwarzałaby wszystkie zdarzenia, zanim zdecyduje, które zwrócić. Dodanie filtra do każdej reguły EventBridge jest nieefektywne, ponieważ zdarzenia nadal trafiałyby do magistrali, a filtrowanie odbywałoby się dopiero na etapie subskrypcji. Użycie transformatora wejściowego na wyjściu potoku służy do modyfikacji formatu danych, a nie do filtrowania zdarzeń na podstawie ich zawartości.