n8n 的核心是节点（Node）之间的数据流动。每个节点接收上游数据、处理后输出给下游。理解这一点，你就能设计任意复杂的工作流。
节点的三大类型
1. Trigger 节点（触发器）
工作流的起点，决定什么时候运行。
| 触发器 | 说明 | 典型用法 |
|---|---|---|
| Webhook | 接收 HTTP 请求时触发 | 接收表单提交、API 回调 |
| Schedule | 定时触发（Cron 表达式） | 每天早上 8 点跑数据报告 |
| Email Trigger | 收到邮件时触发 | 自动处理客户邮件 |
| File System | 文件变化时触发 | 新文件上传自动处理 |
| Manual | 手动点击触发 | 测试或一次性任务 |
Schedule 节点的 Cron 表达式：
0 8 * * 1-5 // 周一到周五早上 8:00
0 */2 * * * // 每 2 小时
0 9 * * 1 // 每周一早上 9:00
2. Action 节点（操作）
对各类服务执行操作的节点，n8n 有 1,000+ 内置集成。
常用集成：
通讯: Slack、Gmail、Telegram、Notion
数据: PostgreSQL、MySQL、MongoDB、Google Sheets
代码: HTTP Request、GraphQL、Execute Command
云服务: AWS S3、Google Drive、Airtable
AI: OpenAI、Anthropic Claude、Hugging Face
3. Logic 节点（逻辑控制）
| 节点 | 功能 |
|---|---|
| IF | 条件分支，根据数据走不同路径 |
| Switch | 多条件分支 |
| Merge | 合并多个分支的数据 |
| Loop Over Items | 遍历数组中的每一项 |
| Wait | 暂停工作流，等待指定时间或外部事件 |
| Set | 设置/修改数据字段 |
| Code | 执行自定义 JavaScript 或 Python |
5 个实战工作流
工作流 1：GitHub PR 自动通知 Slack
场景：有人提交 PR，自动发 Slack 提醒代码 reviewer。
节点链： Webhook → IF（判断是否为 PR 事件）→ Slack
Webhook 配置: POST /github-webhook
IF 条件: {{ $json.body.action }} === "opened" AND {{ $json.body.pull_request }} 存在
Slack 消息:
"🔔 新 PR: {{ $json.body.pull_request.title }}
作者: {{ $json.body.pull_request.user.login }}
链接: {{ $json.body.pull_request.html_url }}"
在 GitHub 仓库 Settings → Webhooks 填入 n8n 的 Webhook URL，事件选 Pull requests。
工作流 2：每日数据汇总邮件
场景：每天早上 8 点从数据库查询前一天数据，发邮件给管理层。
节点链： Schedule → PostgreSQL → Code（格式化）→ Gmail
// Code 节点：把数据库查询结果格式化为 HTML 表格
const items = $input.all();
const rows = items.map(item =>
`<tr><td>${item.json.date}</td><td>${item.json.orders}</td><td>${item.json.revenue}</td></tr>`
).join('');
return [{
json: {
html: `<table><thead><tr><th>日期</th><th>订单数</th><th>收入</th></tr></thead>
<tbody>${rows}</tbody></table>`,
subject: `每日数据报告 - ${new Date().toLocaleDateString('zh-CN')}`
}
}];
工作流 3：表单提交自动入 CRM + 发欢迎邮件
场景：网站表单提交 → 自动创建 HubSpot 联系人 → 发个性化欢迎邮件。
节点链： Webhook → HubSpot（Create Contact）→ Gmail（Send Email）
Webhook 接收: { name, email, company, role }
HubSpot 节点:
- firstname: {{ $json.body.name.split(' ')[0] }}
- email: {{ $json.body.email }}
- company: {{ $json.body.company }}
Gmail 节点:
- To: {{ $json.body.email }}
- Subject: 欢迎加入，{{ $json.body.name.split(' ')[0] }}！
- Body: （HTML 模板）
工作流 4：文件上传自动处理
场景：用户上传 CSV 文件 → 解析数据 → 批量写入数据库。
节点链： Webhook（接收文件）→ Spreadsheet File（解析 CSV）→ Loop Over Items → PostgreSQL（Insert）
关键配置：Webhook 节点设置 Binary Data 接收文件，Spreadsheet File 节点解析 CSV 内容为 JSON 数组，Loop Over Items 遍历每行，PostgreSQL 节点批量插入。
工作流 5：Telegram Bot 查询数据库
场景：给 Telegram Bot 发消息，自动查询数据库返回结果。
节点链： Telegram Trigger → Code（解析命令）→ PostgreSQL → Telegram（回复）
// Code 节点：解析用户命令
const text = $json.message.text;
const chatId = $json.message.chat.id;
// 支持命令: /stats, /order <id>
const command = text.split(' ')[0];
const arg = text.split(' ')[1];
return [{ json: { command, arg, chatId } }];
数据流动：理解 $json 和 $node
n8n 里每个节点的输出格式是 [{ json: {...} }, { json: {...} }, ...]——一个 items 数组。
在 Expression 里引用数据：
{{ $json.fieldName }} // 当前节点输入的字段
{{ $json.nested.deep.value }} // 嵌套字段
{{ $items()[0].json.name }} // 当前节点第一个 item
{{ $node["节点名"].json.id }} // 引用指定节点的输出
{{ $workflow.id }} // 当前 workflow 的 ID
在 Code 节点里处理多条数据：
// 处理所有 items
const results = $input.all().map(item => ({
json: {
...item.json,
processed: true,
timestamp: new Date().toISOString()
}
}));
return results;
// 只返回满足条件的 items（相当于 filter）
return $input.all().filter(item => item.json.status === 'active');
