EventBridge Pipe 使用 Amazon SQS 队列作为其源，并将每个源事件发布到 EventBridge 事件总线。Pipe 中的 Lambda 函数从数据库中查找每个事件的流状态，并将该状态附加到事件中。公司只希望在流状态为“ready”时将事件发布到事件总线。他们应该怎么做？

在 Pipe 中添加过滤步骤是最佳实践，因为它在事件处理流程的早期阶段就过滤掉了不相关的事件。这意味着 Lambda 函数只处理那些可能符合条件的事件，从而减少了不必要的计算和成本。 修改 Lambda 函数来过滤事件虽然也能实现目的，但 Lambda 仍然会接收并处理所有事件，这增加了不必要的计算开销。 在 EventBridge 规则上添加过滤器会使所有事件都先到达事件总线，然后才被过滤，这增加了事件总线的负载，并且不符合在源头附近过滤的最佳实践。 在 Pipe 输出上使用输入转换器来丢弃事件，虽然可以实现过滤，但它发生在事件被 Lambda 处理之后，同样未能避免不必要的 Lambda 调用。