亚马逊AWS官方博客
通过 Amazon EventBridge 与 Commercetools 构建响应式无头电商应用
近年来，许多零售商或品牌客户为创建独特的购物体验来增加客户参与度与忠诚度，采纳了创新现代化的电商策略作为差异化的重点。Commercetools 是亚马逊云科技合作伙伴，提供了基于 MACH （Microservices，API-first，Cloud-native，Headless）原则构建的领先电子商务解决方案，被零售、时尚和其他行业的很多全球著名品牌商所信任。2023 年 5 月，Commercetools 登录中国，部署在亚马逊云科技（宁夏）区域，为中国大陆的客户提供了灵活、安全合规且具有竞争优势的云原生电子商务平台，帮助企业快速适应市场需求和购买行为的变化。
在这篇博文中，我们将展示如何利用 Amazon EventBridge（无服务器事件总线）与 Commercetools 解决方案集成，从而构建可扩展的事件驱动应用程序。企业可以实现：
- 快速响应市场变化：事件驱动的架构可以帮助企业快速响应市场变化和客户需求。
- 提升客户体验：实时处理电子商务事件，为客户提供更加精准和个性化的服务。
- 提高业务效率：自动化的事件处理可以降低人工干预的需求，提高业务处理的效率。
Commercetools 事件消息
Commercetools 在资源对象（如订单或产品）状态发生更改时会自动生成事件消息。可以选择消息队列服务（例如 Amazon SQS）或通知类服务（例如 Amazon SNS）来传输系统间的数据，或者 Amazon EventBridge 创建有关新消息的通知。相对于 SQS 或 SNS，Amazon EventBridge 提供了一种基于内容过滤和路由消息的简单方法，Commercetools 用户可以使用该方式以低运营成本创建可扩展、动态的事件管道。常见的场景用例包括但不限于：
- 商品评价审核 —— 在收到商品评价后，使用 Amazon Comprehend（一种 NLP 服务）来确定评价是否为负面或冒犯性的，如果为消极评论，可以主动联系客户以解决情况。
- 客户互动 —— 当商品打折时，可以联系之前查看或购买过相同或相似产品的客户，并鼓励他们回到您的电商网站。
- 订单履行 —— 一旦下订单，从离客户最近的仓库发送物品。
场景案例示例：新上架商品后邮件自动通知
- 电商站点管理员在网页前端创建并发布了新商品，一个 API 调用 Commercetools 的 API 在后端创建新商品。
- Commercetools 生成“ProductPublishedMessage”并自动将其传送到 Amazon EventBridge。
- 然后，Amazon EventBridge 将消息路由到 Lambda 中的一个目标，Amazon Lambda 是一个无服务器、事件驱动的计算服务，能够为几乎任何类型的应用程序或后端服务运行代码，而无需配置或管理服务器。
- Amazon Lambda 函数通过 Amazon SDK 调用 Amazon Pinpoint（一种多渠道营销通信服务）上的 API，以创建新的电子邮件活动，并向一段客户发送消息，宣布新商品。
 |
以下内容步骤重点介绍如打通 Amazon EventBridge 与 Commercetools 的连接，并配置事件过滤规则：
从 Amazon EventBridge 管理控制台，搜索 Commercetools 合作伙伴事件源，查看设置事件源步骤。
 |
要完成 Commercetools-Amazon EventBridge 的集成，首先您需要使用 Commercetools Subscription API 获取后续交互 token，演示所示：
 |
然后，使用上述获取到的 token 来调用 API 创建一个事件订阅：
 |
成功后返回 Amazon EventBridge 管理控制台，在导航栏中选择“合作伙伴事件源”，便能看到之前创建的订阅，状态为Pending；然后勾选该订阅，并点击“关联到事件总线”。您将看到事件源的状态从“Pending”变为“Active”，事件总线的名称将更新以匹配合作伙伴事件源名称。
 |
接下来，创建并配置一个规则以匹配 Commercetools 事件：
 |
在“定义模式”部分，请执行以下操作：
- 选择“事件模式”。
- 选择“按服务预定义的模式”。
- 对于“服务提供商”，选择“服务合作伙伴”。
- 对于“服务名称”，选择“commercetools”。
- 自定义事件模式以仅匹配“产品发布”。选择“编辑”，进行您的更改，然后选择“保存”。
 |
对于“服务事件总线”，请确保选择与您之前创建的合作伙伴事件源关联的事件总线。
作为此规则的目标，选择您之前创建的 Amazon Lambda 函数。选择“创建”以创建规则。
最后，测试解决方案。从 Commercetools 商家中心创建并发布一个新产品。一旦您创建了一个新产品，您可以从 Amazon Pinpoint 管理控制台验证活动的状态。
方案价值
- 实时数据同步：通过灵活的事件驱动架构，使系统能够实时响应业务事件，保证了不同服务和应用之间的实时数据同步，为业务决策提供及时、准确的数据支持。
- 降低系统复杂度：简化了系统架构，降低了系统复杂度和维护成本，同时也为企业节省了宝贵的资源和时间。
- 易于扩展和维护：构建了一个易于扩展和维护的系统架构，为企业的持续增长和创新提供了坚实的基础。
- 自动化运营：能够根据业务事件自动触发相关的运营活动，如新产品发布的邮件通知，提升运营效率和客户体验。
- 数据安全和合规性：满足中国区的技术和数据保护标准，为企业的合规运营提供保障。
结论
通过本博客，我们详细介绍了如何利用 Amazon EventBridge 和 Commercetools 实现事件驱动的响应式无头电商应用，为零售或品牌商展示了一个创新、高效且能够提高客户参与度的解决方案。若您希望进一步了解更多有关 Amazon EventBridge 事件驱动架构，欢迎联系 亚马逊云科技团队，深入讨论如何利用无头商务架构以及事件驱动的解决方案，为您的零售业务创造更多可能和价值。
合作伙伴简介
Commercetools 是一个基于现代 MACH 原则（Microservices，API-first，Cloud-native，Headless）构建的领先电子商务平台，赋能零售或品牌商根据业务及其客户的确切需求，定制电子商务解决方案，以实现与商务解决方案的协同工作，而不是被迫适应现有的解决方案。
了解更多关于 Commercetools 中国的信息请点击这里。