如何确保SNS主题每条消息单独触发一次Lambda函数？

问题原因 #

SNS默认开启批量交付功能，会把短时间内收到的多条消息打包成一个事件发送给Lambda。如果你的Lambda代码只处理了事件中的最后一条消息，就会出现前面的消息被覆盖、无法推送到Slack的情况。

解决方案 #

方案1：修改SNS订阅的批量设置（推荐） #

直接让SNS每条消息单独触发Lambda：

• 打开AWS SNS控制台，找到对应的主题，进入订阅列表
• 点击目标Lambda订阅的详情，找到「批量交付」配置项
• 将批量大小（Batch size）设置为1，同时把批量窗口（Batch window）设为0
• 保存设置后，每条SNS消息都会单独触发一次Lambda调用，从根源避免消息被覆盖

方案2：调整Lambda代码适配批量消息 #

如果需要保留批量交付功能，修改代码遍历所有消息进行处理：
以Python为例，修正后的代码逻辑如下：

import json
import requests

def lambda_handler(event, context):
    # 遍历事件中的所有SNS记录
    for record in event['Records']:
        # 解析SNS消息体
        sns_msg_content = json.loads(record['Sns']['Message'])
        fruit_name = sns_msg_content.get('fruit')
        
        # 发送到Slack的逻辑（替换为你的Webhook地址）
        slack_data = {"text": f"收到水果：{fruit_name}"}
        requests.post("你的Slack Webhook URL", json=slack_data)
    
    return {'statusCode': 200, 'body': json.dumps('所有消息处理完成')}

验证效果 #

修改完成后，发送3条测试消息：

• 若用方案1，查看Lambda执行日志会看到3次独立的调用记录
• 若用方案2，会看到1次调用但处理了3条消息
• 最终Slack频道会收到所有3条消息对应的fruit值

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