使用 AWS Step Functions 实现无服务器传奇模式

由 Tabby Ward (AWS)、Rohan Mehta () 和 Rimpy Tewani (AWS) 创作 AWS

Summary

在微服务架构中，主要目标是构建解耦且独立的组件，以提高应用程序的敏捷性、灵活性和更快的上市时间。解耦后，每个微服务组件都配有自己的数据持久层。在分布式架构中，业务事务可跨越多个微服务。由于这些微服务不能使用单个原子性、一致性、隔离、耐久性 (ACID) 事务，因此最终可能会出现部分事务。在这种情况下，需要一些控制逻辑撤销已经处理的事务。分布式 saga 模式通常用于该目的。 

Saga 模式是一种故障管理模式，有助于在分布式应用程序中建立一致性，并协调多个微服务之间的事务以保持数据一致性。当您使用 saga 模式时，每个执行事务的服务都会发布事件，该事件会触发后续服务执行链中的下一个事务。这种情况一直持续至链中的最后一笔事务完成。如果业务事务处理失败，saga 会编排一系列补偿性事务，以撤销先前事务所做的更改。

此模式演示了如何使用 AWS Step Functions、Lambda 和 Amazon Dynamo AWS DB 等无服务器技术自动设置和部署示例应用程序（用于处理差旅预订）。该示例应用程序还使用 Amazon API Gateway 和亚马逊简单通知服务 (AmazonSNS) 来实现传奇执行协调器。该模式可以与基础设施即代码 (IaC) 框架一起部署，例如 AWS Cloud Development Kit (AWSCDK)、AWS无服务器应用程序模型 (AWSSAM) 或 Terraform。

有关传奇模式和其他数据持久性模式的更多信息，请参阅AWS规范性指南网站上的指南 “在微服务中启用数据持久性”。

先决条件和限制

先决条件

产品版本

限制

事件源是在微服务架构中实现 saga 编排模式的一种自然方式，在这种架构中，所有组件都是松耦合的，彼此之间没有直接的了解。如果您的事务涉及少量步骤（三到五步），那么 saga 模式可能非常合适。但是，复杂性会随微服务数量和步骤数量的增加而增加。 

使用此类设计时，测试和调试可能会变得困难，因为必须运行所有服务才能模拟事务模式。

架构

目标架构

拟议的架构使用 AWS Step Functions来构建传奇模式，用于预订航班、预订汽车租赁和处理度假付款。

以下工作流图介绍了旅行预订系统的典型流程。工作流程包括预订航空旅行 (“ReserveFlight”)、预订汽车 (“ReserveCarRental”)、处理付款 (“ProcessPayment”)、确认航班预订 (“ConfirmFlight”) 和确认租车 (“ConfirmCarRental”)，然后在这些步骤完成后发出成功通知。但是，如果系统在运行其中任何一个事务时遇到任何错误，它会开始向后失败。例如，付款处理错误 (“ProcessPayment”) 会触发退款 (“RefundPayment”)，然后退款会触发取消租车和航班（“CancelRentalReservation” 和 “CancelFlightReservation”），从而以失败消息结束整个交易。

这种模式为图表中突出显示的每项任务部署了单独的 Lambda 函数，还为航班、汽车租赁和付款部署了三项 DynamoDB 表。每个 Lambda 函数都创建、更新或删除相应的 DynamoDB 表中的行，具体取决于事务是确认还是回滚。该模式使用 Amazon SNS 向订阅者发送短信 (SMS) 消息，通知他们交易失败或成功。 

自动化和扩缩

您可以使用其中一个 IaC 框架为此架构创建配置。通过以下链接之一获取首选 IaC。

工具

AWS服务

代码

可以在以下链接中找到演示传奇模式的示例应用程序的代码，包括 IaC 模板（AWSCDKAWSSAM、或 Terraform）、Lambda 函数和 DynamoDB 表。按照首个操作说明中的说明安装这些工具。

操作说明

npm install

npm run build

npm run watch

npm run test

cdk bootstrap
cdk deploy

sam build
sam deploy --guided

terraform init
terraform apply

cdk diff

sam deploy

terraform plan

cdk destroy

sam delete

terraform destroy

相关资源

技术论文

AWS服务文档

教程

其他信息

代码

出于测试目的，此模式部署API网关和触发 Step Functions 状态机的测试 Lambda 函数。使用 Step Functions，您可以通过传递run_type参数来模仿 “、”、“” ReserveFlight、“” 和 “ReserveCarRental” 中的故障ProcessPayment，从而控制旅行预订系统的功能ConfirmCarRental。ConfirmFlight

sagaLambda 函数 (sagaLambda.ts) 从API网关中的查询参数中获取输入URL，创建以下JSON对象，然后将其传递给 Step Functions 执行：

