Bir EventBridge Pipe, kaynak olarak bir Amazon SQS kuyruğu kullanır ve her kaynak olayını bir EventBridge event bus'a yayınlar. Pipe'taki bir Lambda işlevi, her olayın akış durumunu bir veritabanından arar ve bu durumu olaya ekler. Şirket, olayların yalnızca akış durumu 'ready' olduğunda event bus'a yayınlanmasını istiyor. Ne yapmalılar?

EventBridge Pipe'lar, kaynak ve hedef arasında veri işleme ve filtreleme yetenekleri sunar. Akış durumu 'ready' olan olayları hedef event bus'a iletmek için en verimli yöntem, pipe'a bir filtreleme adımı eklemektir. Bu, yalnızca istenen koşulları karşılayan olayların Lambda işlevinden sonra işlenmesini ve hedefe gönderilmesini sağlar. Diğer seçenekler neden uygun değil: Lambda'yı değiştirmek: Lambda işlevi zaten durumu arıyor ve olaya ekliyor. Lambda'nın kendisinin filtreleme yapması, işlevin amacını aşar ve pipe'ın filtreleme yeteneğini kullanmamış olur. Lambda'nın görevi veriyi zenginleştirmektir, filtrelemek değil. Event bus kurallarına filtre eklemek: Bu, olayların event bus'a zaten gönderildiği anlamına gelir. İstenmeyen olayların event bus'a ulaşmasını engellemez, sadece bus'tan sonraki hedeflere iletilmesini engeller. Bu, gereksiz olay trafiği oluşturur. Input transformer kullanmak: Input transformer'lar, olay yapısını değiştirmek veya belirli alanları çıkarmak için kullanılır, olayları tamamen bırakmak için tasarlanmamıştır. Koşullu filtreleme için uygun bir araç değildir.