n8n 从入门到精通全栈教程

欢迎来到n8n的深度学习之旅！本教程旨在为您提供一份从基础部署到企业级应用的详尽指南，助您高效掌握n8n，实现自动化工作流的无限可能。

第一部分：基础部署与核心概念

1. n8n深度解析

1.1 什么是n8n？为什么选择n8n？

n8n（"node eight n" 的缩写）是一个强大的开源自动化工具，它允许您连接各种应用程序和服务，通过创建“工作流”（workflows）来自动化复杂的任务和流程。它被誉为“自由且可扩展的 Zapier 或 IFTTT”，因为它提供了类似的功能，但却允许您在自己的服务器上运行，拥有完全的数据控制权和更高的可定制性。

n8n 的核心功能与优势：
- 可视化工作流编辑器： 通过拖放节点构建复杂的自动化逻辑。
- 强大的连接器： 内置数百个热门应用和服务的集成（例如：Google Sheets, Slack, Telegram, Email, Notion, Airtable, Salesforce, OpenAI, 各种数据库等）。
- 高度可定制性： 允许通过 Code 节点编写自定义 JavaScript 逻辑，处理复杂数据或集成未内置的服务。
- 自托管能力： 您可以将 n8n 部署在自己的服务器上，确保数据隐私和安全性，避免第三方服务的数据传输风险。
- 开源与社区： 活跃的开源社区提供丰富的资源和支持，持续的更新和功能迭代。
- 数据流控制： 强大的数据处理能力，支持JSON数据的转换、过滤、合并等操作。

与其他自动化工具（如 Zapier, IFTTT, Airflow）的对比：

特性	n8n	Zapier/IFTTT (SaaS)	Apache Airflow
部署方式	自托管 (On-premise) / 云托管	SaaS (软件即服务)	自托管 (通常为大数据/ETL)
数据控制	完全控制	第三方托管	完全控制
费用	开源免费，企业版收费；自托管成本	基于任务量/功能订阅费	开源免费，自托管成本
可定制性	极高 (Code节点, 自定义节点)	有限 (预设操作, 部分自定义脚本)	极高 (Python代码编写DAG)
适用场景	应用集成、API编排、业务流程自动化、数据预处理	轻量级任务自动化、个人效率	复杂数据管道、ETL、任务调度、大数据工作流
学习曲线	中等 (需理解JSON、HTTP、JS基础)	低 (图形化界面，即用型)	高 (需深入Python、调度系统知识)

总结： n8n 介于 Zapier 的易用性和 Airflow 的强大功能之间，是需要高度定制化和数据控制权的中小型企业或开发者的理想选择。

n8n 的开源特性与社区生态：

n8n 基于 MIT 许可证，这意味着您可以免费使用、修改和分发。它拥有一个活跃的社区，您可以在其论坛、GitHub 仓库找到丰富的资源、提问并参与贡献。社区驱动的开发模式也确保了 n8n 功能的持续更新和扩展。

1.2 n8n 架构原理

理解 n8n 的内部工作原理有助于您更好地设计和调试工作流。

节点执行引擎与事件驱动模型：

n8n 的核心是一个事件驱动的执行引擎。当一个工作流被触发（例如收到一个 Webhook 请求或达到一个定时器时间），它会产生一个“执行”（Execution）实例。这个实例会按照工作流中定义的路径，依次执行每个节点。每个节点接收前一个节点的输出数据（以 JSON 格式），处理后生成新的输出数据，再传递给下一个节点。

graph TD A[触发器: Webhook / Cron] --> B(节点 A: 数据获取); B --> C(节点 B: 数据处理); C --> D(节点 C: 数据存储 / 通知); D -- 错误时 --> E(错误处理节点); E --> F(通知管理员);
数据流转机制（JSON数据处理）：

n8n 中的所有数据都以 JSON 格式在节点之间传递。每个节点接收一个包含“项”（items）的数组，每个项都包含一个 json 属性（存储实际数据）以及可选的 binary 属性（用于文件或二进制数据）。
```
[
    {
        "json": {
            "name": "Alice",
            "email": "alice@example.com",
            "orderId": "123"
        },
        "binary": {}
    },
    {
        "json": {
            "name": "Bob",
            "email": "bob@example.com",
            "orderId": "456"
        },
        "binary": {}
    }
]
```
在节点内部，您可以访问和操作这些JSON数据，例如使用表达式或 Code 节点来提取、转换或过滤数据。
持久化存储（SQLite/PostgreSQL/MySQL）：

n8n 需要一个数据库来存储工作流定义、凭据、执行日志以及内部状态。默认情况下，它使用 SQLite，这是一个轻量级的嵌入式数据库。但在生产环境中，强烈建议使用更健壮的数据库如 PostgreSQL 或 MySQL，以确保数据完整性、性能和可扩展性。

1.3 n8n 版本选择与适用场景

开源版 vs. 企业版功能对比：

n8n 提供开源社区版和商业企业版。
- 开源社区版： 免费，功能强大，适用于个人开发者、小型团队或测试环境。它包含了大部分核心功能，足以构建复杂的自动化工作流。
- 企业版： 在社区版基础上提供更多为大型组织设计的功能，例如：
  - 用户管理与权限控制：细粒度权限管理，团队协作更安全。
  - 高级认证： LDAP/SSO 集成。
  - 性能监控与分析：更深入的执行统计和系统健康度监控。
  - 企业级支持：专业的客户服务和技术支持。
  - 私有节点开发：更方便地管理和分发自定义节点。
对于大多数用户而言，开源版已能满足绝大部分需求。当您需要管理大量团队成员、有严格安全合规要求或需要专业支持时，才需考虑企业版。
适用场景：
- IT运维自动化：自动部署、服务器监控告警、日志分析与通知。
- 营销自动化：客户邮件序列、社交媒体内容发布、潜在客户管理。
- 销售流程自动化： CRM数据同步、销售报告生成、销售线索分配。
- 数据管道与ETL：从多个数据源提取、转换、加载数据到数据仓库。
- API集成与编排：连接并协调多个API服务，构建自定义微服务。
- 内容管理：自动发布博客文章、同步CMS内容。
- 财务自动化：自动发票处理、报销流程。

2. 专业级部署方案

部署n8n是使用的第一步。对于生产环境，我们推荐使用Docker或Kubernetes，因为它们提供了更好的可移植性、可伸缩性和易维护性。

2.1 Docker 部署（生产环境推荐）

Docker 是容器化技术的领导者，能够将 n8n 及其所有依赖项打包到一个可移植的容器中，实现快速部署和环境一致性。

Docker 安装与基本概念回顾：

确保您的系统已安装 Docker Engine 和 Docker Compose。如果您不熟悉 Docker，建议先查阅 Docker 官方文档进行基础学习。
单容器部署指南：

