在做数据清洗自动化（比如 n8n 工作流）时，一个绕不开的问题就是：数据存哪里？怎么快速搭一个可用的数据库？

这篇文章我就把整个过程梳理清楚——从申请 Aiven 免费数据库，到连接使用，再到接入 n8n，实现“数据清洗 → 入库”的完整闭环。

---

一、为什么选择 Aiven？

在众多免费数据库方案中，我选择 Aiven 的原因很简单：

• ✅ 支持 MySQL / PostgreSQL
• ✅ 提供云数据库（不用本地部署）
• ✅ 自带公网访问
• ✅ 支持 SSL（更安全）

对于像我这样在做：

n8n + AI 数据清洗 + 自动入库

这种场景，Aiven 是一个非常合适的过渡方案。

---

二、Aiven 免费数据库申请流程

1. 注册账号

直接去 Aiven 官网注册账号（支持 GitHub 登录）。

2. 创建服务（Service）

进入控制台后：

• 点击 Create Service

• 选择：

  • Database：MySQL（或 PostgreSQL）
  • Cloud Provider：任意（推荐离你近的）
  • Plan：选择免费试用或最便宜方案

创建完成后，大概 1~2 分钟就能启动。

---

三、获取数据库连接信息（关键）

创建完成后，进入你的数据库实例，可以看到：

📌 Connection Information

这里有几个核心信息：

• Host（地址）
• Port（端口）
• Database（默认库）
• Username（用户名）
• Password（密码）

同时你会看到一个类似这样的连接串：

mysql://avnadmin:xxxx@n8n-xxx.aivencloud.com:11686/defaultdb?ssl-mode=REQUIRED

👉 这就是你连接数据库的核心。

---

四、SSL 证书配置（很多人卡在这里）

Aiven 默认必须使用 SSL 连接。

你需要在控制台下载：

• ca.pem（证书文件）

使用方式：

如果你是用代码连接：

ssl-mode=REQUIRED

或者在客户端里配置：

• SSL = enabled
• CA file = ca.pem

👉 如果你没看到 ca.pem，说明你还没展开 SSL 下载区域。

---

五、连接数据库（本地验证）

推荐用以下工具测试连接：

• DBeaver
• Navicat
• MySQL Workbench

连接参数：

• Host
• Port
• Username
• Password
• SSL：开启

👉 测试成功后，你就有一个可用的云数据库了。

---

六、创建表结构

根据我们前面的数据清洗需求，创建表：

CREATE TABLE cleaned_leads (
  id INT NOT NULL AUTO_INCREMENT,
  name VARCHAR(100),
  phone VARCHAR(50),
  intent VARCHAR(20),
  industry VARCHAR(100),
  raw_lead_id INT,
  processed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (id)
);

---

七、n8n 接入 Aiven 数据库

1. 新建 MySQL Credentials

在 n8n 中：

• Host：Aiven 提供的地址
• Port：11686（示例）
• User / Password
• Database：defaultdb

2. SSL 配置（重点）

开启 SSL：

• 勾选 SSL
• 上传 ca.pem

---

八、完整数据流实现

我们最终实现的是这样一个自动化流程：

Chat 输入杂乱数据
        ↓
拆分成多条线索
        ↓
AI 逐条清洗（提取 name / phone / intent / industry）
        ↓
循环处理
        ↓
写入 Aiven MySQL

这个流程的关键点：

🔹 1. Split In Batches

逐条处理数据，避免一次性爆掉

🔹 2. AI 清洗

用大模型统一格式，比如：

{
  "name": "张三",
  "phone": "13800000000",
  "intent": "high",
  "industry": "教育"
}

🔹 3. MySQL 插入

每条数据执行：

INSERT INTO cleaned_leads (...)

---