选择您的 Cookie 首选项

我们使用必要 Cookie 和类似工具提供我们的网站和服务。我们使用性能 Cookie 收集匿名统计数据,以便我们可以了解客户如何使用我们的网站并进行改进。必要 Cookie 无法停用,但您可以单击“自定义”或“拒绝”来拒绝性能 Cookie。

如果您同意,AWS 和经批准的第三方还将使用 Cookie 提供有用的网站功能、记住您的首选项并显示相关内容,包括相关广告。要接受或拒绝所有非必要 Cookie,请单击“接受”或“拒绝”。要做出更详细的选择,请单击“自定义”。

AWS Event Fork Pipelines 使用案例示例

聚焦模式

本页内容

AWS Event Fork Pipelines 使用案例示例 - Amazon Simple Notification Service

以下场景描述了一个事件驱动的、无服务器电子商务应用程序,该应用程序使用 AWS Event Fork Pipelines。您可以在 AWS Serverless Application Repository 中使用此示例电子商务应用程序,然后使用 AWS Lambda 控制台将其部署到您的 AWS 账户,您可以在其中测试它并在 GitHub 中检查其源代码。

集成 AWS 服务 的无服务器电子商务应用程序的架构。它描绘了从电子商务用户通过 API Gateway 下订单到包括订单存储、搜索分析和重播在内的不同处理管道的流程,展示了如何通过 Amazon SNS、Lambda、Amazon SQS、DynamoDB 和 Kibana 管理和分析事件。

此电子商务应用程序通过由 API Gateway 托管并由 AWS Lambda 函数 CheckoutApiBackendFunction 支持的 RESTful API 来获取买方的订单。此函数将收到的所有订单发布到名为 CheckoutEventsTopic 的 Amazon SNS 主题,该主题转而将订单分散到四个不同的管道。

第一个管道是由电子商务应用程序的拥有者设计和实现的常规结算处理管道。此管道具有 Amazon SQS 队列 CheckoutQueue(此队列缓冲所有收到的订单)、一个名为 CheckoutFunction 的 AWS Lambda 函数(此函数轮询队列以处理这些订单)和 DynamoDB 表 CheckoutTable(此表安全地保存所有已下订单)。

应用 AWS Event Fork Pipelines

电子商务应用程序的组件处理核心业务逻辑。但是,电子商务应用程序拥有者还需满足:

  • 合规性 - 安全的、压缩的静态加密备份,清理敏感信息

  • 弹性 - 在执行过程中断的情况下重播最近的订单

  • 可搜索性 - 对已下订单运行分析并生成指标

应用程序拥有者可为 AWS Event Fork Pipelines 订阅 CheckoutEventsTopic Amazon SNS 主题,而不是实施此事件处理逻辑

在事件搜索与分析管道的配置中设置以下 JSON 筛选策略。它仅匹配总金额为 100 美元或更多的传入订单。有关更多信息,请参阅 Amazon SNS 消息筛选

{ "amount": [{ "numeric": [ ">=", 100 ] }] }

使用 AWS Event Fork Pipelines 模式,电子商务应用程序拥有者可以避免在编写用于事件处理的一致逻辑后经常产生的开发开销。相反,她可以直接从 AWS Serverless Application Repository 将AWS Event Fork Pipelines 部署到其 AWS 账户。

隐私网站条款Cookie 首选项
© 2025, Amazon Web Services, Inc. 或其附属公司。保留所有权利。