EventBridge Pipe는 Amazon SQS queue를 소스로 사용하고 모든 소스 이벤트를 EventBridge event bus에 게시합니다. 파이프의 Lambda 함수는 데이터베이스에서 각 이벤트의 스트림 상태를 조회하고 해당 상태를 이벤트에 추가합니다. 회사는 스트림 상태가 ready일 때만 이벤트를 이벤트 버스에 게시하려고 합니다. 어떻게 해야 할까요?

EventBridge Pipe의 필터링 단계는 소스에서 수신된 이벤트를 대상으로 보내기 전에 특정 조건에 따라 필터링할 수 있도록 합니다. 따라서 스트림 상태가 'ready'인 이벤트만 EventBridge event bus에 게시되도록 필터 단계를 추가하는 것이 가장 효율적이고 직접적인 방법입니다. Lambda 함수를 수정하는 것은 파이프의 목적과 분리된 로직을 추가하는 것이며, EventBridge rule에 필터를 추가하는 것은 이미 불필요한 이벤트가 버스에 도달한 후 처리하는 것이므로 비효율적입니다. Input transformer는 이벤트 내용을 변환하는 데 사용되며, 이벤트를 삭제하는 데 직접 사용되지 않습니다.