Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 Amazon Web Services 服务入门。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

Step Functions 中的错误处理

任何状态都可能会遇到运行时错误。错误的发生可能有多种原因，例如以下示例：

默认情况下，当某个状态报告错误时，Amazon Step Functions 会导致执行完全失败。

要向您部署错误处理示例，请参阅 ThAmazon Web Services 账户 e Workshop 的模块 8-错误Amazon Step Functions处理。

错误名称

Step Functions 使用区分大小写的字符串（称为错误名称）识别亚马逊状态语言中的错误。Amazon States 语言定义了一组命名众所周知错误的内置字符串，所有字符串都以States.前缀开头。

状态可以报告具有其他名称的错误。但是，这些错误名称不能以States.前缀开头。

作为最佳实践，确保生产代码可以处理 Amazon Lambda 服务异常（Lambda.ServiceException 和 Lambda.SdkClientException）。有关更多信息，请参阅处理 Lambda 服务异常：

出错后重试

Task 和 Parallel 状态可以有名为 Retry 的字段，其值必须是称为重试器 的对象的数组。一个重试器表示特定重试次数，通常重试之间的时间间隔会增加。

重试器包含以下字段：

以下示例 a 进行了Retry两次重试，第一次重试在等待三秒钟后发生，第二次重试是在第一次重试后等待三秒钟后进行的。要查看完整示例，请参阅上的stepfunction-error-handling-examples存储库 GitHub。

"Retry": [ {
   "ErrorEquals": [ "States.Timeout" ],
   "IntervalSeconds": 3,
   "MaxAttempts": 2,
   "BackoffRate": 1
} ]

重试器的 ErrorEquals 字段中显示的保留名称 States.ALL 是一个通配符，与所有错误名称匹配。它必须单独显示在 ErrorEquals 数组中，并且必须显示在 Retry 数组的最后一个重试器中。该名称States.TaskFailed还充当通配符，可匹配除以下以外的任何错误States.Timeout。

Retry 字段的此示例重试 States.Timeout 之外的任意错误。

"Retry": [ {
   "ErrorEquals": [ "States.Timeout" ],
   "MaxAttempts": 0
}, {
   "ErrorEquals": [ "States.ALL" ]
} ]

复杂重试场景

在单状态执行的上下文中，重试器的参数应用到对该重试器的所有访问。

考虑以下 Task 状态。

"X": {
   "Type": "Task",
   "Resource": "arn:aws:states:us-east-1:123456789012:task:X",
   "Next": "Y",
   "Retry": [ {
      "ErrorEquals": [ "ErrorA", "ErrorB" ],
      "IntervalSeconds": 1,
      "BackoffRate": 2.0,
      "MaxAttempts": 2
   }, {
      "ErrorEquals": [ "ErrorC" ],
      "IntervalSeconds": 5
   } ],
   "Catch": [ {
      "ErrorEquals": [ "States.ALL" ],
      "Next": "Z"
   } ]
}

此任务连续四次失败，输出以下错误名称：ErrorAErrorB、ErrorC、和ErrorB。出现以下结果：

备用状态

Task，Map并且每个Parallel状态都可以有一个名为的字段Catch。此字段的值必须是称为捕获器 的对象的数组。

捕获器包含以下字段。

当某个状态报告错误并且没有Retry字段，或者重试无法解决错误时，Step Functions 会按照数组中列出的顺序扫描捕获器。当错误名称显示在捕获器的 ErrorEquals 字段中时，状态机转换为在 Next 字段中指定的状态。

捕获器的 ErrorEquals 字段中显示的保留名称 States.ALL 是一个通配符，与所有错误名称匹配。它必须单独显示在 ErrorEquals 数组中，并且必须显示在 Catch 数组的最后一个捕获器中。该名称States.TaskFailed还充当通配符，可匹配除以下以外的任何错误States.Timeout。

以下示例显示，当 Lambda 函数输出未处理的 Java 异常RecoveryState时，Catch字段会转换为名为的状态。否则，该字段转换为 EndState 状态。

"Catch": [ {
   "ErrorEquals": [ "java.lang.Exception" ],
   "ResultPath": "$.error-info",
   "Next": "RecoveryState"
}, {
   "ErrorEquals": [ "States.ALL" ],
   "Next": "EndState"
} ]

错误输出

当 Step Functions 过渡到catch 名称中指定的状态时，对象通常包含该字段Cause。此字段的值是人类可读格式的错误说明。该对象称为错误输出。

在本示例中，第一个捕获器包含一个 ResultPath 字段。其工作方式类似于状态顶级中的 ResultPath 字段，有两种可能的结果：

因此，对于示例中的第一个捕获器，error-info如果输入中还没有具有此名称的字段，则捕手会将错误输出作为名为的字段添加到输入中。然后，捕手将全部输入发送到RecoveryState。对于第二个捕获器，错误输出会覆盖输入，捕获器仅将错误输出发送到EndState。

