使用n8n构建自动化工作流：从数据库查询到邮件通知的使用指南

news2025/4/24 23:08:36

n8n是一款强大的开源工作流自动化工具，可以帮助你将各种服务和应用程序连接起来，创建复杂的自动化流程。下面我将详细介绍一个实用的n8n用例：从MySQL数据库查询数据并发送邮件通知，包括使用场景、搭建步骤和节点部署方法。

使用场景

场景描述：假设你是一家电商公司的运营人员，需要每天上午10点检查库存量低于警戒值的商品，并自动发送邮件通知采购部门及时补货。

工作流功能：

定时触发工作流（每天上午10点）
连接MySQL数据库查询库存数据
筛选出库存量低于警戒值的商品
将查询结果格式化为易读的HTML表格
通过SMTP服务发送邮件给采购部门

这个自动化流程可以节省每天手动查询和发送邮件的时间，确保补货通知及时准确。

搭建步骤

1. 部署n8n

n8n有多种部署方式，以下是两种常见方法：

方法一：使用Docker快速部署（适合本地测试）

bash

docker run -it --rm --name n8n -p 5678:5678 -v ~/.n8n:/home/node/.n8n docker.n8n.io/n8nio/n8n

部署完成后，访问 http://localhost:5678 即可进入n8n界面。

方法二：使用Railway和Supabase零成本搭建（适合生产环境）

在Supabase创建数据库项目，记录连接信息
在GitHub创建仓库并添加简单的Dockerfile
在Railway部署项目，关联GitHub仓库
设置环境变量（数据库连接、加密密钥等）
配置自定义域名（可选）

2. 创建工作流

登录n8n后，点击"Add workflow"创建新工作流
点击右上角的"Workflow settings"设置工作流名称和描述

部署节点与配置

以下是完整的工作流节点配置步骤：

节点1：Cron定时触发器

从左侧面板拖拽"Cron"节点到画布
配置属性：
- Mode: Every Day
- Hour: 10
- Minute: 0
这个节点会在每天上午10点自动触发工作流

节点2：MySQL数据库查询

添加"MySQL"节点并连接到Cron节点
点击"Create new credential"配置数据库连接：
- Host: 数据库服务器地址
- Database: 数据库名称
- User: 数据库用户名
- Password: 数据库密码
- Port: 3306（默认）
在Operation中选择"Select"

在Query中填写SQL语句：

sql

SELECT product_id, product_name, current_stock, alert_stock 
FROM products 
WHERE current_stock < alert_stock

节点3：IF条件判断（可选）

添加"IF"节点连接到MySQL节点
配置条件判断是否有低库存商品：
- 条件1: {{$node["MySQL"].json["length"] > 0}}
- 这样当查询结果为空时，工作流会终止而不发送空邮件

节点4：HTML格式化

添加"Function"节点连接到IF节点（True分支）
编写JavaScript代码将查询结果格式化为HTML表格：

javascript

const items = $input.all();

let html = `
  <h2>低库存商品警报</h2>
  <p>以下商品需要及时补货：</p>
  <table border="1" cellpadding="5" cellspacing="0">
    <tr>
      <th>商品ID</th>
      <th>商品名称</th>
      <th>当前库存</th>
      <th>警戒库存</th>
    </tr>
`;

items.forEach(item => {
  html += `
    <tr>
      <td>${item.product_id}</td>
      <td>${item.product_name}</td>
      <td>${item.current_stock}</td>
      <td>${item.alert_stock}</td>
    </tr>
  `;
});

html += `</table>`;

return [{ html }];

节点5：邮件发送

添加"Email (SMTP)"节点连接到Function节点
点击"Create new credential"配置SMTP服务：
- User: 发件邮箱
- Password: 邮箱密码或授权码
- Host: SMTP服务器地址（如smtp.gmail.com）
- Port: 465（SSL）或587（TLS）
- Secure: true（SSL）或false（TLS）
配置邮件内容：
- From: 发件人邮箱
- To: 收件人邮箱（如proxy@tiktoksim.com）
- Subject: "每日代理IP报告 - {{$now.format('YYYY-MM-DD')}}"
- Email Type: HTML
- Message: {{$node["Function"].json["html"]}}

测试与调试

点击右上角的"Execute workflow"手动测试工作流
检查每个节点的输出是否符合预期：
- MySQL节点应返回查询结果
- Function节点应生成正确的HTML
- Email节点应成功发送邮件
在节点的"Options"中启用"Always Output Data"可以查看节点处理的数据

高级优化

1. 分批处理大数据

如果查询结果很多，可以使用"SplitInBatches"节点分批发送邮件，避免单封邮件过大：

在MySQL和Function节点之间添加"SplitInBatches"节点
设置Batch Size为10（每封邮件包含10条记录）
将Email节点连接到SplitInBatches节点

2. 错误处理

添加"Error Trigger"节点捕获工作流中的错误
配置错误通知方式（如发送到Slack或另一封邮件）

3. 数据持久化

使用Supabase作为n8n的数据库（替代默认的SQLite）

配置环境变量：

env

DB_TYPE=postgresdb
DB_POSTGRESDB_DATABASE=your_db_name
DB_POSTGRESDB_HOST=your_supabase_host
DB_POSTGRESDB_PORT=5432
DB_POSTGRESDB_USER=postgres
DB_POSTGRESDB_PASSWORD=your_password

这样可以确保工作流数据和凭证在重启后不会丢失