如何在AWS中限制Lambda调用次数？FIFO SQS触发场景每小时仅处理200条

针对FIFO SQS触发Lambda、需将处理速率限制为每小时200条的需求，以下是几种架构层面的解决方案：

方案一：Lambda触发配置+执行延迟控制 #

• 调整Lambda的SQS触发器设置：将批量大小设为1，最大并发数设为1，确保同一时间仅处理一条消息
• 在处理Lambda的逻辑中加入固定延迟：按每小时200条计算，每条消息的处理间隔需约18秒（3600秒/200条），处理完消息后添加17-18秒的延迟（预留少量处理耗时缓冲），这样每小时刚好处理200条
• 同时设置SQS消息的可见性超时为25秒左右，避免消息被其他进程重复拉取

方案二：CloudWatch Events调度层解耦触发与处理 #

• 暂停原FIFO SQS到Lambda的直接触发关系
• 创建CloudWatch Events定时规则：按固定频率触发调度Lambda，频率设为每18秒一次（对应每小时200次）
• 调度Lambda每次从FIFO SQS拉取1条消息（通过SQS API指定批量大小1），再调用原处理Lambda完成消息处理（或直接在调度Lambda中集成处理逻辑）
• 该方案通过定时调度严格控制处理频次，速率精度更高，且解耦了队列触发与业务处理逻辑

方案三：FIFO队列消息延迟分组（适合长期速率管控） #

• 新建一个FIFO SQS队列，保留与原队列相同的分组规则
• 将原队列中50000条消息批量迁移至新队列，为每条消息设置递增的延迟时间：第1条延迟0秒，第2条延迟18秒，第3条延迟36秒……以此类推，确保消息按18秒间隔依次进入可处理状态
• 配置新队列触发原Lambda，设置批量大小1、最大并发1，消息会按延迟时间依次被处理，刚好符合每小时200条的速率要求
• 后续新消息进入队列时，同样按规则设置延迟时间，长期维持速率限制

内容的提问来源于stack exchange，提问作者Marcelo Gazzola