amazon-web-services - 根据错误消息重试 StepFunction 任务

Question

根据 AWS StepFunction 文档，可以为每个错误配置重试，但我想知道是否可以使用错误消息中的详细信息来定义重试策略？

在我的例子中，我正在触发 Glue ETL 作业，该作业可能因自定义异常 NoDataLoadedException 而失败，所以我想识别它并且不重试。这是我的任务定义(第一个 Retry block 永远不会发生):

"ExecuteEtl": {
     "Type": "Task",
     "Resource": "arn:aws:states:::glue:startJobRun.sync",
     "Parameters": {
       "JobName.$": "$.jobName",
        "Arguments.$": "$.jobArguments"
      },
      "Retry" : [{
        "ErrorEquals": [ "NoDataLoadedException" ],
        "MaxAttempts": 0
      },{
        "ErrorEquals": [ "States.Timeout", "States.TaskFailed", "States.Runtime" ],
        "MaxAttempts": 4,
        "IntervalSeconds": 60,
        "BackoffRate": 2
      }],
      "Next": "ExtractGlueJobExecutionId"
}

这是失败输出:

{
  "resourceType": "glue",
  "resource": "startJobRun.sync",
  "error": "{\"AllocatedCapacity\":10,\"Arguments\":{},\"Attempt\":0,\"CompletedOn\":1549662956476,\"ErrorMessage\":\" NoDataLoadedException No data loaded from...",
  "cause": "States.TaskFailed"
}

是否可以使用 error.ErrorMessage 来确定任务的重试策略？

Answer 1

将 NoDataLoadedException 错误添加到 Catch block 中.在其中，您可以定义 Next 步骤。这应该有效:

"ExecuteEtl": {
        "Type": "Task",
        "Resource": "arn:aws:states:::glue:startJobRun.sync",
        "Parameters": {
            "JobName.$": "$.jobName",
            "Arguments.$": "$.jobArguments"
        },
        "Retry" : [{
            "ErrorEquals": [ "States.Timeout", "States.TaskFailed", "States.Runtime" ],
            "MaxAttempts": 4,
            "IntervalSeconds": 60,
            "BackoffRate": 2
        }],
        "Catch": [{
            "ErrorEquals": [ "NoDataLoadedException" ],
            "Next": "NoDataStep"
        }],
        "Next": "ExtractGlueJobExecutionId"
    }

因为 NoDataLoadedException 不会被 Retry block 处理，所以它会落入 Catch，这是您可以对其使用react的地方。