Eine EventBridge Pipe verwendet eine Amazon SQS-Warteschlange als Quelle und veröffentlicht jedes Quellereignis in einem EventBridge Event Bus. Eine Lambda-Funktion in der Pipe schlägt den Stream-Status jedes Ereignisses in einer Datenbank nach und fügt diesen Status dem Ereignis hinzu. Das Unternehmen möchte, dass Ereignisse nur dann im Event Bus veröffentlicht werden, wenn der Stream-Status "ready" ist. Was sollte das Unternehmen tun?

Die korrekte Antwort ist, der Pipe einen Filterschritt hinzuzufügen. EventBridge Pipes ermöglichen es, Filter nach der Anreicherung (Enrichment) anzuwenden, aber vor dem Ziel. Da die Lambda-Funktion den Stream-Status während der Anreicherung hinzufügt, kann ein nachfolgender Filterschritt verwendet werden, um nur Ereignisse mit dem Status "ready" an den Event Bus weiterzuleiten. Die Option, die Lambda-Funktion zu ändern, ist nicht ideal, da die Lambda-Funktion für die Anreicherung zuständig sein sollte und nicht für die Filterung. Die Option, Filterung zu jeder EventBridge-Regel hinzuzufügen, ist ineffizient und fehleranfällig, da dies bei jeder Regel manuell konfiguriert werden müsste. Ein Input Transformer ist für die Transformation von Daten vor dem Senden an das Ziel gedacht, nicht für das Verwerfen von Ereignissen basierend auf Bedingungen.