如何实现仅每月1日从FIFO SQS轮询消息的Lambda函数？

当然可以实现，核心是放弃Lambda与SQS的持续事件源映射，改用定时触发+主动轮询的方式，既满足需求又能节约非必要的轮询成本，具体方案如下：

具体步骤 #

1. 不要用SQS事件源映射关联Lambda #

默认的SQS事件源映射会让Lambda持续轮询队列，哪怕队列是空的也会产生调用开销，所以直接跳过这种方式。

2. 用EventBridge定时触发处理Lambda #

创建EventBridge规则，设置为每月1日触发（比如凌晨0点开始），触发目标就是你的消息处理Lambda。

• 示例Cron表达式：0 0 1 * ? *（每月1日凌晨0点触发一次）
• 如果需要当天内多次轮询确保消息处理完，可以改成每小时触发一次：0 0/60 1 * ? *

3. 在Lambda里主动轮询并处理消息 #

在Lambda代码里主动调用SQS的ReceiveMessage接口拉取消息，处理完成后调用DeleteMessage删除，同时满足你的要求：

• 每条消息独立调用：拉取时设置MaxNumberOfMessages=1，每次只处理一条，处理完就结束本次Lambda调用，下一次触发再处理下一条
• 并发限制为1：直接在Lambda配置里把并发数设为1，确保同一时间只有一个实例在跑
• 仅每月第一天轮询：只有EventBridge在每月1日触发Lambda，其他时间Lambda不会启动，自然不会去轮询队列

4. 适配FIFO队列特性 #

因为是FIFO队列，处理时注意这两点：

• 拉取消息时开启长轮询（设置WaitTimeSeconds=20），减少空轮询的次数
• 由于并发限制为1，天然能保证同MessageGroupId的消息按顺序处理，符合FIFO队列的要求

额外优化 #

• 如果消息量多，可以调整EventBridge的触发频率，比如每30分钟触发一次，配合并发限制1，实现串行处理所有消息
• 加个错误处理：处理失败的消息可以利用SQS的可见性超时自动放回队列，或者配置死信队列存处理不了的消息

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