这是最简单的部署方式，适合快速测试或开发环境。数据默认存储在容器内部，重启容器可能会丢失数据，除非使用卷挂载。
```
docker run -it --rm \
   --name n8n \
   -p 5678:5678 \
   -v ~/.n8n:/home/node/.n8n \
   n8nio/n8n
```
- -it: 交互式模式
- --rm: 容器停止后自动删除
- --name n8n: 给容器命名为 n8n
- -p 5678:5678: 将宿主机的 5678 端口映射到容器的 5678 端口（n8n 默认端口）
- -v ~/.n8n:/home/node/.n8n: 关键！将宿主机的 ~/.n8n 目录挂载到容器的 /home/node/.n8n 目录。这是 n8n 存储其配置、凭据和 SQLite 数据库的默认位置，确保数据持久化。
- n8nio/n8n: 指定使用的 n8n 官方 Docker 镜像。
运行后，您可以通过浏览器访问 http://localhost:5678 来访问 n8n。

Docker Compose 多服务部署（包含PostgreSQL、Redis）：

对于生产环境，强烈推荐使用 Docker Compose 部署 n8n，并连接到外部的 PostgreSQL 数据库和 Redis 缓存。PostgreSQL 用于存储核心数据（工作流、凭据），Redis 用于存储队列和会话数据，提高性能和稳定性。

创建 docker-compose.yml 文件：

version: '3.8'

