SendGrid 大批量邮件发送的最佳实践：REST API 批量提交方案-Golang-PHP中文网

对于日均数十万级的已渲染邮件发送场景，优先采用 sendgrid 的 v3 rest api 批量接口（/mail/send），单次请求最多携带 1000 封个性化邮件，显著优于 smtp 或单封 rest 请求的吞吐量与稳定性。

对于日均数十万级的已渲染邮件发送场景，优先采用 sendgrid 的 v3 rest api 批量接口（/mail/send），单次请求最多携带 1000 封个性化邮件，显著优于 smtp 或单封 rest 请求的吞吐量与稳定性。

在高吞吐邮件投递场景中（如您描述的 600,000 封已渲染完成的邮件），性能瓶颈往往不在模板渲染，而在于传输层协议与请求编排策略。SendGrid 明确支持两种主流通道：SMTP 和 v3 REST API。但二者在大规模、高并发场景下的表现差异显著：

SMTP 方式：虽协议成熟、兼容性强，但受限于连接建立开销、TLS 握手延迟及每连接串行发送限制。实测典型吞吐约为 2–5 封/秒（单连接），即使启用连接池与多线程，也难以突破百级并发瓶颈，且连接管理复杂、失败重试逻辑冗余。
REST API 单封调用：看似灵活，但 600k 次 HTTP 请求将带来巨大 TCP 连接复用压力、DNS 查询开销及 API 网关排队延迟；即便使用 goroutines 并发（如 100 协程 × 6000 次请求），仍面临 Rate Limit（默认 1200 TPS）、HTTP 超时、错误聚合难等问题，整体耗时可能达数小时。

Wordpress REST API
OpenClaw技能，提供WordPress REST API命令行工具，支持通过原生HTTP处理文章、页面、分类、标签、用户及自定义请求。

下载

✅ 推荐方案：v3 REST API 批量提交（Batching）
SendGrid v3 /mail/send 接口原生支持「单请求多收件人 + 多个性化内容」模式。关键优势包括：

✅ 单次 POST 最多可包含 1000 封独立邮件（每个 personalizations[i] 对应唯一收件人及定制化内容）；
✅ 全部邮件共享同一 from, subject, content 模板，但 personalizations 中可指定 to, substitutions, dynamic_template_data 等差异化字段；
✅ 实测单请求平均耗时 3–8 分钟内完成提交；
✅ 自动享受 SendGrid 后端智能分发、IP 池轮转、送达率优化等能力，无需自行维护队列或重试机制。

? 示例：Go 中构造批量请求体（精简核心结构）

type SendGridBatchRequest struct {
    From        map[string]string          `json:"from"`
    Subject     string                     `json:"subject"`
    Content     []map[string]string        `json:"content"`
    Personalizations []Personalization     `json:"personalizations"`
}

type Personalization struct {
    To                []map[string]string `json:"to"`
    DynamicTemplateData map[string]interface{} `json:"dynamic_template_data"`
}

// 构建含 500 封邮件的批次（实际建议 800–1000 封/批以平衡成功率与内存）
batch := SendGridBatchRequest{
    From:    map[string]string{"email": "noreply@yourapp.com"},
    Subject: "Welcome to Our Service",
    Content: []map[string]string{{"type": "text/html", "value": ""}},
    Personalizations: make([]Personalization, 0, 500),
}

for _, user := range users[:500] {
    batch.Personalizations = append(batch.Personalizations, Personalization{
        To: []map[string]string{{"email": user.Email}},
        DynamicTemplateData: map[string]interface{}{
            "name":     user.Name,
            "campaign": "q3_welcome",
            "link":     user.DashboardURL,
        },
    })
}

// 使用 http.Client（启用连接复用、超时控制）发送
resp, err := client.Post("https://api.sendgrid.com/v3/mail/send",
    "application/json",
    bytes.NewBuffer(mustJSON(batch)))

⚠️ 注意事项：