当前位置：首页 > news >正文

n8n循环处理完全指南

news 2025/8/10 7:32:32

一、使用Split In Batches节点实现可视化循环

适用场景：批量处理大量数据（如100条新闻分10批处理）

添加Split In Batches节点
配置节点参数：

批量大小(Batch Size)：10
输入数据：{{ $json.items }}

在循环体中处理单条数据
使用"循环完成"连接后续节点

示例配置

// 输入数据表达式
{{ $node["RSS获取"].json["items"] }}
// 循环体内访问当前项
{{ $json.title }}
{{ $json.summary }}

二、在Code节点中使用JavaScript循环

1. forEach循环处理关键词数组

// ... existing code ...
// 处理关键词并添加分类标签
let categorizedKeywords = [];
$json.keywords.forEach(keyword => {
  // 定义关键词分类映射
  const categories = {
    "技术趋势": ["GPT-4", "大模型", "生成式AI"],
    "核心技术": ["深度学习", "神经网络", "自然语言处理"],
    "头部企业": ["OpenAI", "谷歌", "百度", "微软"]
  };

  // 查找关键词所属分类
  let category = "其他";
  for(const [cat, keywords] of Object.entries(categories))
  {
    if(keywords.includes(keyword)) {
      category = cat;
      break;
    }
  }

  categorizedKeywords.push({
    name: keyword,
    category: category
  });
});
return {
  title: $json.title,
  pubDate: $json.pubDate,
  summary: $json.summary,
  keywords: categorizedKeywords,
  rating: $json.rating,
  link: $json.link
};
// ... existing code ...

2. map方法处理数组生成HTML列表

// 将新闻列表转换为HTML列表
{{ $json.items.map(item => `
  <div class="news-item">
    <h3>${item.title}</h3>
    <p>${item.summary.substring(0, 100)}...</p>
    <div class="meta">${item.pubDate}</div>
  </div>
`).join('') }}

如果是多条输入一起处理的模式，请使用下面代码：

{{ $input.all().map(item => `
<h1>${item.json.output.title}</h1>
<div class="news-item">
<h3 class="title">${item.json.output.title}</h3>
<div >
${item.json.output.pubDate}
<span class="rating">${item.json.output.rating}</span>
</div>
<p class="summary">${item.json.output.summary}</p>
<p><span class="keywords">关键词:</span> ${item.json.output.keywords.join(', ')}</p>
<p><a href="${item.json.output.link}" class="link" target="_blank">请阅读原文</a></p>
</div>
`)}}

3. for循环实现嵌套数据处理

// 处理包含嵌套结构的新闻数据
let result = [];
for(let i = 0; i < $json.news.length; i++) {
  const news = $json.news[i];

  // 处理嵌套的相关文章
  let relatedArticles = [];
  if(news.related && news.related.length > 0) {
    for(let j = 0; j < news.related.length; j++) {
      relatedArticles.push({
        id: news.related[j].id,
        title: news.related[j].title,
        // 只保留必要字段
      });
    }
  }

  result.push({
    title: news.title,
    pubDate: news.pubDate,
    relatedCount: relatedArticles.length,
    related: relatedArticles
  });
}
return { processedNews: result };

三、使用Loop节点实现条件循环

适用场景：需要满足特定条件才停止的循环（如重试API直到成功）

添加Loop节点并设置循环条件：
{{ $node["API请求"].json["status"] !== "success" &&
$json.retries < 3 }}
循环体内配置：
- API请求节点
- 错误处理节点
- 重试计数更新：{{ $json.retries + 1 }}
循环完成后连接后续节点

四、实战案例：批量处理新闻数据

需求：将多条新闻按关键词分类并统计数量

// 在Code节点中处理多条新闻数据
const newsItems = $node["RSS获取"].json["items"];
const categoryStats = {
  "技术趋势": 0,
  "核心技术": 0,
  "头部企业": 0,
  "应用场景": 0,
  "其他": 0
};
// 定义关键词分类
const keywordCategories = {
  "技术趋势": ["GPT-4", "大模型", "生成式AI", "AGI", "AIGC"],
  "核心技术": ["深度学习", "神经网络", "自然语言处理", "计算机视
  觉"],
  "头部企业": ["OpenAI", "谷歌", "百度", "微软", "阿里", "腾讯
  "],
  "应用场景": ["医疗", "教育", "金融", "自动驾驶", "智能制造"]
};
// 遍历所有新闻
newsItems.forEach(news => {
  let newsCategory = "其他";

  // 遍历新闻关键词
  news.keywords.forEach(keyword => {
    // 匹配分类
    for(const [category, keywords] of Object.entries
    (keywordCategories)) {
      if(keywords.includes(keyword)) {
        newsCategory = category;
        categoryStats[category]++;
        return; // 找到分类后跳出循环
      }
    }
  });

  // 为新闻添加分类
  news.category = newsCategory;
});
return {
  totalNews: newsItems.length,
  categoryStats: categoryStats,
  processedNews: newsItems
};

五、循环处理常见问题解决

1. 避免无限循环

// 添加最大循环次数保护
const maxIterations = 100;
let count = 0;
let result = [];
let currentItem = $json.firstItem;
while(currentItem && count < maxIterations) {
  result.push(currentItem);
  currentItem = currentItem.nextItem;
  count++;
}
return { items: result, iterations: count };

2. 循环中的异步处理

// 使用Promise.all处理异步操作
async function processItems(items) {
  const promises = items.map(async (item) => {
    // 异步API调用
    const response = await fetch('https://api.example.com/
    process', {
      method: 'POST',
      body: JSON.stringify(item)
    });
    return response.json();
  });

  return Promise.all(promises);
}
// 执行并返回结果
const processed = await processItems($json.items);
return { processedItems: processed };