Пайп EventBridge использует очередь Amazon SQS в качестве источника и публикует каждое событие источника в шину событий EventBridge. Функция Lambda в пайпе ищет статус потока каждого события в базе данных и добавляет этот статус к событию. Компания хочет, чтобы события публиковались в шину событий только тогда, когда статус потока равен ready. Что им следует сделать?

Добавление шага фильтрации непосредственно в пайп EventBridge — это наиболее эффективное и правильное решение. Это позволяет отфильтровывать нежелательные события до того, как они достигнут целевой шины событий, экономя ресурсы и упрощая дальнейшую обработку. Изменение Lambda для возврата только событий со статусом "ready" неоптимально, так как Lambda все равно будет обрабатывать все события, а фильтрация должна происходить до вызова целевого сервиса. Добавление фильтра к каждому правилу EventBridge, подписывающемуся на шину, неэффективно, поскольку события все равно будут публиковаться в шину, а фильтрация будет дублироваться для каждого потребителя. Использование входного преобразователя для отбрасывания событий не является его основной функцией; преобразователь предназначен для изменения структуры данных, а не для фильтрации по содержимому.