当状态同时包含Retry和Catch字段时，Step Functions 会首先使用任何相应的检索器。如果重试策略无法解决错误，Step Functions 会应用匹配的捕手转换。

导致有效载荷和服务集成

捕手返回字符串有效负载作为输出。在使用 Amazon Athena 等服务集成时Amazon CodeBuild，您可能需要将Cause字符串转换为 JSON。以下带有内部函数的Pass状态示例显示了如何将Cause字符串转换为 JSON。

"Handle escaped JSON with JSONtoString": {
  "Type": "Pass",
  "Parameters": {
    "Cause.$": "States.StringToJson($.Cause)"
  },
  "Next": "Pass State with Pass Processing"
},

使用重试和使用 Catch 的示例

以下示例中定义的状态机假设存在两个 Lambda 函数：一个总是失败，另一个等待足够长的时间以允许状态机中定义的超时发生。

这是 Node.js Lambda 函数的定义，该函数总是失败并返回消息error。在随后的状态机示例中，此 Lambda 函数被命名为FailFunction。有关创建 Lambda 函数的信息，请参阅步骤 1：创建 Lambda 函数部分。

exports.handler = (event, context, callback) => {
    callback("error");
};

这是睡眠 10 秒钟的 Node.js Lambda 函数的定义。在随后的状态机示例中，此 Lambda 函数被命名为sleep10。

exports.handler = (event, context, callback) => {
    setTimeout(function(){
    }, 11000);
};

使用 “重试” 处理故障

此状态机使用 Retry 字段重试失败的函数，并输出错误名称 HandledError。它重试此函数两次，在两次重试之间以指数回退。

{
   "Comment": "A Hello World example of the Amazon States Language using an Amazon Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:us-east-1:123456789012:function:FailFunction",
         "Retry": [ {
            "ErrorEquals": ["HandledError"],
            "IntervalSeconds": 1,
            "MaxAttempts": 2,
            "BackoffRate": 2.0
         } ],
      "End": true
      }
   }
}

此变体使用预定义的错误代码States.TaskFailed，该代码与 Lambda 函数输出的任何错误相匹配。

{
   "Comment": "A Hello World example of the Amazon States Language using an Amazon Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:us-east-1:123456789012:function:FailFunction",
         "Retry": [ {
            "ErrorEquals": ["States.TaskFailed"],
            "IntervalSeconds": 1,
            "MaxAttempts": 2,
            "BackoffRate": 2.0
         } ],
         "End": true
      }
   }
}

使用 Catch 处理故障

此示例使用 Catch 字段。当 Lambda 函数输出错误时，它会捕获错误，然后状态机过渡到fallback状态。

{
   "Comment": "A Hello World example of the Amazon States Language using an Amazon Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:us-east-1:123456789012:function:FailFunction",
         "Catch": [ {
            "ErrorEquals": ["HandledError"],
            "Next": "fallback"
         } ],
         "End": true
      },
      "fallback": {
         "Type": "Pass",
         "Result": "Hello, Amazon Step Functions!",
         "End": true
      }
   }
}

此变体使用预定义的错误代码States.TaskFailed，该代码与 Lambda 函数输出的任何错误相匹配。

{
   "Comment": "A Hello World example of the Amazon States Language using an Amazon Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:us-east-1:123456789012:function:FailFunction",
         "Catch": [ {
            "ErrorEquals": ["States.TaskFailed"],
            "Next": "fallback"
         } ],
      "End": true
      },
      "fallback": {
         "Type": "Pass",
         "Result": "Hello, Amazon Step Functions!",
         "End": true
      }
   }
}

使用 “重试” 处理超时

此状态机使用Retry字段根据中指定的超时值重试超时的Task状态TimeoutSeconds。Step Functions 在此Task状态下重试 Lambda 函数调用两次，重试之间呈指数级退缩。

{
   "Comment": "A Hello World example of the Amazon States Language using an Amazon Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:us-east-1:123456789012:function:sleep10",
         "TimeoutSeconds": 2,
         "Retry": [ {
            "ErrorEquals": ["States.Timeout"],
            "IntervalSeconds": 1,
            "MaxAttempts": 2,
            "BackoffRate": 2.0
         } ],
         "End": true
      }
   }
}

使用 Catch 处理超时

此示例使用 Catch 字段。在出现超时的情况下，状态机会转换为 fallback 状态。

{
   "Comment": "A Hello World example of the Amazon States Language using an Amazon Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:us-east-1:123456789012:function:sleep10",
         "TimeoutSeconds": 2,
         "Catch": [ {
            "ErrorEquals": ["States.Timeout"],
            "Next": "fallback"
         } ],
         "End": true
      },
      "fallback": {
         "Type": "Pass",
         "Result": "Hello, Amazon Step Functions!",
         "End": true
      }
   }
}