services:
  n8n:
    image: n8nio/n8n
    restart: always
    ports:
      - "5678:5678"
    environment:
      - N8N_HOST=${N8N_HOST:-localhost}
      - N8N_PROTOCOL=${N8N_PROTOCOL:-http}
      - WEBHOOK_URL=${WEBHOOK_URL:-http://localhost:5678/} # 生产环境改为您的公网URL
      - DB_TYPE=postgresdb
      - DB_POSTGRESDB_HOST=postgres
      - DB_POSTGRESDB_PORT=5432
      - DB_POSTGRESDB_DATABASE=${POSTGRES_DB:-n8n}
      - DB_POSTGRESDB_USER=${POSTGRES_USER:-n8n}
      - DB_POSTGRESDB_PASSWORD=${POSTGRES_PASSWORD:-n8n}
      - QUEUE_HEALTH_CHECK_ACTIVE=true # 启用队列健康检查
      - QUEUE_TYPE=redis
      - QUEUE_REDIS_HOST=redis
      - QUEUE_REDIS_PORT=6379
      - N8N_ENCRYPTION_KEY=${N8N_ENCRYPTION_KEY} # 重要：设置加密密钥
      - N8N_BASIC_AUTH_ACTIVE=${N8N_BASIC_AUTH_ACTIVE:-false}
      - N8N_BASIC_AUTH_USER=${N8N_BASIC_AUTH_USER}
      - N8N_BASIC_AUTH_PASSWORD=${N8N_BASIC_AUTH_PASSWORD}
      - TZ=${TZ:-Asia/Shanghai} # 设置时区
    volumes:
      - n8n_data:/home/node/.n8n

  postgres:
    image: postgres:13
    restart: always
    environment:
      - POSTGRES_DB=${POSTGRES_DB:-n8n}
      - POSTGRES_USER=${POSTGRES_USER:-n8n}
      - POSTGRES_PASSWORD=${POSTGRES_PASSWORD:-n8n}
    volumes:
      - postgres_data:/var/lib/postgresql/data

  redis:
    image: redis:6-alpine
    restart: always
    command: redis-server --appendonly yes
    volumes:
      - redis_data:/data

volumes:
  n8n_data:
  postgres_data:
  redis_data:

创建 .env 文件来管理环境变量：

# .env
N8N_HOST=your.domain.com # 您的域名或IP地址
N8N_PROTOCOL=https # 如果使用HTTPS
WEBHOOK_URL=https://your.domain.com/ # Webhook回调URL

POSTGRES_DB=n8n_prod
POSTGRES_USER=n8n_user
POSTGRES_PASSWORD=your_strong_db_password

N8N_ENCRYPTION_KEY=a_very_long_and_random_string_for_encryption_key # 至少32位随机字符
N8N_BASIC_AUTH_ACTIVE=true
N8N_BASIC_AUTH_USER=admin
N8N_BASIC_AUTH_PASSWORD=your_strong_admin_password

TZ=Asia/Shanghai

在 docker-compose.yml 和 .env 文件所在的目录执行：

docker-compose up -d

这将启动 n8n、PostgreSQL 和 Redis 三个服务。

环境变量配置（持久化、时区、认证）：

在 Docker Compose 示例中，我们配置了以下重要的环境变量：
- N8N_HOST, N8N_PROTOCOL, WEBHOOK_URL: 用于正确生成 webhook URL。在生产环境，必须将 WEBHOOK_URL 设置为您的公网可访问的域名或IP。
- DB_TYPE, DB_POSTGRESDB_HOST 等: 配置 n8n 连接 PostgreSQL 数据库。
- QUEUE_TYPE, QUEUE_REDIS_HOST 等: 配置 n8n 使用 Redis 作为队列。
- N8N_ENCRYPTION_KEY: 极度重要！用于加密存储在数据库中的敏感凭据（如 API Keys）。请务必生成一个复杂且随机的字符串，并妥善保管。一旦丢失，您将无法解密现有凭据。
- N8N_BASIC_AUTH_ACTIVE, N8N_BASIC_AUTH_USER, N8N_BASIC_AUTH_PASSWORD: 启用并设置 n8n UI 的基础认证，增加安全性。
- TZ: 设置容器内部的时区，确保定时任务（Cron Trigger）的准确性。

2.2 Kubernetes (K8s) 部署（高可用与规模化）

对于需要高可用、大规模部署和更精细资源管理的场景，Kubernetes 是理想选择。n8n 官方提供了 Helm Chart，简化了部署过程。

Helm Chart 配置与部署：

Helm 是 Kubernetes 的包管理器。首先确保您的 Kubernetes 集群已就绪，并安装了 Helm。

# 添加 n8n Helm 仓库
helm repo add n8n-charts https://n8n.io/helm-charts/
helm repo update

# 创建一个 values.yaml 文件进行配置
# values.yaml (部分关键配置)
# persistence:
#   enabled: true
#   storageClass: "your-storage-class" # 您的持久卷存储类
#   size: 10Gi

# externalDatabase:
#   type: "postgres"
#   host: "your-external-postgres-host"
#   port: 5432
#   database: "n8n"
#   user: "n8n"
#   password: "your_strong_db_password"

# externalRedis:
#   enabled: true
#   host: "your-external-redis-host"
#   port: 6379

# environment:
#   N8N_ENCRYPTION_KEY: "a_very_long_and_random_string_for_encryption_key"
#   WEBHOOK_URL: "https://your.n8n.domain.com/"
#   N8N_BASIC_AUTH_ACTIVE: "true"
#   N8N_BASIC_AUTH_USER: "admin"
#   N8N_BASIC_AUTH_PASSWORD: "your_strong_admin_password"

# ingress:
#   enabled: true
#   className: "nginx" # 或您的 Ingress Controller
#   hosts:
#     - host: your.n8n.domain.com
#       paths:
#         - path: /
#           pathType: Prefix
#   tls:
#     - hosts:
#         - your.n8n.domain.com
#       secretName: n8n-tls-secret # 提前创建或由 cert-manager 自动生成

# service:
#   type: ClusterIP # 或 LoadBalancer

# resources: # 资源限制与请求
#   requests:
#     cpu: 500m
#     memory: 1Gi
#   limits:
#     cpu: 1000m
#     memory: 2Gi

# 部署 n8n
helm install n8n n8n-charts/n8n -f values.yaml

持久卷（Persistent Volume）配置：

在 Kubernetes 中，工作流和凭据数据应存储在持久卷上，以确保数据不会随 Pod 的重启而丢失。在 values.yaml 中配置 persistence.enabled: true 并指定 storageClass。
Ingress 配置与负载均衡：

Ingress 用于暴露 n8n 服务到集群外部，并可以配置域名、SSL/TLS 证书。它通常与 Nginx Ingress Controller 或 Traefik 等负载均衡器配合使用。

2.3 云服务托管部署简介

如果您不想自己管理服务器，也可以选择一些提供容器托管服务的云平台。

AWS ECS/EC2 + RDS 持久化方案：

在 AWS 上，您可以将 n8n 部署为 ECS Fargate 服务（无服务器容器），将 PostgreSQL 数据库部署为 RDS 实例。这种方式简化了基础设施管理。
Render、Railway 等平台快速部署：

这些平台提供了非常简单的部署界面，可以直接从 GitHub 仓库或 Docker 镜像部署 n8n，并自动处理域名、SSL 和数据库连接，适合快速原型开发或小型应用。

2.4 部署后的初始设置与安全性

安全是任何生产系统的基石。以下步骤至关重要。

设置 N8N_ENCRYPTION_KEY 进行敏感数据加密：

这个环境变量用于加密您的凭据（例如 API 密钥、OAuth 令牌）。务必在首次启动 n8n 前设置它，且不要随意更改或丢失！更改密钥会导致无法解密旧的凭据。
```
# 生成一个随机密钥 (例如使用 OpenSSL)
openssl rand -base64 32
```
将其添加到您的 Docker Compose .env 文件或 Kubernetes values 中。
配置用户认证（Basic Auth, OAuth2）：

默认情况下，n8n 没有用户认证。为了防止未经授权的访问，请务必启用认证。
- Basic Auth (基本认证)： 在 .env 中设置 N8N_BASIC_AUTH_ACTIVE=true, N8N_BASIC_AUTH_USER 和 N8N_BASIC_AUTH_PASSWORD。
- OAuth2 / OpenID Connect： 对于企业级应用，可以集成 Google, GitHub 等 OAuth2 提供商进行登录。这需要在 n8n 配置额外的环境变量和在 OAuth 提供商处注册应用。

启用 HTTPS（Nginx/Caddy 反向代理，Let's Encrypt 自动续签）：

所有公共访问的 Webhook URL 和 n8n UI 都应通过 HTTPS 保护，以加密数据传输。这通常通过在 n8n 前面部署一个反向代理服务器（如 Nginx 或 Caddy）来实现，并配置 Let's Encrypt 自动生成和续签 SSL 证书。

graph TD A[用户浏览器] -- HTTPS --> B[Nginx/Caddy 反向代理] B -- HTTP --> C[n8n 服务] C -- DB连接 --> D[PostgreSQL] C -- Redis连接 --> E[Redis]

例如，使用 Nginx 配置：

server {
    listen 80;
    server_name your.n8n.domain.com;
    return 301 https://$host$request_uri;
}

server {
    listen 443 ssl http2;
    server_name your.n8n.domain.com;

    ssl_certificate /etc/letsencrypt/live/your.n8n.domain.com/fullchain.pem;
    ssl_certificate_key /etc/letsencrypt/live/your.n8n.domain.com/privkey.pem;

    location / {
        proxy_pass http://localhost:5678; # n8n 内部地址和端口
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
    }
}

3. n8n 用户界面与基本操作

熟悉 n8n 的用户界面是高效使用的基础。

3.1 Dashboard（仪表盘）详解

这是您登录 n8n 后的主界面，提供了工作流的概览。

工作流列表与状态：显示所有已创建的工作流，包括名称、启用/禁用状态、上次执行时间、错误计数等。
执行日志与错误概览：快速查看近期工作流的执行成功与失败情况，帮助您及时发现并处理问题。
创建新工作流：通常在右上角有按钮用于创建新的空白工作流。

3.2 Workflow Editor（工作流编辑器）深度探索

这是您构建和修改工作流的核心区域。

画布操作：
- 拖拽： 从左侧节点面板将节点拖到画布上。
- 连接： 鼠标点击一个节点的输出端点，拖拽到另一个节点的输入端点，建立数据流连接。
- 分组： 选择多个节点，右键点击可以将其分组，方便管理复杂工作流。
节点搜索与添加：
在画布上双击或点击“+”按钮，可以弹出节点搜索框，快速找到并添加所需节点。
数据预览与调试模式：
在编辑模式下，点击任何一个节点，其右侧面板会显示该节点的配置选项。在工作流执行后，点击节点可以看到该节点的“输入”（Input）和“输出”（Output）数据，这对于调试至关重要。您可以点击“Test Workflow”按钮来手动执行当前工作流并预览数据流。

3.3 Credentials（凭据管理）

凭据用于安全地存储您的 API Key、OAuth 令牌、用户名/密码等敏感信息，供工作流中的节点使用。

为什么需要凭据？
将敏感信息与工作流逻辑分离，提高安全性。当凭据过期或需要更新时，只需更新凭据本身，而无需修改所有使用该凭据的工作流。
如何添加和管理不同服务的 API Key/OAuth 凭据：
在 n8n 界面左侧导航栏找到“Credentials”（钥匙图标），点击“New Credential”创建新凭据。根据不同服务的要求（OAuth2, API Key, Basic Auth, Token 等），选择相应的凭据类型并填写所需信息。n8n 会引导您完成 OAuth2 认证流程。

3.4 Settings（系统设置）

提供了 n8n 实例的全局配置。

通知设置：配置当工作流执行失败时，如何通过邮件、Slack、Telegram 等方式接收通知。
时区、语言等：调整 n8n 界面和定时任务的时区。
Webhooks URL 配置：确保 WEBHOOK_URL 环境变量设置正确，否则外部服务可能无法正确回调您的 n8n 实例。

第二部分：工作流开发与高级技巧

1. 工作流核心组件详解

工作流由触发器、功能节点和应用节点组成，通过连接线构建数据流。

1.1 触发器 (Trigger) 节点：工作流的起点

每个工作流都必须有一个触发器，它定义了工作流何时启动。

Webhook Trigger：
- 功能： 监听一个特定的 HTTP URL，当该 URL 收到 HTTP 请求时，工作流被触发。
- 应用场景：
  - 作为外部服务的回调接口（例如：Stripe 支付成功通知）。
  - 接收表单提交数据（例如：Typeform, Google Forms）。
  - 构建简单的 REST API 端点。
- 配置： 选择 HTTP 方法（GET, POST 等），可以添加认证、响应自定义等。
Cron Trigger：
- 功能： 按照预设的时间间隔或特定的时间点触发工作流，类似于 Linux 的 cron 任务。
- 应用场景：
  - 定时生成报告并发送。
  - 每日数据同步任务。
  - 定期检查外部服务状态。
- 配置： 支持多种时间配置方式，从简单的“每小时”、“每天”到复杂的 Cron 表达式。
应用程序特定触发器：

许多应用节点也提供自己的触发器功能，例如：
- Gmail New Email: 当收到新邮件时触发。
- Slack New Message: 当 Slack 频道收到新消息时触发。
- Airtable New Record: 当 Airtable 表格中添加新记录时触发。
HTTP Request Trigger：

此触发器允许您在特定 URL 收到请求时启动工作流，并且可以更灵活地配置请求参数，例如处理不同的 HTTP 方法、路径参数等。

1.2 核心功能节点：数据处理与控制流

这些节点是构建工作流逻辑的基石。

HTTP Request：
- 功能： 发送 HTTP 请求到任何 URL，用于与外部 API 进行交互。
- 高级配置：
  - Method (方法)： GET, POST, PUT, DELETE 等。
  - URL：可以使用表达式动态构建 URL。
  - Headers (请求头)：添加认证令牌、内容类型等。
  - Query Parameters (查询参数)： URL 后面的 ?key=value 参数。
  - Body (请求体)： POST/PUT 请求的数据，支持 JSON、表单数据等。
  - SSL Verification (SSL验证)：生产环境通常保持开启。
  - Authentication (认证)：支持 Basic Auth, OAuth2, Bearer Token 等多种认证方式。
Set：
- 功能： 用于设置、修改或删除工作流中的数据字段。
- 应用：
  - 添加新字段。
  - 修改现有字段的值（可以使用表达式）。
  - 删除不需要的字段（数据清洗）。
  - 重命名字段。
  - 设置静态值或动态值。
Merge：
- 功能： 将来自不同路径或多个节点的输入数据合并为一个输出。
- 合并模式：
  - Append (追加)：将所有输入项简单地合并到一个列表中。
  - Combine (组合)：基于一个或多个键值对（例如 ID）匹配不同输入流的项，然后将它们合并到同一个项中。
SplitInBatches：
- 功能： 当处理大量数据时，将其拆分为更小的批次进行处理。
- 应用场景： 避免 API 速率限制、减少内存消耗、提高稳定性。
- 配置： 指定每个批次包含的项数。
Code：
- 功能： 允许您编写自定义的 JavaScript 代码来处理数据、执行复杂逻辑或与 n8n 内部 API 交互。
- 访问内置对象：
  - items: 包含所有输入数据项的数组。
  - $json: 访问当前项的 JSON 数据。
  - $node: 访问特定节点的输出数据。
  - _ (lodash): 内置的实用工具库。
  - moment: 内置的日期时间处理库。
- 示例：
```
// Code 节点示例：计算总价并添加新字段
const newItems = items.map(item => {
  const quantity = item.json.quantity;
  const price = item.json.price;
  const total = quantity * price;
  return {
    json: {
      ...item.json, // 复制所有现有字段
      totalPrice: total // 添加新字段
    }
  };
});
return newItems;
```
If：
- 功能： 根据条件判断将数据流分成两条路径（True/False）。
- 条件构建： 支持复杂逻辑（AND, OR, NOT），可以使用表达式、比较运算符（等于、大于、包含等）。
Wait：
- 功能： 暂停工作流执行，直到指定时间过去或特定条件满足。
- 应用场景：
  - 实现延迟发送邮件。
  - 等待外部API处理完成。
  - 排队处理任务以避免超载。
NoOp：
- 功能： 不执行任何操作，只传递输入数据到输出。
- 应用场景： 作为占位符、组织节点或调试点。
Try/Catch：
- 功能： 捕获上游节点发生的错误，并将错误信息传递给下游节点进行处理。
- 应用： 实现健壮的错误处理机制，例如发送错误通知、记录错误日志、重试操作。

1.3 应用集成节点：连接外部服务

n8n 内置了大量针对特定应用的节点，简化了与这些服务的集成。

常用应用节点的使用配置：
例如 Google Sheets, Slack, Telegram, Email, Notion, Airtable, Salesforce, OpenAI 等。

每个应用节点通常有以下配置：
- Credential (凭据)： 选择或创建连接到该服务的凭据。
- Operation (操作)： 选择您想执行的操作，例如 Google Sheets 的“Append Row”（添加行）、Slack 的“Post Message”（发送消息）、Notion 的“Create Page”（创建页面）。
- Parameters (参数)： 根据所选操作，配置相应的参数，如表格ID、频道名称、消息内容、页面属性等。这些参数通常可以使用表达式引用上游数据。
如何连接 OAuth2 服务（以 Google Sheets 为例）：
对于 Google Sheets 这样的 OAuth2 服务，您需要：
1. 在 Google Cloud Console 创建一个 OAuth 2.0 客户端 ID 和密钥。
2. 在 n8n 的 Credentials 界面，选择 "Google" -> "Google Sheets API" -> "OAuth2 API"。
3. 输入您的客户端 ID 和密钥。
4. 点击“Connect your account”，n8n 会将您重定向到 Google 进行授权。
5. 授权成功后，n8n 将获取并存储您的访问令牌，供 Google Sheets 节点使用。
如何连接 API Key 服务（以 Notion 为例）：
对于 Notion 这样的 API Key 服务，您需要：
1. 在 Notion 创建一个内部集成，并获取其 API Token。
2. 在 n8n 的 Credentials 界面，选择 "Notion" -> "Notion API" -> "API Key"。
3. 输入您从 Notion 获取的 API Token。
4. 点击“Connect”完成连接。

2. 数据流与表达式进阶

精通数据处理是构建强大n8n工作流的关键。

2.1 n8n 的数据结构：Items 与 JSON

n8n 内部所有数据都以“项”（Items）的数组形式传递。

理解 items 数组结构与 json 对象：

每个 item 对象通常包含两个主要属性：
- item.json: 存储实际的 JSON 数据负载。这是您在节点配置中最常引用和操作的数据。
- item.binary: 可选属性，用于存储二进制数据（如图片、文件）。
当工作流处理多个数据记录时，例如从数据库查询出多条记录，每个记录会作为 items 数组中的一个单独的 item。
如何访问前一个节点的数据：
- ${{ $json.field_name }}: 最常用。访问当前处理的 item 的 json 数据中的 field_name 字段。
- ${{ $node["PreviousNodeName"].json.field_name }}: 访问指定名称的 PreviousNodeName 节点的输出数据中的 json.field_name。这在需要跨节点引用数据时非常有用。
- ${{ $item(index).json.field_name }}: 访问 items 数组中特定索引 index 的项的 json.field_name。
- ${{ $items("PreviousNodeName")[index].json.field_name }}: 访问指定节点输出的 items 数组中特定索引的项的数据。

2.2 表达式引擎（Expression Engine）精通

表达式是 n8n 的核心之一，允许您动态地构建值、条件和逻辑。

基本表达式语法：

表达式以 ${{ ... }} 包裹。在其中可以编写 JavaScript 片段。

// 访问字段
${{ $json.email }}

// 字符串拼接
${{ 'Hello ' + $json.name + '!' }}

// 数学运算
${{ $json.price * $json.quantity }}

使用 JavaScript 函数：

您可以在表达式中使用大部分标准的 JavaScript 函数。

// 转换为大写
${{ $json.name.toUpperCase() }}

// 获取字符串长度
${{ $json.description.length }}

// 日期格式化 (使用内置的 moment 库)
${{ moment($json.timestamp).format('YYYY-MM-DD HH:mm:ss') }}

复杂条件表达式：

在 If 节点或 Code 节点中，您可以构建复杂的布尔逻辑。

// 订单金额大于100且状态为“已支付”
${{ $json.amount > 100 && $json.status === 'paid' }}

// 客户等级为VIP或通过邮件订阅
${{ $json.customerTier === 'VIP' || $json.emailSubscribed === true }}

JMESPath 高级查询：

n8n 也支持 JMESPath，这是一种用于 JSON 数据的高级查询语言，特别适合过滤、转换和提取嵌套数据。

要使用 JMESPath，通常在 Code 节点中引入，或者在某些节点的“表达式”字段直接使用。jmespath.search(data, expression)
- 过滤：
```
// 提取 status 为 'active' 的所有 id
$json.users[?status=='active'].id
```
- 转换：
```
// 将数组中的对象转换为新结构
$json.products.{name: product_name, price: price_usd}
```
- 提取嵌套数据：
```
// 提取所有订单中的所有商品名称
$json.orders[].items[].name
```
JMESPath 在 Code 节点中使用时需要引入：const jmespath = require('jmespath');

2.3 数据转换与清洗

数据的格式化和清洗是自动化流程中不可或缺的一环。

Set 节点的高级用法：
- 添加/删除/重命名字段： 灵活地调整数据的结构，使其符合下游节点的预期。
- 批量操作： 如果您有多个项，Set 节点会分别对每个项执行配置的操作。
- 类型转换： 虽然 Set 节点本身不直接进行复杂类型转换，但您可以利用表达式进行简单的数值或字符串转换。

Code 节点实现复杂数据映射与聚合：

当 Set 节点无法满足需求时，Code 节点提供了无限可能。您可以使用 JavaScript 的 map(), filter(), reduce() 等数组方法，以及 Lodash (_) 库进行复杂的数据操作。

// Code 节点：聚合订单数据
const aggregatedData = items.reduce((acc, item) => {
  const customerId = item.json.customerId;
  if (!acc[customerId]) {
    acc[customerId] = {
      customerId: customerId,
      totalOrders: 0,
      totalAmount: 0,
      orderDates: []
    };
  }
  acc[customerId].totalOrders++;
  acc[customerId].totalAmount += item.json.amount;
  acc[customerId].orderDates.push(item.json.orderDate);
  return acc;
}, {});

return [{ json: Object.values(aggregatedData) }];

使用 Split In Batches 和 Merge 进行批处理数据流：
当从一个源获取大量数据，但目标 API 有速率限制时，Split In Batches 节点非常有用。它将一个大数据项数组拆分成多个小批次，每个批次独立执行后续节点。处理完所有批次后，可以使用 Merge 节点将所有批次的输出再次合并。

graph LR A[数据源获取大量数据] --> B(Split In Batches); B --> C(处理单个批次); C --> B; B --> D(Merge 批次结果); D --> E[最终结果];

3. 错误处理与调试最佳实践

优雅的错误处理和高效的调试是构建健壮工作流的必备技能。

3.1 执行日志 (Execution Logs) 分析

成功/失败执行记录：在 Dashboard 的 "Executions" 页面，您可以查看每次工作流的运行情况。绿色表示成功，红色表示失败。
节点输入/输出数据检查：点击任何一个执行记录，可以进入详细视图。在这里，您可以点击工作流中的每个节点，查看其“Input”（接收到的数据）和“Output”（处理后发出的数据）。这是定位问题发生在哪一步的关键。
错误信息定位：对于失败的执行，错误信息会高亮显示，并提供堆栈跟踪，帮助您快速找到错误发生的原因和位置。

3.2 Try/Catch 节点应用

Try/Catch 节点提供了一种结构化的错误处理方式，类似于编程语言中的 try-catch 块。

全局错误处理与特定节点错误捕获：
您可以将可能发生错误的节点放入 Try 块中。如果 Try 块内的任何节点失败，控制流会立即转移到 Catch 块。Catch 节点会接收到一个包含错误信息的 item。
错误发生时的通知与重试机制：
在 Catch 节点之后，您可以添加：
- 通知节点：例如 Slack, Email, Telegram 等，发送错误详情给管理员。
- 日志记录节点：将错误信息记录到数据库或文件。
- 重试机制：如果错误是暂时的（例如网络超时），可以在 Catch 节点后使用 Wait 节点等待一段时间，然后尝试重新执行之前的操作（这通常需要更复杂的子工作流设计）。
graph LR A[触发器] --> B(Try); B --> C(API请求 - 核心逻辑); C --> D(数据处理); D --> B; B --- E(Catch); E --> F(记录错误日志); F --> G(发送错误通知);

3.3 调试技巧

"Test Workflow" 与 "Execute Workflow" 的区别：
- Test Workflow (测试工作流)： 在编辑模式下手动触发工作流一次。它的执行结果不会记录在常规的“执行历史”中，但您可以在编辑器中实时查看每个节点的输入/输出数据，非常适合调试。
- Execute Workflow (执行工作流)： 当工作流处于激活状态时，它会等待触发器被激活（例如收到 Webhook 请求），然后自动执行。执行记录会保存到“执行历史”中。
使用 console.log() 在 Code 节点中打印调试信息：
在 Code 节点中，您可以像在常规 JavaScript 中一样使用 console.log() 来打印变量的值或调试信息。这些信息会显示在 Code 节点的输出数据中，或者如果您查看 n8n 运行的 Docker 容器日志，也可以看到。
```
console.log('当前数据:', items[0].json);
console.log('API响应状态码:', $node["HTTP Request"].json.statusCode);
return items; // 必须返回 items，否则数据流会中断
```
逐步执行与数据预览：
在“Test Workflow”模式下，您可以点击工作流中的任意节点，查看其在当前执行步骤中的输入和输出数据。这让您可以逐个节点地跟踪数据流，定位问题所在。

第三部分：高阶特性、性能与架构

1. 子工作流 (Sub-Workflows) 与模块化

子工作流是组织复杂工作流、提高复用性和可维护性的强大工具。

1.1 什么是子工作流？为什么使用子工作流？

什么是子工作流？

子工作流是作为一个独立的工作流创建的，但可以通过 Call Workflow 节点在另一个“主工作流”中调用。它就像一个函数或一个微服务，接收输入并返回输出。
为什么使用子工作流？
- 复杂工作流的组织与解耦：将一个巨大的工作流拆分为更小、更易于管理和理解的模块。
- 提升可重用性与维护性：将通用的逻辑（如认证、日志记录、错误处理）封装为子工作流。当这部分逻辑需要修改时，只需修改一个地方，所有调用它的主工作流都会受益。
- 清晰的职责划分：每个子工作流专注于完成一个单一的、明确定义的任务。

1.2 创建与调用子工作流

Start/End 节点在子工作流中的作用：
- Start 节点： 作为子工作流的入口，定义了可以接收哪些输入参数。
- End 节点： 作为子工作流的出口，定义了将哪些数据作为输出返回给调用者。
它们允许主工作流与子工作流进行参数传递和结果接收。
Call Workflow 节点参数传递与结果接收：

在主工作流中，使用 Call Workflow 节点来调用子工作流。您可以在该节点中配置：
- Workflow To Call： 选择要调用的子工作流。
- Input Data： 将当前主工作流的数据或特定表达式作为参数传递给子工作流的 Start 节点。
- Output Data： 接收子工作流 End 节点返回的数据。

1.3 模块化设计原则

将重复或独立的逻辑抽象为子工作流。

常见可复用模块：
- 认证模块： 封装 OAuth2 令牌刷新、API 密钥管理等复杂认证逻辑。
- 日志记录模块： 统一的错误日志、审计日志写入到数据库或日志服务。
- 通用数据处理模块： 如数据清洗、格式化、验证。
- 通知模块： 封装发送 Slack、邮件、短信等通知的逻辑。

2. Code 节点深度应用

Code 节点是 n8n 的“瑞士军刀”，让您能够突破图形化界面的限制，实现任何自定义逻辑。

2.1 JavaScript 基础回顾与 n8n 上下文

如何访问 items、$json、$node 等内置对象：

在 Code 节点中，您可以直接访问以下全局可用的变量：
- items: 一个数组，包含所有流入该 Code 节点的输入数据项。每个项都有 json 和 binary 属性。
- $json: 当前处理的 item 的 json 数据。当 Code 节点处理单个项时，您可以直接使用它。
- $node["NodeName"]: 访问名为 NodeName 的节点的所有输出数据。
- _ (lodash): 一个流行的 JavaScript 实用工具库，提供数组、对象、函数等操作的便捷方法。
- moment: 一个 JavaScript 日期处理库。
- axios: 用于发送 HTTP 请求的库。
```
const _ = require('lodash'); // 显式引入 lodash
const moment = require('moment'); // 显式引入 moment

// 示例：从输入数据中筛选并转换
const filteredItems = items.filter(item => item.json.status === 'completed');

const transformedItems = filteredItems.map(item => ({
  json: {
    orderId: item.json.id,
    customerName: item.json.customer.name,
    processedDate: moment().format('YYYY-MM-DD HH:mm:ss')
  }
}));

// 返回处理后的数据，Code 节点必须返回一个包含 items 的数组
return transformedItems;
```
常用 JavaScript 内置方法（map, filter, reduce 等）：

充分利用 JavaScript 数组和对象的方法来处理 n8n 的数据结构。
- items.map(...): 对每个输入项进行转换，生成新的项数组。
- items.filter(...): 根据条件筛选输入项，返回符合条件的项数组。
- items.reduce(...): 将输入项聚合成单个值或对象（如统计总和）。

2.2 N8n 内置实用函数与库

n8n 提供的辅助函数：

在 Code 节点中，n8n 提供了一些辅助函数来更方便地操作节点参数和数据。
- getNodeParameter(parameterName, defaultValue): 获取当前 Code 节点配置中的参数值。
- getDataProperty(data, path): 安全地从复杂对象中获取嵌套属性。
集成第三方 npm 包：

默认情况下，Code 节点只支持 n8n 内置的少数几个库。如果您需要使用其他 npm 包，例如 xml2js 或 axios（尽管 HTTP Request 节点通常已足够），您需要：
1. 对于 Docker 部署：创建一个自定义的 Dockerfile，在其中安装所需的 npm 包，然后构建您的自定义 n8n 镜像。
2. 对于 npm/yarn 部署：在 n8n 的安装目录下运行 npm install <package-name>。
然后在 Code 节点中通过 require('package-name') 引入。

2.3 编写自定义 REST API 逻辑

结合 Webhook Trigger 和 Code 节点，n8n 可以作为轻量级的 API 服务，响应自定义请求。

通过 Code 节点模拟简单的API端点响应：

在 Webhook Trigger 收到请求后，您可以：

使用 Code 节点解析请求体、查询参数或请求头。
执行业务逻辑（例如查询数据库、调用其他 API）。
构建自定义的 JSON 响应。
将响应数据传递给 Webhook Response 节点，该节点会向发起请求的客户端返回数据。

// Code 节点示例：简单的API响应
const requestBody = items[0].json.body; // 从 Webhook Trigger 获取请求体

if (requestBody && requestBody.action === 'greet') {
  return [{
    json: {
      status: 'success',
      message: `Hello, ${requestBody.name || 'Guest'}!`
    }
  }];
} else {
  return [{
    json: {
      status: 'error',
      message: 'Invalid request'
    },
    // 设置HTTP状态码
    statusCode: 400
  }];
}

3. n8n 部署与维护进阶

生产环境的部署需要考虑数据持久性、可伸缩性和版本管理。

3.1 持久化数据管理

数据存储介质选择：SQLite (默认), PostgreSQL, MySQL：
- SQLite：适合开发和小型部署，数据存储在单个文件中。但并发性能差，不适合生产环境。
- PostgreSQL/MySQL：推荐用于生产环境。提供更好的并发处理能力、数据完整性和可伸缩性。在 Docker Compose 或 Kubernetes 中配置连接到外部数据库。
数据备份与恢复策略：

定期备份 n8n 使用的数据库是非常重要的。根据您选择的数据库，制定相应的备份策略：
- PostgreSQL/MySQL：使用 pg_dump / mysqldump 工具进行逻辑备份，或使用数据库的物理备份（如 EBS 快照）。
- n8n 数据卷：如果您使用 SQLite 或有自定义节点等文件，确保备份 n8n 的数据卷（例如 Docker 中的 n8n_data 卷）。
```
# PostgreSQL 备份示例
docker exec -t postgres pg_dumpall -c -U n8n > dump_$(date +%Y-%m-%d).sql
```

3.2 n8n 版本升级

推荐的升级流程与注意事项：
1. 备份数据：在升级前务必对数据库和数据卷进行完整备份。
2. 查看官方发布说明：仔细阅读 n8n 官方的升级指南和发行说明，了解是否有重大变更或不兼容性。
3. 停止 n8n 服务：在升级过程中停止 n8n 容器或进程。
4. 更新 Docker 镜像或 npm 包：
```
# Docker Compose 升级
docker-compose pull n8n
docker-compose up -d --remove-orphans # 确保清除旧的服务
```
```
# npm 升级
npm update n8n -g
```
5. 启动 n8n 服务：首次启动新版本时，n8n 可能会执行数据库迁移操作。
6. 验证功能：检查关键工作流是否正常运行。
兼容性检查：尤其在跨大版本升级时，某些节点配置或内部 API 可能会有变化。在测试环境充分验证后再推送到生产。

3.3 性能优化与伸缩性

工作流设计优化：
- 减少不必要的节点：避免重复的数据操作。
- 数据压缩：在 Code 节点中处理大数据前，可以考虑对数据进行压缩或只处理所需字段。
- 利用批处理：优先使用 Split In Batches 节点来分批处理大量数据，而不是一次性处理。
- 异步执行：对于不需要立即返回结果的任务，可以考虑使用队列或子工作流进行异步处理。
资源配置：CPU、内存、并发执行数：
- CPU & 内存：为 n8n 容器或 VM 分配足够的 CPU 和内存。复杂的工作流和高并发会消耗更多资源。
- 并发执行数 (`N8N_WORKFLOW_CONCURRENCY`)：这个环境变量控制 n8n 可以同时执行的工作流数量。默认是 10。如果您的服务器资源充足且有大量并发任务，可以适当提高。
```
# Docker Compose environment
- N8N_WORKFLOW_CONCURRENCY=20
```
分布式部署考量：多个工作器 (Worker) 节点与 Redis 队列：

当单个 n8n 实例无法满足性能需求时，可以部署多个 n8n Worker 实例。这些 Worker 实例共享同一个 PostgreSQL 数据库和 Redis 队列。Redis 充当任务队列，协调不同 Worker 之间的任务分配，实现负载均衡。

graph TD A[触发器] --> B(Redis 队列); B --> C1[n8n Worker 1]; B --> C2[n8n Worker 2]; C1 -- 读写 --> D[PostgreSQL]; C2 -- 读写 --> D;

在 Docker Compose 中配置多个 Worker：可以复制 n8n 服务并命名为 n8n_worker_1, n8n_worker_2 等，并确保它们连接到同一个 PostgreSQL 和 Redis 服务。

第四部分：实战项目与企业级应用

理论知识的掌握最终要通过实践来检验。以下两个详细的项目将帮助您巩固所学，并体会 n8n 的强大之处。

1. 项目一：自动化邮件通知与Google Sheets数据记录

场景： 您的网站有一个联系表单（例如使用 Typeform、Google Forms 或自定义HTML表单），当有用户提交表单后，您希望：

立即发送一封确认邮件给用户。
发送一封通知邮件给您的团队（例如销售团队或客服团队）。
将表单提交的数据自动记录到 Google Sheets 中，方便后续管理。

实现步骤：

Webhook Trigger：接收表单提交数据。
- 在 n8n 中创建一个新的工作流。
- 添加 Webhook 节点作为触发器。
- 配置 Webhook 节点：
  - HTTP Method: 选择 POST (因为表单提交通常是 POST 请求)。
  - 点击 "Webhook URL" 旁边的 "Activate" 按钮，n8n 会生成一个唯一的 URL。将这个 URL 配置到您的表单提交目标中（例如 Typeform 的 Webhook 设置，或自定义表单的 action 属性）。
- 测试：点击 "Test Workflow" 按钮，然后从您的表单提交一份测试数据。在 n8n 中，您应该能看到 Webhook 节点成功接收到数据，并显示其输出。
```
// Webhook Trigger 接收到的示例数据
{
  "json": {
    "name": "张三",
    "email": "zhangsan@example.com",
    "message": "我对贵公司产品很感兴趣！",
    "timestamp": "2023-10-27T10:30:00Z"
  }
}
```
Set 节点：提取并格式化所需数据。
- 将 Webhook Trigger 的输出连接到 Set 节点。
- 配置 Set 节点，将您需要的字段提取出来，并可以重命名或添加新字段，使数据结构更清晰。
  - Keep Only Set: 启用，只保留您设置的字段。
  - Values:
    - Name: fullName, Value: ${{ $json.name }}
    - Name: userEmail, Value: ${{ $json.email }}
    - Name: inquiryMessage, Value: ${{ $json.message }}
    - Name: submissionTime, Value: ${{ moment($json.timestamp).format('YYYY-MM-DD HH:mm:ss') }} (使用 moment 格式化时间)
Google Sheets 节点：将数据添加到指定工作表。
- 确保您已在 n8n 中配置了 Google Sheets 的 OAuth2 凭据。
- 将 Set 节点的输出连接到 Google Sheets 节点。
- 配置 Google Sheets 节点：
  - Credential: 选择您的 Google Sheets 凭据。
  - Operation: Append Row (添加行)。
  - Spreadsheet ID: 填写您的 Google Sheets 文档 ID（URL 中 /d/ 和 /edit 之间的那串字符）。
  - Sheet Name: 填写工作表名称（如 "Leads"）。
  - Data to Send: 设置要添加到表格的列名和对应的值。确保列名与您 Google Sheet 中的表头一致。
    - Name: 姓名, Value: ${{ $json.fullName }}
    - Name: 邮箱, Value: ${{ $json.userEmail }}
    - Name: 留言, Value: ${{ $json.inquiryMessage }}
    - Name: 提交时间, Value: ${{ $json.submissionTime }}
Gmail/SMTP 节点（用户）：发送确认邮件（包含动态数据）。
- 将 Google Sheets 节点的输出连接到 Gmail 或 SMTP Email 节点。
- 配置邮件节点：
  - Credential: 选择您的邮件凭据。
  - From Email: 您的发件邮箱。
  - To Email: ${{ $json.userEmail }} (发送给用户)。
  - Subject: 感谢您的咨询 - [您的公司名称]
  - Body: 编写邮件正文，可以使用 HTML 格式。
```
尊敬的 ${{ $json.fullName }}，

感谢您联系我们！我们已收到您的咨询：
“${{ $json.inquiryMessage }}”

我们将尽快与您联系。如有其他疑问，请随时回复此邮件。

祝好！
您的公司团队
```
Gmail/SMTP 节点（管理员）：发送通知邮件。
- 将 Google Sheets 节点的输出连接到第二个 Gmail 或 SMTP Email 节点。
- 配置邮件节点：
  - To Email: 您的团队邮箱地址（例如 sales@yourcompany.com）。
  - Subject: 【新咨询】来自 ${{ $json.fullName }} 的表单提交
  - Body: 包含所有提交详情，方便团队查看。
```
新的网站咨询已提交：

姓名：${{ $json.fullName }}
邮箱：${{ $json.userEmail }}
留言：${{ $json.inquiryMessage }}
提交时间：${{ $json.submissionTime }}

请及时处理。
```
错误处理：使用 Try/Catch 捕获发送邮件或写入表格的错误。
- 在 Google Sheets 节点和邮件节点之前，添加一个 Try 节点。
- 连接一个 Catch 节点到 Try 节点的错误输出。
- 在 Catch 节点之后，添加一个 Slack 或 Email 节点，用于发送错误通知给系统管理员，包含错误信息：${{ $json.error.message }}。

通过这个项目，您将掌握 Webhook 接收、数据提取、Google Sheets 写入、邮件发送以及基本的错误处理。

2. 项目二：RSS订阅内容自动发布到Telegram频道

场景： 您希望监控某个或多个技术博客、新闻网站的 RSS 订阅源，当有新文章发布时，自动将文章标题和链接发布到您的 Telegram 频道，并且需要实现去重，避免重复发布。

实现步骤：

RSS Feed Read Trigger：定时拉取RSS源最新内容。
- 在 n8n 中创建一个新的工作流。
- 添加 RSS Feed Read 节点作为触发器。
- 配置 RSS Feed Read 节点：
  - URL: 填写您要监控的 RSS 源 URL（例如：https://www.n8n.io/blog/rss.xml）。
  - Interval: 设置拉取频率（例如：每 30 分钟）。
  - Return All： 设置为 false，只返回最新的。
  - Read Older Feeds: 首次激活时可以设置为 false，避免拉取所有历史文章。
- 测试：点击 "Test Workflow"，查看 RSS 节点是否能正确获取文章列表。

Code 节点：实现去重逻辑。

为了避免重复发布，我们需要一个机制来记录已发布的文章。这里我们将使用 n8n 的内置持久化变量。

将 RSS Feed Read 节点的输出连接到 Code 节点。
在 Code 节点中编写 JavaScript：

const publishedUrlsKey = 'published_rss_urls';
let publishedUrls = await n8n.getContext(publishedUrlsKey, []); // 从上下文获取已发布的URL列表，默认空数组

const newItems = [];
for (const item of items) {
  const url = item.json.link; // 假设文章链接是唯一标识

  if (!publishedUrls.includes(url)) {
    // 如果URL不在已发布列表中，则为新文章
    newItems.push(item);
    publishedUrls.push(url); // 添加到已发布列表
  }
}

// 更新上下文中的已发布URL列表
await n8n.setContext(publishedUrlsKey, publishedUrls);

// 只返回新文章
return newItems;

上述代码使用了 n8n.getContext() 和 n8n.setContext()。这是 n8n 提供的内置方法，用于在工作流的多次执行之间持久化少量数据。

If 节点：判断是否有新文章。
- 将 Code 节点的输出连接到 If 节点。
- 配置 If 节点：
  - Value 1: ${{ $json.items.length }} (如果 Code 节点输出了新文章，则 items 数组长度会大于 0)。
  - Operation: Greater than (大于)。
  - Value 2: 0。
- 如果条件为 True (有新文章)，数据流进入 True 分支；如果为 False，工作流结束。
Telegram 节点：发送格式化后的文章信息到指定频道。
- 将 If 节点的 True 分支连接到 Telegram 节点。
- 确保您已在 n8n 中配置了 Telegram 的 Bot 凭据（Token）。
- 配置 Telegram 节点：
  - Credential: 选择您的 Telegram 凭据。
  - Operation: Send Message。
  - Chat ID: 填写您要发送的 Telegram 频道或群组 ID (需要以 @ 开头，或者数字 ID)。
  - Text: 编写要发送的消息内容，可以使用 Markdown 格式美化。
```
**新文章发布：**
${{ $json.title }}

_来源：${{ $json.creator }}_
[阅读原文](${{ $json.link }})
```
  - Parse Mode: 设置为 HTML 或 Markdown，以便解析消息中的链接和粗体等格式。
错误处理与日志记录：
- 在 Telegram 节点后添加一个 Log 节点，记录发布成功。
- 使用 Try/Catch 节点封装 Telegram 发布逻辑，如果发送失败，则通过邮件或 Slack 通知管理员。

此项目展示了如何使用定时触发、数据去重、条件判断和第三方服务集成。

3. 企业级应用案例概览

n8n 在企业中拥有广泛的应用场景，能够显著提升运营效率。

ERP/CRM数据同步：
- 场景： 确保不同系统间的数据一致性，例如销售线索从网站表单自动同步到 CRM (Salesforce, HubSpot)，或订单状态从电商平台同步到 ERP (SAP, Oracle)。
- 典型工作流： Cron触发 → CRM/ERP API节点（获取最新数据） → 数据清洗/转换 → 数据库/另一个CRM/ERP节点（更新/插入） → 审计日志记录。
- 关键： 需要处理数据映射、冲突解决和增量同步。
AI智能工单系统：
- 场景： 结合 AI 提升客户服务效率，例如自动分类客户咨询、生成回复草稿。
- 典型工作流： 邮件触发（新客户咨询） → OpenAI节点（分类工单/生成摘要） → CRM节点（创建工单并添加AI分析结果） → Slack/企业微信通知客服团队。
- 关键： 精准的 AI 模型调用和参数配置。
营销自动化：
- 场景： 自动化客户旅程，例如新用户注册后自动发送欢迎邮件、生日时发送优惠券。
- 典型工作流： 数据库触发（新用户注册） → If节点（判断用户属性） → SendGrid/Mailchimp节点（发送个性化邮件） → Wait节点（等待N天） → SendGrid/Mailchimp节点（发送第二封邮件）。
- 关键： 条件分支、定时任务和用户数据管理。
数据管道与ETL：
- 场景： 定时从多个数据源（API、数据库、文件）拉取数据，进行清洗、转换，然后加载到数据仓库或BI工具。
- 典型工作流： Cron触发 → HTTP Request/Database节点（数据提取） → Code/Set节点（数据转换与清洗） → PostgreSQL/BigQuery节点（数据加载） → 日志与通知。
- 关键： 批处理、错误重试、数据一致性校验。
API网关与微服务编排：
- 场景： n8n 可以作为轻量级的 API 网关，将外部请求路由到多个内部微服务，并对响应进行聚合或转换。
- 典型工作流： Webhook Trigger → HTTP Request节点（调用微服务A） → HTTP Request节点（调用微服务B） → Merge/Code节点（聚合响应） → Webhook Response节点。
- 关键： HTTP Request 的高级配置、Code 节点进行数据编排。

恭喜您！您已经完成了这份n8n从入门到精通的全栈教程。n8n的强大功能远不止于此，鼓励您继续探索其丰富的节点库，并尝试构建更多复杂的自动化工作流。实践是最好的老师，祝您在自动化之路上越走越远！

目录导航

n8n 从入门到精通全栈教程

预览结果：