使用 Step Functions 状态机处理错误情形

登录到IAM 控制台然后选择角色、创建角色.

在存储库的选择受信任实体的类型页面，下Amazon服务选择，选择Lambda从列表中选择，然后选择后续：Permissions (下一步：权限)。

在存储库的附加权限策略在页面上，选择后续：审核。

在存储库的审核页面，输入MyLambdaRole为了角色名称选择，然后选择创建角色.

打开 Amazon Lambda 控制台，地址：https://console.aws.amazon.com/lambda/。

选择创建函数。

在蓝图部分的筛选条件中输入 step-functions，然后选择 step-functions-error 蓝图。

在基本信息部分中，配置 Lambda 函数：

1. 对于 Name (名称)，请输入 FailFunction。

2. 对于 Role (角色)，选择 Choose an existing role (选择现有角色)。

3. 适用于现有角色，选择您之前创建的 Lambda 角色.

   注意

   如果您创建的 IAM 角色未显示在列表中，该角色可能仍需要几分钟才能传播到 Lambda。

以下代码显示在Lambda 函数代码窗格。

'use strict';

exports.handler = (event, context, callback) => {
    function CustomError(message) {
        this.name = 'CustomError';
        this.message = message;
    }
    CustomError.prototype = new Error();

    const error = new CustomError('This is a custom error!');
    callback(error);
};

context 对象返回错误消息 This is a custom error!。

选择 Create function（创建函数）。

创建 Lambda 函数后，记下其亚马逊资源名称 (ARN) 位于页面右上角的亚马逊资源名称 (ARN)，如以下示例所示。

arn:aws:lambda:us-east-1:123456789012:function:FailFunction

在 FailFunction 页面上，选择 Test。

在配置测试事件对话框中，输入FailFunction为了Event name (事件名称)选择，然后选择Create.

在存储库的FailFunction页面，测试您的 Lambda 函数。

测试结果 (模拟错误) 显示在页面底部。

打开Step Functions 控制然后选择创建状态机.

在存储库的创建状态机在页面上，选择从模板开始选择，然后选择抓取失败时.

在 Type (类型) 下，选择 Standard (标准)。

在代码窗格中，添加 ARN您之前创建的 Lambda 函数到Resource字段，如以下示例所示。

{
   "Comment": "A Catch example of the Amazon States Language using an Amazon Lambda function",
   "StartAt": "CreateAccount",
   "States": {
      "CreateAccount": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:us-east-1:123456789012:function:FailFunction",
         "Catch": [ {
            "ErrorEquals": ["CustomError"],
            "Next": "CustomErrorFallback"
         }, {
            "ErrorEquals": ["States.TaskFailed"],
            "Next": "ReservedTypeFallback"
         }, {
            "ErrorEquals": ["States.ALL"],
            "Next": "CatchAllFallback"
         } ],
         "End": true
      },
      "CustomErrorFallback": {
         "Type": "Pass",
         "Result": "This is a fallback from a custom Lambda function exception",
         "End": true
      },
      "ReservedTypeFallback": {
         "Type": "Pass",
         "Result": "This is a fallback from a reserved error code",
         "End": true
      },
      "CatchAllFallback": {
         "Type": "Pass",
         "Result": "This is a fallback from any error code",
         "End": true
      }
   }
}

这是使用亚马逊状态机的说明。它定义了名为 CreateAccount 的单个 Task 状态。有关更多信息，请参阅状态机结构。

有关 Retry 字段的语法的更多信息，请参阅使用重试和使用 Catch 的示例。

使用中的图表可视工作流” 窗格以检查您的亚马逊状态机代码是否正确描述了状态机。

如果您未看到该图表，请在 Visual Workflow 窗格中选择“”。

选择下一步。

输入名称为了使用状态机，或使用默认名称，Catchfailure.

选择选择现有角色、mylambdarole在下拉列表中。

选择 Create state machine (创建状态机)。

在存储库的CatchStateMachine在页面上，选择启动执行.

此时将显示 New execution 页面。

（可选）为了帮助识别您的执行情况，您可以在输入执行名称。如果未输入 ID，Step Functions 将自动生成一个唯一 ID。

选择 Start Execution (开始执行)。

此时将启动新的状态机执行，并显示一个说明正在运行的执行的新页面。

要查看工作流程的输出，请在 Execution Details (执行详细信息) 部分展开 Output (输出) 部分。

要查看您的自定义错误消息，请选择 CreateAccountVisual workflow (可视工作流程) 中的 ，并展开 Output (输出) 部分。