利用 Resend 和 Workers 零成本实现电子邮件订阅

起因#

虽然没什么人看，但我突发奇想想要给博客加上一个电子邮件订阅系统。

最开始的想法是利用网站已有的 RSS 进行转换，因为我不怎么了解 Resend，最开始就想要找一个全自动的托管平台。

但问题就是，类似于 Mailer 这样的服务免费额度确实很大，但我们想要的最核心的功能 RSS to Email 却是收费的，那要这么大的免费额度干什么呢？

正好了解过 Resend，干脆就自己手搓一个吧。

构思设计#

Resend 功能虽然强大，但它只有发件和管理订阅者的功能，并不是一种我们想要的托管平台。想以 Resend 为核心构建系统，还缺少以下组件：

一个表单，用于收集订阅用户的邮箱
转换 RSS 到电子邮件的实现
调用 Resend API 发送邮件的服务
负责添加订阅用户的服务

因为我的博客本身是完全静态的，我不想在博客内部引入任何无服务器函数。为了系统的可扩展性和可维护性考虑，每个服务之间和每个服务与博客之间应该没有任何关联。最终，我的方案如下：

Tally 作为 Web 表单，通过 Webhook 发送信息
写一个 Python 脚本处理 RSS 转换和邮件发送
Cloudflare Workers 充当 Webhook endpoint，调用 API 向 Resend 添加订阅者
事件驱动的 GitHub Action 运行 Python 脚本

系统实现#

Resend#

这里利用了 Resend 的 Broadcasts 功能。

在注册 Resend 并添加域名后，记得添加一个 API Key，这个需要保留好，后面会用到。

同时管理订阅者也是利用了 Resend Audience 功能里的 Segment 功能实现的，下文会提到。

通过 Broadcasts API 的 Create Broadcasts 进行邮件的创建和批量发送。它的 Python API 大概长这样：

1
import resend
2

3
resend.api_key = "re_xxxxxxxxx"
4

5
// Create a draft broadcast
6
params: resend.Broadcasts.CreateParams = {
7
  "segment_id": "78261eea-8f8b-4381-83c6-79fa7120f1cf",
8
  "from": "Acme <onboarding@resend.dev>",
9
  "subject": "Hello, world!",
10
  "html": "Hi {{{FIRST_NAME|there}}}, you can unsubscribe here: {{{RESEND_UNSUBSCRIBE_URL}}}",
11
}
12
resend.Broadcasts.create(params)
13

14
// Create and send immediately
15
params: resend.Broadcasts.CreateParams = {
16
  "segment_id": "78261eea-8f8b-4381-83c6-79fa7120f1cf",
17
  "from": "Acme <onboarding@resend.dev>",
18
  "subject": "Hello, world!",
19
  "html": "Hi {{{FIRST_NAME|there}}}, you can unsubscribe here: {{{RESEND_UNSUBSCRIBE_URL}}}",
20
  "send": true,
21
}
22
resend.Broadcasts.create(params)
23

24
// Create and schedule
25
params: resend.Broadcasts.CreateParams = {
26
  "segment_id": "78261eea-8f8b-4381-83c6-79fa7120f1cf",
27
  "from": "Acme <onboarding@resend.dev>",
28
  "subject": "Hello, world!",
29
  "html": "Hi {{{FIRST_NAME|there}}}, you can unsubscribe here: {{{RESEND_UNSUBSCRIBE_URL}}}",
30
  "send": true,
31
  "scheduled_at": "in 1 hour",
32
}
33
resend.Broadcasts.create(params)

其实没这么复杂，关键的字段并不多。我的实现会在下文的 Python 脚本给出以供参考。

Python 脚本#

Python 脚本需要做的事情大概有三件：

提取 RSS 的第一个 Item
编写电子邮件内容
通过 Resend Broadcasts API 发送

1
import html
2
import requests
3
import xml.etree.ElementTree as ET
4
import resend
5
import os
6

7

8
def getRss(url):
9
    headers = {
10
        "User-Agent": "Nalanyinyun RSS and email service/1.0, +https://nalanyinyun.work"
11
    }
12
    response = requests.get(url, headers=headers, timeout=15)
13
    response.raise_for_status()
14
    return response.text
15

16
def generateEmailContent(rss):
17
    root = ET.fromstring(rss)
18
    items = root.findall("./channel/item")
19
    if not items:
20
        return "No posts found in RSS feed."
21

22
    first = items[0]
23
    title = first.findtext("title", default="Untitled")
24
    description = first.findtext("description", default="No description.")
25
    pubDate = first.findtext("pubDate", default="Unknown date")
