n8n 工作流设计最佳实践：构建高效稳定的自动化流程

用户注册 → 发送欢迎邮件 → 创建 CRM 记录 → 添加到邮件列表 → 生成报告 → 通知管理员

// 主工作流
Webhook → 数据验证 → 调用子工作流 → 返回结果

// 子工作流：用户数据处理
数据清洗 → 数据验证 → 数据存储 → 返回处理结果

// 同步处理（不推荐）
接收数据 → 长时间处理 → 返回结果

// 异步处理（推荐）
接收数据 → 立即返回确认 → 后台队列处理 → 完成后通知

// HTTP Request 节点错误处理示例
{
  "errorHandling": {
    "continueOnFail": true,
    "retryOnFail": true,
    "maxRetries": 3,
    "retryInterval": 1000
  }
}

主要服务 API → [失败] → 备用服务 API → [失败] → 记录错误并通知

// 错误处理工作流
错误触发器 → 错误分类 → 严重性评估 → 发送告警 → 记录日志

// 在 Function 节点中处理错误
const error = $input.all()[0].error;
const errorData = {
  workflowId: $workflow.id,
  executionId: $execution.id,
  errorMessage: error.message,
  timestamp: new Date().toISOString(),
  severity: error.message.includes('timeout') ? 'high' : 'medium'
};

return { errorData };

for (const item of items) {
  await apiCall(item);
}

// 使用批处理 API
await batchApiCall(items);

// 或者分批处理
const batches = chunk(items, 100);
for (const batch of batches) {
  await processBatch(batch);
}

// 高频数据监控
Schedule Trigger: "*/1 * * * *" // 每分钟

// 日常报告生成
Schedule Trigger: "0 9 * * 1-5" // 工作日上午9点

// 数据备份
Schedule Trigger: "0 2 * * 0" // 每周日凌晨2点

// Function 节点中过滤数据
const filteredData = $input.all().map(item => ({
  id: item.json.id,
  name: item.json.name,
  email: item.json.email
  // 移除不必要的字段
}));

return filteredData;

// 数据验证 Function 节点
function validateInput(data) {
  const required = ['email', 'name'];
  const missing = required.filter(field => !data[field]);

  if (missing.length > 0) {
    throw new Error(`Missing required fields: ${missing.join(', ')}`);
  }

  if (!isValidEmail(data.email)) {
    throw new Error('Invalid email format');
  }

  return data;
}

return $input.all().map(item => validateInput(item.json));

// 数据清洗示例
function cleanData(item) {
  return {
    name: item.name?.trim()?.toLowerCase(),
    email: item.email?.toLowerCase(),
    phone: item.phone?.replace(/\D/g, ''), // 只保留数字
    createdAt: new Date().toISOString()
  };
}

// 基于 ID 去重
const uniqueItems = $input.all().filter((item, index, array) =>
  array.findIndex(i => i.json.id === item.json.id) === index
);

function sanitizeData(data) {
  const sensitiveFields = ['password', 'ssn', 'creditCard'];
  const sanitized = { ...data };

  sensitiveFields.forEach(field => {
    if (sanitized[field]) {
      sanitized[field] = '***';
    }
  });

  return sanitized;
}

function logEvent(level, message, metadata = {}) {
  const logEntry = {
    timestamp: new Date().toISOString(),
    level,
    workflowId: $workflow.id,
    executionId: $execution.id,
    message,
    metadata
  };

  console.log(JSON.stringify(logEntry));
  return logEntry;
}

// 审计日志示例
const auditLog = {
  action: 'user_created',
  userId: userData.id,
  timestamp: new Date().toISOString(),
  executor: $execution.mode,
  changes: {
    before: null,
    after: userData
  }
};

// 测试数据
const testCases = [
  { input: { email: '[email protected]' }, expected: true },
  { input: { email: 'invalid-email' }, expected: false }
];

// 在 Function 节点中运行测试
testCases.forEach(test => {
  const result = validateEmail(test.input.email);
  console.assert(result === test.expected, `Test failed for ${test.input.email}`);
});

测试数据生成 → 执行主工作流 → 验证结果 → 清理测试数据

# 用户注册工作流

## 目的
处理新用户注册请求，包括数据验证、账户创建和欢迎邮件发送。

## 触发条件
- Webhook 接收到 POST /api/register 请求

## 数据流
1. 接收用户数据
2. 验证邮箱和必填字段
3. 检查用户是否已存在
4. 创建用户账户
5. 发送欢迎邮件
6. 返回成功响应

## 错误处理
- 数据验证失败：返回 400 错误
- 用户已存在：返回 409 错误
- 邮件发送失败：记录错误但不阻止流程

const apiUrl = 'https://api.example.com/v1/users';

const apiUrl = $env.API_BASE_URL + '/v1/users';

async function processLargeDataset(query) {
  let page = 1;
  const pageSize = 100;

  while (true) {
    const data = await fetchData(query, page, pageSize);
    if (data.length === 0) break;

    await processData(data);
    page++;
  }
}

let attempts = 0;
const maxAttempts = 10;

while (condition && attempts < maxAttempts) {
  // 处理逻辑
  attempts++;
}