使用Step Functions 调用 Lambda - Amazon Step Functions
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

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

使用Step Functions 调用 Lambda

Step Functions 可以控制某些Amazon直接从亚马逊状态语言提供的服务。有关使用的更多信息Amazon Step Functions及其集成，请参阅以下内容：

优化的 Lambda 集成与 Lambda 集成有何不同AmazonSDK 集成

  • 这些区域有：Payload响应的字段从转义的 Json 解析为 Json。

  • 响应包含字段FunctionError，任务将失败。

有关管理状态输入、输出和结果的更多信息，请参阅Step Functions 中输入和输出的处理。

支持的 Amazon Lambda API：

下面这个状态Task状态，调用 Lambda 函数。

{  
   "StartAt":"CallLambda",
   "States":{  
      "CallLambda":{  
         "Type":"Task",
         "Resource":"arn:aws:states:::lambda:invoke",
         "Parameters":{  
            "FunctionName":"MyFunction"
         },
         "End":true
      }
   }
}

下面这个状态Task实现了回调服务集成模式。

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

当您调用 Lambda 函数时，执行将等待该函数完成。如果您通过回调任务调用 Lambda 函数，则在 Lambda 函数完成执行并返回任务令牌后，心跳超时才会开始计数。只要执行 Lambda 函数，就不会强制执行心跳超时。

还可以使用异步调用 LambdaInvocationType参数，如下面的示例所示：

注意

对于 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": "echo",
        "InvocationType": "Event"
      },
      "End": true
    }
  }
}

当Taskresult，则函数输出嵌套在元数据字典中。例如：

{

   "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
      }
   }
}

通过在 ARN 中指定相应选项，您可以调用特定 Lambda 函数版本或别名Resource字段中返回的子位置类型。请参阅 Lambda 文档中的以下内容：

有关在将步骤函数与其他函数一起使用时如何配置 IAM 的信息Amazon服务，请参阅集成服务的 IAM 政策.