AWS Step Functions中的直通输入到输出

Question

如何Task将AWS Step Functions中的状态输入传递给输出？

阅读AWS文档中的输入和输出处理页面后,我使用了各种组合InputPath,ResultPath和OutputPath.

州定义:

"First State": {
    "Type": "Task",
    "Resource": "[My Lambda ARN]",
    "Next": "Second State",
    "InputPath": "$.someKey",
    "OutputPath": "$"
}

输入:

{
    "someKey": "someValue"
}

预期结果

我希望输出First State(以及输入Second State)

{
    "someKey": "someValue"
}

实际结果

[empty]

---

如果输入更复杂,例如

{
    "firstKey": "firstValue",
    "secondKey": "secondValue"
}

我想转发所有这些而不用担心(子)路径.

Answer 1

在亚马逊国家语言中,声明:

如果ResultPath的值为null,则意味着将丢弃状态自身的原始输出,并且其原始输入将成为其结果.

因此,我将我的州定义更新为

"First State": {
    "Type": "Task",
    "Resource": "[My Lambda ARN]",
    "Next": "Second State",
    "ResultPath": null
}

因此,当传递输入示例时,Task输入有效负载将被复制到输出,即使对于富对象,例如:

{
    "firstKey": "firstValue",
    "secondKey": "secondValue"
}

Answer 2

对于那些使用 CDK 的人来说，解决方案是使用显式aws_stepfunctions.JsonPath.DISCARD枚举而不是 None/null。

from aws_cdk import (
    aws_stepfunctions,
    aws_stepfunctions_tasks,
)

aws_stepfunctions_tasks.LambdaInvoke(
    self,
    "my_function",
    lambda_function=lambda_function,
    result_path=aws_stepfunctions.JsonPath.DISCARD,
)

https://docs.aws.amazon.com/cdk/api/latest/docs/@aws-cdk_aws-stepfunctions.JsonPath.html#static-discard