如何使用 AWS CDK 中的 InvokeLambda 将 JSON 传递给 AWS StepFunction 中的 lambda

如何解决如何使用 AWS CDK 中的 InvokeLambda 将 JSON 传递给 AWS StepFunction 中的 lambda

我认为有效负载需要对象，但我找不到任何帮助以及如何在 AWS StepFunction 中将 JSON 传递给 Lambda

create_group = tasks.LambdaInvoke(
            self,"CreateGroup",lambda_function=notification_lambda,payload={
                "Input.$": "$","Stage": "CreateGroup","token.$": "$$.Task.Token","callback": "true"
            },result_path='$',timeout=Duration.seconds(300)
        )

这是我合成时遇到的错误

jsii.errors.JavaScriptError: 
  Error: Expected object reference,got {"$jsii.map":{"Input.$":"$","Stage":"CreateGroup","token.$":"$$.Task.Token","callback":"true"}}

解决方法

尝试使用 JSON.stringify 将其解析为 json 字符串。 我正在将 json.dumps 用于我的 python 实现，它执行相同的操作并且可以正常工作。

,

您可以像这样将 json 传递给 LambdaInvoke

from aws_cdk import (
    core,aws_stepfunctions_tasks as tasks,aws_stepfunctions as sf
)

hello_task: tasks.LambdaInvoke = tasks.LambdaInvoke(
    self,"[Lambda] hello",lambda_function=hello_lambda,result_path="$.helloLambda")

sample_task: tasks.LambdaInvoke = tasks.LambdaInvoke(
    self,"[Lambda] world",lambda_function=world_lambda,payload=sf.TaskInput.from_json_path_at("$.helloLambda.Payload"))