26
    formatted_str = (
27
        f"<pre style='white-space: pre-wrap; font-family: sans-serif; font-size: 14px;'>"
28
        f"Nalanyinyun's Library 已更新，以下是摘要：\n\n"
29
        f"Title: {title}\n"
30
        f"Date: {pubDate}\n"
31
        f"{'-'*20}\n"
32
        f"Description: {description}\n\n"
33
        f"退订见：<a href=\"{{{{{{ resend_unsubscribe_url }}}}}}\">点击此处退订</a>"
34
        f"</pre>"
35
    )
36
    return formatted_str
37

38

39
def publishLatest(apiKey, segmentID, fromID, subject, content):
40
    resend.api_key = apiKey
41
    resend.Broadcasts.create({
42
        "segment_id": segmentID,
43
        "from": fromID,
44
        "subject": subject,
45
        "html": content,
46
        "headers": {
47
            "List-Unsubscribe": "<{{{{ resend_unsubscribe_url }}}}>",
48
            "List-Unsubscribe-Post": "List-Unsubscribe=One-Click"
49
        },
50
        "send": True
51
    })
52

53

54
url = "https://nalanyinyun.work/rss.xml"
55
content = generateEmailContent(getRss(url))
56

57
publishLatest(
58
    apiKey = os.getenv("RESEND_API_KEY"),
59
    segmentID="76654bf7-fd97-45e9-81a6-e38cda6391fc",
60
    fromID="Nalanyinyun <nalanyinyun@nalanyinyun.work>",
61
    subject="Nalanyinyun's Library Content Delivered",
62
    content=content
63
)

在使用时，替换 url 和 apiKey、segmentID 之类的变量就可以了。小心别把机密信息硬编码进去了。

值得注意的是，Resend 已经替我们处理好了所有的退订逻辑，但请在的正文和 Headers 里标识出来，不然很可能第一次发邮件就被拒信了。

Tally#

Tally 的 Web 表单是开箱即用的，我的表单只有这么一个输入框。在编辑之后点击 Integrities，添加一个 Webhook endpoint 就可以了。

Webhook endpoint 的实现下文会提到。

Tally 的自定义域名需要付费计划，不过我觉得这个是不是自己的域名应该无关紧要。记得在设置里开启禁止重复填写。

Cloudflare Workers#

Resend Audience。这个只需要创建好 Segment 并记住 ID 就可以了。

Cloudflare Workers 主要负责解析 Webhook 传入的数据，因为我实在是不懂 JavaScript，所以找 Gemini 生成一个勉强能用的后端。

1
export default {
2
  async fetch(request, env, ctx) {
3
    if (request.method !== "POST") {
4
      return new Response("Method Not Allowed", { status: 405 });
5
    }
6

7
    try {
8
      const body = await request.json();
9
      const emailField = body.data.fields.find(f => f.type === "INPUT_EMAIL");
10
      const userEmail = emailField ? emailField.value : null;
11

12
      if (!userEmail) {
13
        return new Response("No email found in webhook data", { status: 400 });
14
      }
15

16
      const segmentId = env.RESEND_SEGMENT_ID;
17
      const url = `https://api.resend.com/segments/${segmentId}/contacts`;
18

19
      const resendResponse = await fetch(url, {
20
        method: "POST",
21
        headers: {
22
          "Content-Type": "application/json",
23
          "Authorization": `Bearer ${env.RESEND_API_KEY}`,
24
        },
25
        body: JSON.stringify({
26
          email: userEmail,
27
        }),
28
      });
29

30
      const result = await resendResponse.json();
31

32
      if (resendResponse.ok) {
33
        console.log(`Success: Added ${userEmail} to segment`);
34
        return new Response("Subscribed to segment successfully!", { status: 200 });
35
      } else {
36
        console.error("Resend API Error:", result);
37
        return new Response(JSON.stringify(result), { status: resendResponse.status });
38
      }
39

40
    } catch (err) {
41
      return new Response("Internal Server Error: " + err.message, { status: 500 });
42
    }
43
  },
44
};

使用时需要添加机密 RESEND_API_KEY 和RESEND_SEGMENT_ID。

如果你的 Tally Webhook 传入和我的不一样，可能需要稍微改一改解析的逻辑，调用 API 那部分应该是没有问题的。

GitHub Action#

这部分就很简单了，只要监听相关文件变化再执行 Python 脚本就可以了，大概长这样。

1
name: RSS to Email on File Change
2

3
on:
4
  push:
5
    branches:
6
      - main
7
    paths:
8
      - src/content/posts/**
9
  workflow_dispatch:
10

11
jobs:
12
  email_notification:
13
    runs-on: ubuntu-latest
14
    steps:
15
      - name: Checkout Code
16
        uses: actions/checkout@v4
17

18
      - name: Set up Python
19
        uses: actions/setup-python@v5
20
        with:
21
          python-version: '3.10'
22

23
      - name: Install Dependencies
24
        run: pip install requests resend
25

26
      - name: Run Script
27
        env:
28
          RESEND_API_KEY: ${{ secrets.RESEND_API_KEY }}
29
        run: python blogutils/emailutils.py