기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Step Functions 워크플로의 오류 처리

Pass 및 Wait 상태를 제외한 모든 상태에서 런타임 오류가 발생할 수 있습니다. 다음과 같은 다양한 이유로 오류가 발생할 수 있습니다.

기본적으로 상태가 오류를 보고하면 실행 AWS Step Functions 이 완전히 실패합니다.

오류 이름

Step Functions는 오류 이름이라고 하는 대소문자를 구분하는 문자열을 사용하여 Amazon States Language의 오류를 식별합니다. Amazon States Language는 잘 알려진 오류의 이름을 지정하는 기본 제공 문자열 집합을 정의하며,모든 문자열은 States. 접두사로 시작합니다.

상태는 다른 이름으로 오류를 보고할 수 있습니다. 하지만 이러한 오류 이름은 States. 접두사로 시작할 수 없습니다.

프로덕션 코드가 AWS Lambda 서비스 예외(Lambda.ServiceException 및 )를 처리할 수 있는지 확인하는 것이 가장 좋습니다Lambda.SdkClientException. 자세한 내용은 임시 Lambda 서비스 예외 처리 단원을 참조하십시오.

오류 후 재시도

Task, Parallel 및 Map 상태에 Retry라는 이름의 필드가 있을 수 있습니다. 이 필드의 값은 Retrier라고 알려진 객체의 배열이어야 합니다. 개별 Retrier는 특정 재시도 횟수를 나타내며, 보통 점점 시간 간격이 증가합니다.

이러한 상태 중 하나에서 오류를 보고하고 Retry 필드가 있으면 Step Functions에서 배열에 나열된 순서대로 Retire 전체를 스캔합니다. Retirer ErrorEquals 필드 값에 오류 이름이 나타나면 상태 시스템은 Retry 필드에 정의된 대로 재시도를 시도합니다.

가 redriven 실행은 재시도를 정의한 Task 워크플로 상태병렬 워크플로 상태, 또는 인라인 맵 상태를 다시 실행합니다. 이러한 상태에 대한 재시도 횟수는에 대한 최대 시도 횟수를 허용하기 위해 0으로 재설정됩니다.redrive. 의 경우 redriven 콘솔을 사용하여 이러한 상태의 개별 재시도를 추적할 수 있습니다. 자세한 설명은 를 사용하여 상태 시스템 실행 다시 시작 redrive Step Functions의에서 의 재시도 동작 redriven 실행 섹션을 참조하세요.

Retrier에는 다음 필드가 포함됩니다.

Retry 필드 예제

이 섹션에는 다음 Retry 필드 예제가 포함되어 있습니다.

예제 1 - 로 재시도 BackoffRate

다음 예제의 Retry는 3초 동안 기다린 후 첫 번째 재시도를 두 번 수행합니다. 지정한 BackoffRate에 따라 Step Functions는 최대 재시도 횟수에 도달할 때까지 각 재시도 간의 간격을 늘립니다. 다음 예제에서는 첫 번째 재시도 후 3초 동안 기다린 후 두 번째 재시도가 시작합니다.

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

예제 2 - 로 재시도 MaxDelaySeconds

다음 예시에서는 재시도를 3번 수행하고 BackoffRate로 인한 대기 시간을 5초로 제한합니다. 첫 번째 재시도는 3초 동안 기다린 후에 수행됩니다. MaxDelaySeconds에서 설정한 최대 대기 시간 한도로 인해 두 번째 및 세 번째 재시도는 이전 재시도 후 5초 후에 수행됩니다.

"Retry": [ {
    "ErrorEquals": [ "States.Timeout" ],
    "IntervalSeconds": 3,
    "MaxAttempts": 3,
    "BackoffRate":2,
    "MaxDelaySeconds": 5,
    "JitterStrategy": "FULL"
} ]

MaxDelaySeconds를 설정하지 않으면 두 번째 재시도는 첫 번째 재시도 후 6초 후에 수행되고 세 번째 재시도는 두 번째 재시도 후 12초 후에 수행됩니다.

예제 3 - States.Timeout을 제외한 모든 오류 재시도

Retrier의 ErrorEquals 필드에 표시되는 예약된 이름 States.ALL은 모든 오류 이름을 나타내는 와일드카드입니다. 이 이름은 ErrorEquals 어레이에 하나만 표시되어야 하며, Retry 어레이의 마지막 Retrier에 표시되어야 합니다. States.TaskFailed 이름은 와일드카드 역할도 하며 States.Timeout를 제외한 모든 오류와 일치합니다.

다음은 States.Timeout을 제외한 모든 오류를 재시도하는 Retry 필드의 예제입니다.

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

