SQS事件触发场景下如何对Lambda执行速率进行限流

以下是无需在Lambda代码中添加sleep休眠即可实现限流的可行方案，完全适配下游组件的流量承载上限需求：

方案1：使用EventBridge Pipes原生限流（最简便） #

这是云厂商官方提供的无代码限流方案，直接在中间件层实现调用速率控制：

• 源端选择你当前对接Lambda的SQS队列，保留原来的批量大小、消息过滤等原有配置
• 目标端选择对应的Lambda函数
• 在配置页的附加设置-限流项下，直接设置Invocations per minute为你需要的阈值，例如填写10即可实现每分钟最多触发10次Lambda的效果
• 无需调整Lambda原有预留并发、事件源映射配置，业务代码零修改

方案2：基于SQS事件源映射参数调整实现 #

如果你不想引入额外服务，可以结合现有配置做优化：

• Lambda SQS事件源映射现在支持配置Maximum concurrency参数，你可以配合消息可见性超时控制单位时间调用量：比如要实现每分钟10次调用，可设置Maximum concurrency = 1，同时将SQS消息默认可见性超时设置为6秒，这样单并发下每次处理完要等6秒才会拉取下一条消息，天然控制在每分钟10次的速率
• 如果需要更灵活的阈值调整，可通过API/SDK动态修改Maximum concurrency和可见性超时参数，适配不同时间段的限流要求

方案3：定时触发+主动拉取消息模式 #

如果你的业务允许一定的处理延迟，可以把触发模式从SQS被动触发改成主动拉取：

• 移除原来的SQS事件源映射
• 创建EventBridge定时规则，按你需要的频率触发Lambda：比如要每分钟调用10次，可设置规则为rate(6 seconds)
• Lambda被触发后主动调用SQS的ReceiveMessage接口拉取1条消息处理，完成后直接返回
• 该模式下调用频率完全由定时规则控制，不会出现突发调用的情况

以上方案均不需要占用Lambda运行时间做休眠，避免浪费函数算力、产生额外费用。

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