Een EventBridge Pipe gebruikt een Amazon SQS-wachtrij als bron en publiceert elke brongebeurtenis naar een EventBridge event bus. Een Lambda-functie in de pipe zoekt de streamstatus van elke gebeurtenis op in een database en voegt die status toe aan de gebeurtenis. Het bedrijf wil alleen gebeurtenissen naar de event bus publiceren wanneer de streamstatus 'ready' is. Wat moeten ze doen?

De meest efficiënte oplossing is het toevoegen van een filterstap aan de EventBridge Pipe. Pipes ondersteunen filtering na verrijking, wat betekent dat de Lambda-functie eerst de streamstatus kan toevoegen, waarna de pipe alleen gebeurtenissen met de status 'ready' doorstuurt naar de event bus. Dit voorkomt onnodige publicaties naar de bus. Het wijzigen van de Lambda-functie is minder ideaal omdat de Lambda dan verantwoordelijk wordt voor zowel verrijking als filtering, wat de functionaliteit minder modulair maakt. Het toevoegen van filters aan elke EventBridge-regel op de bus is inefficiënt en complex, vooral bij veel regels, en de ongewenste gebeurtenissen worden dan alsnog naar de bus gestuurd. Een input transformer is bedoeld om de structuur van de output aan te passen, niet om gebeurtenissen te filteren op basis van inhoud.