Lambda与SQS通过事件源映射集成：批量处理部分失败的解决方案

核心解决方案是利用Lambda的**部分批量响应（Partial Batch Response）**机制，这是AWS官方为批量处理场景设计的原生能力，无需手动重新发送消息到队列，就能精准控制哪些失败消息重新入队。

具体实现步骤 #

1. 启用Event Source Mapping的批量失败报告功能 #

在你的Lambda与SQS的Event Source Mapping（ESM）配置中，开启ReportBatchItemFailures选项：

• 控制台操作：找到对应的ESM配置，勾选"Report batch item failures"；
• AWS CLI命令：

aws lambda update-event-source-mapping --uuid <你的ESM唯一ID> --report-batch-item-failures

2. 修改Lambda代码，返回失败消息ID列表 #

在Lambda处理逻辑中，收集所有处理失败的消息的messageId，并按照指定格式返回给AWS。这样ESM会自动将这些标记为失败的消息重新放回SQS队列，而成功处理的消息会被正常删除。

示例Python代码：

def lambda_handler(event, context):
    failed_item_ids = []
    
    for record in event["Records"]:
        message_id = record["messageId"]
        try:
            # 替换为你的实际消息处理逻辑
            process_sqs_message(record["body"])
        except Exception as err:
            # 记录错误日志，同时收集失败的消息ID
            print(f"处理消息{message_id}失败: {str(err)}")
            failed_item_ids.append({"itemIdentifier": message_id})
    
    # 返回部分批量响应结果
    return {
        "batchItemFailures": failed_item_ids
    }

3. 逻辑有效性说明 #

当Lambda返回上述格式的响应后，ESM会：

• 删除所有未出现在batchItemFailures中的消息；
• 将标记为失败的消息的可见性超时重置，使其重新回到队列待处理；
• 不会因为部分失败而让整批消息重新入队，避免重复处理已成功的消息。

额外注意点 #

该机制完全适配你当前的配置（可见性超时60秒、批量大小10），只要Lambda在可见性超时到期前返回响应，就能正常触发批量失败处理；无需额外维护消息重发逻辑，完全依赖AWS原生的事件源映射能力，稳定性更高。

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