Step Functions를 사용하여 Lambda 간접 호출

Step Functions는 Amazon States Language (ASL) 에서 직접 특정 AWS 서비스를 제어할 수 있습니다. 자세한 내용은 다른 서비스와 함께 사용 및 파라미터를 서비스 API에 전달 섹션을 참조하세요.

최적화된 Lambda 통합이 Lambda SDK 통합과 다른 점 AWS

• 응답 Payload 필드는 이스케이프된 Json에서 Json으로 파싱됩니다.

• 응답에 FunctionError 필드가 포함되어 있거나 Lambda 함수 내에서 예외가 발생하면 작업이 실패합니다.

상태 입력, 출력, 결과 관리에 대한 자세한 내용은 Step Functions에서 입력 및 출력 처리 단원을 참조하십시오.

지원되는 API: AWS Lambda

• Invoke

  • 요청 구문

  • 지원되는 파라미터

    • ClientContext

    • FunctionName

    • InvocationType

    • Qualifier

    • Payload

  • 응답 구문

참고

네이티브 서비스 Step Functions API가 PascalCase CamelCase인 경우에도 의 파라미터는 로 표현됩니다. 예를 들어 Step Functions API 작업 startSyncExecution을 사용하고 해당 파라미터를 StateMachineArn으로 지정할 수 있습니다.

다음에는 Lambda 함수를 간접적으로 호출하는 Task 상태가 포함됩니다.

{  
   "StartAt":"CallLambda",
   "States":{  
      "CallLambda":{  
         "Type":"Task",
         "Resource":"arn:aws:states:::lambda:invoke",
         "Parameters":{  
            "FunctionName":"arn:aws:lambda:us-east-1:123456789012:function:MyFunction"
         },
         "End":true
      }
   }
}

다음에는 콜백 서비스 통합 패턴을 구현하는 Task 상태가 포함됩니다.

{  
   "StartAt":"GetManualReview",
   "States":{  
      "GetManualReview":{  
         "Type":"Task",
         "Resource":"arn:aws:states:::lambda:invoke.waitForTaskToken",
         "Parameters":{  
            "FunctionName":"arn:aws:lambda:us-east-1:123456789012:function:get-model-review-decision",
            "Payload":{  
               "model.$":"$.new_model",
               "token.$":"$$.Task.Token"
            },
            "Qualifier":"prod-v1"
         },
         "End":true
      }
   }
}

Lambda 함수를 간접적으로 호출하면 함수가 완료될 때까지 실행이 대기합니다. 콜백 작업으로 Lambda 함수를 간접적으로 호출하면 Lambda 함수가 실행을 완료하고 결과를 반환할 때까지 하트비트 제한 시간이 계산되지 않습니다. Lambda 함수가 실행되는 동안에는 하트비트 제한 시간이 적용되지 않습니다.

다음 예제와 같이 InvocationType 파라미터를 사용하여 Lambda를 비동기적으로 호출할 수도 있습니다.

참고

Lambda 함수의 비동기 호출의 경우 하트비트 제한 시간이 즉시 시작됩니다.

{

  "Comment": "A Hello World example of the Amazon States Language using Pass states",
  "StartAt": "Hello",
  "States": {
    "Hello": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Parameters": {
        "FunctionName": "arn:aws:lambda:us-east-1:123456789012:function:echo",
        "InvocationType": "Event"
      },
      "End": true
    }
  }
}             

Task 결과가 반환되면 함수 출력이 메타데이터 사전 내에서 중첩됩니다. 예:

{

   "ExecutedVersion":"$LATEST",
   "Payload":"FUNCTION OUTPUT",
   "SdkHttpMetadata":{
      "HttpHeaders":{
         "Connection":"keep-alive",
         "Content-Length":"4",
         "Content-Type":"application/json",
         "Date":"Fri, 26 Mar 2021 07:42:02 GMT",
         "X-Amz-Executed-Version":"$LATEST",
         "x-amzn-Remapped-Content-Length":"0",
         "x-amzn-RequestId":"0101aa0101-1111-111a-aa55-1010aaa1010",
         "X-Amzn-Trace-Id":"root=1-1a1a000a2a2-fe0101aa10ab;sampled=0"
      },
      "HttpStatusCode":200
   },
   "SdkResponseMetadata":{
      "RequestId":"6b3bebdb-9251-453a-ae45-512d9e2bf4d3"
   },
   "StatusCode":200
}

또는 함수 ARN을 “리소스” 필드에 직접 지정하여 Lambda 함수를 간접적으로 호출할 수 있습니다. 이런 방식으로 Lambda 함수를 간접적으로 호출할 때는 .waitForTaskToken을 지정할 수 없으며 작업 결과에 함수 출력만 포함됩니다.

{  
   "StartAt":"CallFunction",
   "States":{  
      "CallFunction": {  
         "Type":"Task",
         "Resource":"arn:aws:lambda:us-east-1:123456789012:function:HelloFunction",
         "End": true
      }
   }
}     

Resource 필드의 ARN에서 해당 옵션을 지정하여 특정 Lambda 함수 버전 또는 별칭을 간접적으로 호출할 수 있습니다. Lambda 설명서에서 다음을 참조하세요.

• AWS Lambda 버전 관리

• AWS Lambda 별칭

다른 AWS 서비스와 Step Functions 함께 사용할 때 IAM 권한을 구성하는 방법에 대한 자세한 내용은 을 참조하십시오통합 서비스용 IAM 정책.