AWS Step Functions：将任务输入与部分任务输出相结合

Question

我正在处理 AWS Step 函数。我已经阅读了 InputPath, OutputPath, and ResultPath 上的文档。我的问题是，我想将来自输入的值组合到 Lambda 任务，并从任务中获得 部分输出 。

任务的输入类似于下面。我想继续将这些值传递给后续任务。

{
    "previous_task_result": 100,
    "next_task_input": "asdf"
}

我想要的是让我的 Lambda 任务的输出如下所示：

{
    "previous_task_result": 100,
    "next_task_input": "asdf",
    "current_task_result": {
        "val1": "ghjk",
        "val2": [0,2,13,100]
    }
}

具体问题是 Lambda 任务的原始输出看起来像这样。我只关心 Payload 节点。其余输出是样板，我不想通过阶跃函数。

{
  "resourceType": "lambda",
  "resource": "invoke",
  "output": {
    "ExecutedVersion": "$LATEST",
    "Payload": {
        "val1": "ghjk",
        "val2": [0,2,13,100]
    },
    "SdkHttpMetadata": {
      "HttpHeaders": {
        "Connection": "keep-alive",
        "Content-Length": "42",
        "Content-Type": "application/json",
        "Date": "Tue, 25 Feb 2020 14:36:29 GMT",
        "X-Amz-Executed-Version": "$LATEST",
        "x-amzn-Remapped-Content-Length": "0"
      },
      "HttpStatusCode": 200
    },
    "SdkResponseMetadata": {
      "RequestId": "redacted"
    },
    "StatusCode": 200
  }
}

我知道如何使用ResultPath和OutputPath来合并输入和输出，或者将输出分配给特定的节点，但是我找不到合并的方法只是结果中现有输入的 Payload 节点。

Answer 1

使用 Lambda 任务状态时，您可以通过 3 种方式构建任务状态：

1.请求响应：

此方法 return 是包含 SdkHttpMetadata 字段的完整 API 响应。我怀疑 return 完整 HTTP 响应的原因是因为这是您可以从 Step Function 异步调用 Lambda 函数的唯一方法（异步 Lambda 调用仅 return 状态代码）。示例：

"CallLambda": {
    "Type": "Task",
    "Resource": "arn:aws:states:::lambda:invoke",
    "Parameters": {
        "FunctionName": "MyFunction",
        "InvocationType": "Event|RequestResponse|DryRun",
        "Payload.$": "$"
    },
    "End": true
}

2。 Lambda ARN 作为资源：

我相信这就是您要找的。将 Lambda 函数的 ARN 指定为资源时，Step Functions 将同步调用您的 Lambda 函数，并且 return 仅调用您的 Lambda 函数的结果而没有 API 响应元数据。在这种情况下，您的状态输入将作为有效载荷传递给您的 Lambda 函数，或者您可以使用 InputPath/Parameters 到 filter/modify 作为有效载荷发送的数据。

"CallLambda": {
    "Type": "Task",
    "Resource": "arn:aws:lambda:us-west-2:123456789012:function:my-function",
    "ResultPath": "$.current_task_result",
    "End": true
}

使用您示例中的输入，上述任务将为您提供如下输出：

{
    "previous_task_result": 100,
    "next_task_input": "asdf",
    "current_task_result": {
        <Your Lambda Functions Result>
    }
}

3。 .WaitForTaskToken:

将令牌传递给您的函数，暂停执行直到收到对 SendTaskSuccess 或 SendTaskFailed 的调用（此方法只会 return 来自 SendTaskSuccess 或 SendTaskFailed 的 Result/Error，无需额外的 HTTP元数据）。

"CallLambda": {
    "Type": "Task",
    "Resource":"arn:aws:states:::lambda:invoke.waitForTaskToken",
    "Parameters": {
        "FunctionName": "MyFunction",
        "Payload":{  
           "token.$":"$$.Task.Token"
        }
    },
    "End": true
}

Answer 2

对于现在发现它的任何人，ResultSelector（截至 8/2020 的新功能）完全执行我在发布时寻找的功能。

InputPath, Parameters and ResultSelector

AWS Step Functions：将任务输入与部分任务输出相结合

AWS Step Functions: Combine task input with partial task output

amazon-web-services

aws-lambda