let input = {
"trip_id": tripID, //  value taken from query parameter, default is AWS request ID
"depart_city": "Detroit",
"depart_time": "2021-07-07T06:00:00.000Z",
"arrive_city": "Frankfurt",
"arrive_time": "2021-07-09T08:00:00.000Z",
"rental": "BMW",
"rental_from": "2021-07-09T00:00:00.000Z",
"rental_to": "2021-07-17T00:00:00.000Z",
"run_type": runType // value taken from query parameter, default is "success"
};

您可以通过传递以下URL参数来试验 Step Functions 状态机的不同流程：

IaC 模板

链接的存储库包含 IaC 模板，您可使用这些模板来创建整个示例旅行预订应用程序。

DynamoDB 表

以下是关于航班、租车和付款表的数据模型。

Flight Data Model:
 var params = {
      TableName: process.env.TABLE_NAME,
      Item: {
        'pk' : {S: event.trip_id},
        'sk' : {S: flightReservationID},
        'trip_id' : {S: event.trip_id},
        'id': {S: flightReservationID},
        'depart_city' : {S: event.depart_city},
        'depart_time': {S: event.depart_time},
        'arrive_city': {S: event.arrive_city},
        'arrive_time': {S: event.arrive_time},
        'transaction_status': {S: 'pending'}
      }
    };

Car Rental Data Model:
var params = {
      TableName: process.env.TABLE_NAME,
      Item: {
        'pk' : {S: event.trip_id},
        'sk' : {S: carRentalReservationID},
        'trip_id' : {S: event.trip_id},
        'id': {S: carRentalReservationID},
        'rental': {S: event.rental},
        'rental_from': {S: event.rental_from},
        'rental_to': {S: event.rental_to},
        'transaction_status': {S: 'pending'}
      }
    };

Payment Data Model:
var params = {
      TableName: process.env.TABLE_NAME,
      Item: {
        'pk' : {S: event.trip_id},
        'sk' : {S: paymentID},
        'trip_id' : {S: event.trip_id},
        'id': {S: paymentID},
        'amount': {S: "750.00"}, // hard coded for simplicity as implementing any monetary transaction functionality is beyond the scope of this pattern
        'currency': {S: "USD"},
        'transaction_status': {S: "confirmed"}
      }
    };

Lambda 函数

将创建以下函数，以支持 Step Functions 中的状态机流程和执行：

Amazon SNS

该示例应用程序创建了以下主题和订阅，用于发送SMS消息并通知客户预订成功或失败。如果您想在测试示例应用程序时接收短信，请在状态机定义文件中使用您的有效电话号码更新SMS订阅。

AWSCDK片段（在以下代码的第二行中添加电话号码）：

const topic = new  sns.Topic(this, 'Topic');
topic.addSubscription(new subscriptions.SmsSubscription('+11111111111'));
const snsNotificationFailure = new tasks.SnsPublish(this ,'SendingSMSFailure', {
topic:topic,
integrationPattern: sfn.IntegrationPattern.REQUEST_RESPONSE,
message: sfn.TaskInput.fromText('Your Travel Reservation Failed'),
});
 
const snsNotificationSuccess = new tasks.SnsPublish(this ,'SendingSMSSuccess', {
topic:topic,
integrationPattern: sfn.IntegrationPattern.REQUEST_RESPONSE,
message: sfn.TaskInput.fromText('Your Travel Reservation is Successful'),
});

AWSSAM片段（用您的有效电话号码替换+1111111111字符串）：

  StateMachineTopic11111111111:
    Type: 'AWS::SNS::Subscription'
    Properties:
      Protocol: sms
      TopicArn:
        Ref: StateMachineTopic
      Endpoint: '+11111111111'
    Metadata:
      'aws:sam:path': SamServerlessSagaStack/StateMachine/Topic/+11111111111/Resource

Terraform 片段（用您的有效电话号码替换 +111111111 字符串）：

resource "aws_sns_topic_subscription" "sms-target" {
  topic_arn = aws_sns_topic.topic.arn
  protocol  = "sms"
  endpoint  = "+11111111111"
}

成功预订

以下流程说明了成功的预订ReserveFlight，“” 和 “ReserveCarRentalProcessPayment” 后面是 “ConfirmFlight” 和 “” ConfirmCarRental。通过向该SNS主题的订阅者发送SMS消息，向客户通知预订成功。

预订失败

此流程是 saga 模式失败的一个例子。如果在预订航班和租车后，“ProcessPayment” 失败，则按相反的顺序取消步骤。 取消预订，并通过向该SNS主题的订阅者发送SMS消息将失败通知客户。