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

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

使用场景

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

工作流功能：

1. 定时触发工作流（每天上午10点）

2. 连接MySQL数据库查询库存数据

3. 筛选出库存量低于警戒值的商品

4. 将查询结果格式化为易读的HTML表格

5. 通过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零成本搭建（适合生产环境）

1. 在Supabase创建数据库项目，记录连接信息

2. 在GitHub创建仓库并添加简单的Dockerfile

3. 在Railway部署项目，关联GitHub仓库

4. 设置环境变量（数据库连接、加密密钥等）

5. 配置自定义域名（可选）

2. 创建工作流

1. 登录n8n后，点击"Add workflow"创建新工作流

2. 点击右上角的"Workflow settings"设置工作流名称和描述

部署节点与配置

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

节点1：Cron定时触发器

1. 从左侧面板拖拽"Cron"节点到画布

2. 配置属性：

   • Mode: Every Day

   • Hour: 10

   • Minute: 0

3. 这个节点会在每天上午10点自动触发工作流

节点2：MySQL数据库查询

1. 添加"MySQL"节点并连接到Cron节点

2. 点击"Create new credential"配置数据库连接：

   • Host: 数据库服务器地址

   • Database: 数据库名称

   • User: 数据库用户名

   • Password: 数据库密码

   • Port: 3306（默认）

3. 在Operation中选择"Select"

4. 在Query中填写SQL语句：

   sql

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

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

1. 添加"IF"节点连接到MySQL节点

2. 配置条件判断是否有低库存商品：

   • 条件1: {{$node["MySQL"].json["length"] > 0}}

   • 这样当查询结果为空时，工作流会终止而不发送空邮件

节点4：HTML格式化

1. 添加"Function"节点连接到IF节点（True分支）

2. 编写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：邮件发送

1. 添加"Email (SMTP)"节点连接到Function节点

2. 点击"Create new credential"配置SMTP服务：

   • User: 发件邮箱

   • Password: 邮箱密码或授权码

   • Host: SMTP服务器地址（如smtp.gmail.com）

   • Port: 465（SSL）或587（TLS）

   • Secure: true（SSL）或false（TLS）

3. 配置邮件内容：

   • From: 发件人邮箱

   • To: 收件人邮箱（如[e-mail]）

   • Subject: "每日代理IP报告 - {{$now.format('YYYY-MM-DD')}}"

   • Email Type: HTML

   • Message: {{$node["Function"].json["html"]}}

测试与调试

1. 点击右上角的"Execute workflow"手动测试工作流

2. 检查每个节点的输出是否符合预期：

   • MySQL节点应返回查询结果

   • Function节点应生成正确的HTML

   • Email节点应成功发送邮件

3. 在节点的"Options"中启用"Always Output Data"可以查看节点处理的数据

高级优化

1. 分批处理大数据

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

1. 在MySQL和Function节点之间添加"SplitInBatches"节点

2. 设置Batch Size为10（每封邮件包含10条记录）

3. 将Email节点连接到SplitInBatches节点

2. 错误处理

1. 添加"Error Trigger"节点捕获工作流中的错误

2. 配置错误通知方式（如发送到Slack或另一封邮件）

3. 数据持久化

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

2. 配置环境变量：

   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

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

部署到生产环境

如果使用Railway部署n8n，可以：

1. 在Railway的项目设置中添加所有必要的环境变量

2. 配置自定义域名（如n8n.tiktoksim.com）

3. 设置N8N_ENCRYPTION_KEY环境变量，确保凭证加密安全

4. 启用EXECUTIONS_DATA_PRUNE自动清理旧数据，防止数据库过大

扩展应用

这个基础工作流可以进一步扩展：

1. 多通知渠道：添加Slack、企业微信等通知方式

2. 自动补货：连接采购系统API，当库存低于警戒值时自动创建采购订单

3. 数据分析：将查询结果保存到Google Sheets或Notion，形成历史记录

4. AI增强：使用MCP节点接入大模型，让AI分析库存趋势并给出补货建议

总结

通过这个用例，我们展示了如何使用n8n构建一个完整的自动化工作流，从数据库查询到邮件通知。n8n的强大之处在于：

1. 可视化编排：无需编写复杂代码即可连接各种服务

2. 丰富的节点库：支持数百种常见应用和服务

3. 灵活部署：可以在本地Docker运行，也可以部署到云平台

4. 扩展性强：可以通过社区节点或自定义代码扩展功能