能否使用AWS Step Functions等待多SQS事件及DynamoDB记录存在后执行业务逻辑?
订单事件整合实现需求
拟议架构
(原含架构图展示)
现有资源与事件流
- 资源:2个SQS队列、1个Lambda函数
- 事件接收规则:
- SQS流1:接收客户邮箱和交易ID订单事件
- SQS流2:接收订单商品信息订单事件
- Lambda函数:负责在数据库中创建客户记录
期望实现逻辑
使用AWS Step Functions捕获SQS流1的订单事件,等待以下两个条件满足:
- 对应订单的SQS流2事件已到达
- 数据库中该客户的记录已存在
待所有条件达成后,基于整合后的流1、流2数据以及客户记录执行业务逻辑
内容的提问来源于stack exchange,提问作者TonyDMorris
相关产品推荐
相关产品推荐

