如何实现AWS SQS每隔N秒出队一条消息触发AWS Lambda？

针对你遇到的标准队列批量消息同时触发Lambda的问题，结合下游API的低速率限制，给你几个可行的解决思路：

方案一：Lambda并发控制+单条拉取+代码内延迟 #

• 给你的Lambda设置预留并发数为1，确保同一时间只会有一个Lambda实例在运行，避免多实例同时处理消息
• 配置SQS到Lambda的触发器，把批量大小设为1，让Lambda每次只从队列拉取一条消息
• 在Lambda业务代码的最后，添加3秒的延迟（比如Python用time.sleep(3)，Node.js用await new Promise(resolve => setTimeout(resolve, 3000))），处理完当前消息后等待3秒再结束函数，保证下一条消息的处理间隔符合要求

注意：要把Lambda的超时时间设置得足够长，比如如果有100条消息、每条处理+等待共5秒的话，超时至少要设为500秒以上，避免函数中途被终止。

方案二：用EventBridge调度+主动拉取消息 #

如果不想依赖Lambda的并发限制，可以单独做一套调度逻辑：

• 创建一个CloudWatch Events（EventBridge）规则，设置每隔3秒触发一次调度Lambda
• 调度Lambda的逻辑很简单：调用SQS的ReceiveMessage接口拉取1条消息，然后直接调用处理业务的Lambda（或者在调度Lambda里直接处理业务）
• 处理完成后，调用SQS的DeleteMessage接口删除已处理的消息

这种方式完全由你控制消息的处理间隔，不受SQS默认触发机制影响，适合对间隔精度要求高的场景。

补充说明 #

如果可以切换到FIFO队列的话，FIFO队列的消息分组ID特性可以保证同一分组内的消息按顺序处理，再配合Lambda批量大小1和代码内延迟，也能实现类似效果，但你目前用的是标准队列，上面两个方案更直接。

内容的提问来源于stack exchange，提问作者Fernando Baladi