微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Stepfunction 将 lambdas 的输出传递给另一个 lamabda

如何解决Stepfunction 将 lambdas 的输出传递给另一个 lamabda

我有一个步进函数状态机,它有 3 个 lambda,例如 lambda_aLambda_blambda_c

lambda_c 需要来自 lambda_alambda_b 的输入 lambda_alambda_b 都返回有效负载作为回报,lambda_c 期望这些有效负载作为输入。 他们像这样调用/链接: lambda_a

lambda_a_step = sfn_tasks.LambdaInvoke(self,'lambda_a',lambda_function=lambda_a_function,payload_response_only=True,result_path='$.lambda_a.Payload')

Lambda_b

lambda_a_step = sfn_tasks.LambdaInvoke(self,'lambda_b',lambda_function=lambda_b_function,result_path='$.lambda_b.Payload')

来自 lambda 的两个示例输出负载如下所示:

{
  "Comment": "Insert your JSON here","lambda_a": {
    "Payload": {
      "result": "succeeded","start_date": "20210419 11:50:55","finish_date": "20210419 11:51:00","reason": "No errors found in the log file"
    }

如何将完整的负载从 lambda_a 和 lambda_b 传递到我的 lambda_c?即 lambda_c 应该从 lambda_a.payload 和 lambda_b.Payload 获取输入

在执行输出中,我可以看到两个有效载荷。但是如何将这 2 个有效载荷传递给我的 lambda_c?

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。