aws步进函数使用cdk设置资源数据

Question

嗨，我正在使用python cdk创建一个步进函数，我的步进函数代码看起来像这样:

state_machine = sfn.StateMachine(
self,
"MyStateMachine",
definition=tasks.LambdaInvoke(
self,
"MyLambdaTask",
lambda_function=hello_function
).next(
sfn.Succeed(
self,
"GreetedWorld"
)
)
)

这里我想添加这个配置来等待使用python cdk:

，因为我直接在aws仪表板中编辑状态机json中添加了这个配置

"Resource": "arn:aws:states:::lambda:invoke.waitForTaskToken",

希望使用python CDK添加这行代码。不能找到方法添加这个

Answer 1

根据我的理解，您希望异步调用Lambda函数并等待响应令牌。

要在CDK中做到这一点，您可以为LambdaInvoke操作指定集成类型，并将令牌传递给处理程序:

state_machine = sfn.StateMachine(
self,
"MyStateMachine",
definition=tasks.LambdaInvoke(
self,
"MyLambdaTask",
lambda_function=hello_function,
integration_pattern=tasks.IntegrationPattern.WAIT_FOR_TASK_TOKEN,
payload={"token.$":"$$.Task.Token"},
).next(
sfn.Succeed(
self,
"GreetedWorld"
)
)
)

引用:

https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html connect-wait-token

https://docs.aws.amazon.com/cdk/api/v2/docs/aws-cdk-lib.aws_stepfunctions_tasks.LambdaInvoke.html integrationpattern