问题描述
我有一个步进函数状态机,它有 3 个 lambda,例如
lambda_a
,
Lambda_b
和lambda_c
lambda_c
需要来自 lambda_a
和 lambda_b
的输入
lambda_a
和 lambda_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')
{
"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 (将#修改为@)