我有一个Step Function State Machine
,它在流中执行一些lambda。
我只想在上传流所需的10个文件后运行状态机,这是棘手的部分
- 在S3 bucket中手动上传10个文件
- S3上传触发向EventBridge的通知(需要等待所有新的CSV上传(
- EventBridge启动状态机
我认为我的当前流将不起作用,因为它将为每个文件上传调用状态机10次。。。
我知道如何使用S3文件上传来触发状态机,就像本例中一样,但我不知道如何确保在触发状态机一次之前上传所有文件。
这有可能实现吗?有什么想法吗?
我认为我当前的流将不起作用,因为它将为每个文件上传调用状态机10次
没错。每次上传对象时,S3事件都会触发EventBridge,它将调用step函数。
要实现所需的工作流,请使用lambda函数替换EventBridge规则。让lambda函数检查bucket的总大小,如果满足条件(已上传10个文件(,则直接调用Step函数。