如何在AWS SES中高效发送超发送速率限制的大量邮件

1. 高效发送大量邮件并避免拒信/退信的方案 #

核心思路是流量削峰+配额适配+合规配置，结合AWS服务实现稳定发送：

• 用**SQS（简单队列服务）**做任务缓冲：将所有待发送的邮件任务（含收件人、内容、参数等）分批写入SQS队列，避免直接一次性调用SES触发速率限制。
• 用Lambda/ECS做队列消费者，严格匹配SES配额：根据SES每秒100封的发送速率，配置消费者的并发数和批量处理大小。比如设置Lambda批量大小为100、并发数为1，确保每秒仅处理100封；若需更快完成，可在SES单日限额允许范围内调整并发数。
• 配置SES合规项：确保发送域名完成DKIM、SPF、DMARC验证，使用SES配置集开启发送行为监控，同时避免邮件内容包含垃圾邮件特征（如敏感关键词、虚假标题）。
• 用CloudWatch监控发送指标：实时追踪SES发送成功率、退信率，异常时触发告警，及时调整发送策略。

2. 获取退信/被拒邮件的反馈信息 #

通过SES事件通知机制实现全链路反馈追踪：

• 创建SES配置集，开启退信（Bounce）、投诉（Complaint）、发送失败（Delivery Failure）等事件的通知功能，将这些事件推送到SNS主题。
• 订阅SNS主题到Lambda函数，把收到的反馈数据（含收件人邮箱、失败原因、时间戳等）存储到DynamoDB/RDS中，应用可直接从这些存储服务查询或同步反馈信息。
• 可选：将SES事件同步到CloudWatch Logs，通过CloudWatch Insights批量分析退信原因分布、高发问题域名等数据。

3. 能否通过Lambda/SQS实现需求？ #

完全可以，这是适配动态任务量的最优无服务器架构方案，具体流程如下：

1. 任务入队：应用将每封待发送邮件的信息（收件人、模板ID、自定义参数等）作为消息写入SQS队列，支持动态添加任务（适配不固定的待发送数量）。
2. Lambda消费发送：配置Lambda触发器为SQS队列，设置批量处理大小和并发数，确保发送速率不超过SES的100封/秒。Lambda核心逻辑示例：

import boto3

ses_client = boto3.client('ses')
sqs_client = boto3.client('sqs')

def lambda_handler(event, context):
    for record in event['Records']:
        message_body = record['body']
        # 解析邮件任务参数
        email_params = eval(message_body)
        try:
            ses_client.send_email(
                Source='your-verified-email@domain.com',
                Destination={'ToAddresses': [email_params['recipient']]},
                Message={
                    'Subject': {'Data': email_params['subject']},
                    'Body': {'Html': {'Data': email_params['content']}}
                }
            )
        except Exception as e:
            # 处理发送失败：将消息转入死信队列待后续排查
            sqs_client.send_message(
                QueueUrl='your-dead-letter-queue-url',
                MessageBody=message_body
            )
    return {'statusCode': 200}

3. 失败兜底：为SQS队列配置死信队列（DLQ），将多次发送失败的任务转入DLQ，后续可人工排查原因后重新发送。

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