예제 4 — 복잡한 재시도 시나리오

Retrier의 파라미터는 단일 상태 실행의 맥락에서 해당 Retrier에 대한 모든 방문에 적용됩니다.

다음 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"
   } ]
}

이 작업은 연속 4번 실패하며 오류 이름 ErrorA, ErrorB, ErrorC 및 ErrorB가 출력됩니다. 결과로 다음이 발생합니다.

폴백 상태

Task, Map 및 Parallel 상태 각각에는 Catch라는 필드가 있을 수 있습니다. 이 필드의 값은 catchers라는 객체의 어레이이어야 합니다.

Catcher에는 다음 필드가 포함됩니다.

상태에서 오류를 보고하고 Retry 필드가 없거나 재시도를 통해 오류가 해결되지 않으면 Step Function는 배열에 나열된 순서대로 Catcher 전체를 스캔합니다. Catcher의 ErrorEquals 필드 값에 오류 이름이 표시되면 상태 머신이 Next 필드에 이름이 지정된 상태로 전환됩니다.

Catcher의 ErrorEquals 필드에 표시되는 예약된 이름 States.ALL은 모든 오류 이름을 나타내는 와일드카드입니다. 이 이름은 ErrorEquals 어레이에 하나만 표시되어야 하며, Catch 어레이의 마지막 Catcher에 표시되어야 합니다. 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 필드가 포함됩니다. 이 필드 값은 육안으로 읽을 수 있는 오류 설명입니다. 이 객체를 오류 출력이라고 합니다.

예 예에서 첫 번째 Catcher에는 ResultPath 필드가 들어 있습니다. 이 예는 상태의 최상위에 있는 ResultPath 필드와 유사하게 작동하여 다음과 같은 두 가지 작업을 수행할 수 있습니다.

따라서 이 예제의 첫 번째 Catcher의 경우 입력에 error-info 필드가 아직 없으면 Catcher에서 오류 출력을 이 필드로 입력에 추가합니다. 그러면 Catcher가 전체 입력을 RecoveryState로 전송합니다. 두 번째 Catcher의 경우 오류 출력이 입력을 덮어쓰고 Catcher는 오류 출력만 EndState에 전송합니다.

상태에 Retry 및 Catch 필드가 모두 있으면 Step Functions는 적절한 Retrier를 먼저 사용합니다. 재시도 정책에서 오류를 해결하지 못하면 Step Functions는 일치하는 Catcher 전환을 적용합니다.

페이로드 및 서비스 통합으로 인한 오류

Catcher는 문자열 페이로드를 출력으로 반환합니다. Amazon Athena 또는와 같은 서비스 통합을 사용하는 경우 Cause 문자열을 로 변환할 AWS CodeBuild수 있습니다JSON. 내장 함수가 있는 Pass 상태의 다음 예제는 Cause 문자열을 로 변환하는 방법을 보여줍니다JSON.

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

Retry 및 Catch를 사용하는 상태 시스템 예제

다음 예제에 정의된 상태 시스템에는 Lambda 함수가 2개 있습니다. 하나는 항상 실패하는 함수이고 다른 하나는 상태 시스템에 정의된 시간 제한이 발생할 수 있도록 충분히 오래 기다리는 함수입니다.

다음은 항상 실패하는 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를 사용하여 실패 처리

이 상태 머신은 Retry 필드를 사용하여 실패하고 오류 이름 HandledError를 출력하는 함수를 재시도합니다. 재시도 간 지수 백오프를 사용하여 이 함수를 두 번 재시도합니다.

{
   "Comment": "A Hello World example of the Amazon States Language using an AWS 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 AWS 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 AWS 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, AWS Step Functions!",
         "End": true
      }
   }
}

이 변형에서는 사전 정의된 오류 코드 States.TaskFailed를 사용하며 이 오류 코드는 Lambda 함수에서 출력하는 오류와 일치합니다.

{
   "Comment": "A Hello World example of the Amazon States Language using an AWS 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, AWS Step Functions!",
         "End": true
      }
   }
}

Retry를 사용하여 제한 시간 처리

이 상태 시스템은 Retry 필드를 사용하여 TimeoutSeconds에 지정된 제한 시간 값에 따라 제한 시간이 초과된 Task 상태를 재시도합니다. Step Functions는 이 Task 상태에서 Lambda 함수 간접 호출을 두 번 재시도하며 재시도 간에 지수 백오프를 적용합니다.

{
   "Comment": "A Hello World example of the Amazon States Language using an AWS 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 AWS 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, AWS Step Functions!",
         "End": true
      }
   }
}