AWS SQS 的 DeleteMessageBatch 操作支持部分成功：即使部分消息删除失败，API 仍返回 HTTP 200，需通过响应中的 Failed 字段解析具体失败的 MessageId 及原因，而非依赖错误（err）字段。
aws sqs 的 `deletemessagebatch` 操作支持部分成功：即使部分消息删除失败，api 仍返回 http 200，需通过响应中的 `failed` 字段解析具体失败的 messageid 及原因，而非依赖错误（err）字段。
在使用 AWS SDK for Go 进行 SQS 消息批量删除时，一个常见误区是认为 err != nil 才表示有消息未被删除。实际上，SQS 的 DeleteMessageBatch 是幂等且容错的批量操作：只要请求格式合法、队列权限正确，API 总是返回 HTTP 200 状态码，并在响应体中明确区分成功与失败项——无论是否有消息删除失败，err 都可能为 nil。
真正判断哪些消息未被删除，应检查响应结构 *sqs.DeleteMessageBatchResponse 中的 Failed 字段：
deleteMessagesParams := &sqs.DeleteMessageBatchInput{
Entries: messagesToDelete,
QueueUrl: aws.String(QUEUE_URL),
}
resp, err := svc.DeleteMessageBatch(deleteMessagesParams)
if err != nil {
// 此处 err 表示网络异常、认证失败、参数校验不通过等严重错误
log.Printf("Critical error during batch delete: %v", err)
return
}
// ✅ 关键：即使 err == nil，仍需检查 resp.Failed
if len(resp.Failed) > 0 {
log.Printf("Found %d failed deletions:", len(resp.Failed))
for _, fail := range resp.Failed {
log.Printf("- MessageId: %s, Code: %s, Message: %s",
aws.StringValue(fail.Id),
aws.StringValue(fail.Code),
aws.StringValue(fail.Message),
)
}
} else {
log.Println("All messages deleted successfully.")
}
resp.Failed 是 []*sqs.BatchResultErrorEntry 类型，每个元素包含：
- Id: 对应请求中 DeleteMessageBatchRequestEntry.Id（建议设置为唯一标识，如 msg.ReceiptHandle 的哈希或序号）；
- Code: 错误码（如 "AWS.SimpleQueueService.NonExistentQueue"、"AWS.SimpleQueueService.InvalidParameterValue"）；
- Message: 人类可读的失败原因；
- SenderFault: 布尔值，指示是否为客户端错误（如无效 ReceiptHandle）。
⚠️ 注意事项：
- Entries 中每条 DeleteMessageBatchRequestEntry 的 Id 字段必须唯一，否则响应中无法准确映射失败项；
- ReceiptHandle 过期、已被删除或不属于当前队列，均会导致单条失败，但不影响其他消息；
- 不要忽略 Failed 列表——未处理的失败项可能导致消息重复消费（因未真正删除）；
- 生产环境建议对 Failed 中的失败项进行重试（注意幂等性）或记录告警。
总结：SQS 批量删除的健壮性依赖于主动解析 resp.Failed，而非被动等待 err。这是 AWS 批量 API 的通用设计模式（同样适用于 SendMessageBatch、ChangeMessageVisibilityBatch 等），掌握该模式是构建高可靠消息处理系统的关键基础。
