Node.js如何在循环中调用Facebook API且不触发速率限制？

刚好之前帮朋友处理过类似的Facebook API批量调用问题，你的痛点我太懂了——普通异步循环会瞬间把请求砸过去，哪怕你尝试用Promise加setTimeout，如果没控制好执行顺序，所有延迟的请求还是会几乎同时触发，根本起不到限流作用。

问题根源 #

你之前的方案无效，核心原因是同步循环会一次性创建所有的setTimeout任务，它们的延迟时间都是20ms，到点后会同时发起请求，本质还是并发打满接口，自然触发速率限制。

解决方案1：严格串行请求控制 #

这个方案会让每个请求完成后，等待20ms再发起下一个，完全按顺序执行，绝对不会触发速率限制（只要20ms的间隔符合Facebook的要求）。缺点是处理200万条数据耗时会比较长（200万*20ms≈111小时），但胜在稳定。

async function processIdsSequentially(idArray) {
  for (const id of idArray) {
    try {
      // 调用你的Facebook API接口
      const result = await callFacebookAPI(id);
      console.log(`处理ID ${id} 成功`, result);
      // 等待20ms再发起下一个请求
      await new Promise(resolve => setTimeout(resolve, 20));
    } catch (error) {
      console.error(`处理ID ${id} 失败:`, error);
      // 遇到错误可以适当延长等待时间，避免连续报错
      await new Promise(resolve => setTimeout(resolve, 1000));
    }
  }
}

// 封装你的API调用逻辑
async function callFacebookAPI(idSender) {
  const response = await fetch(`https://graph.facebook.com/v18.0/${idSender}/[你的端点]`, {
    method: 'GET', // 或者POST，根据你的需求调整
    headers: {
      'Authorization': 'Bearer [你的访问令牌]',
      'Content-Type': 'application/json'
    }
  });

  if (!response.ok) {
    // 特别处理429速率限制错误，后续可以加重试逻辑
    if (response.status === 429) {
      throw new Error(`速率限制触发，剩余请求: ${response.headers.get('x-rate-limit-remaining')}`);
    }
    throw new Error(`API请求失败，状态码: ${response.status}`);
  }

  return response.json();
}

解决方案2：带延迟的批量并发（平衡速度与限流） #

如果觉得串行太慢，可以用分批并发+请求间隔的方式，既保证一定的处理速度，又不会触发速率限制。比如每批处理10个请求，每个请求之间间隔20ms，批次之间再加一点延迟。

async function processIdsInBatches(idArray, batchSize = 10, requestDelay = 20, batchDelay = 500) {
  for (let i = 0; i < idArray.length; i += batchSize) {
    const currentBatch = idArray.slice(i, i + batchSize);
    
    // 对批次内的每个ID，依次发起请求，每个请求延迟 index*requestDelay
    // 这样同一批次里的请求会按20ms的间隔依次发出，不会同时打过去
    const batchPromises = currentBatch.map(async (id, index) => {
      await new Promise(resolve => setTimeout(resolve, index * requestDelay));
      try {
        return await callFacebookAPI(id);
      } catch (error) {
        console.error(`处理ID ${id} 失败:`, error);
        return null;
      }
    });

    // 等待当前批次所有请求完成
    await Promise.all(batchPromises);
    // 批次之间加延迟，进一步降低整体请求速率
    await new Promise(resolve => setTimeout(resolve, batchDelay));
  }
}

额外优化技巧 #

• 动态调整延迟：Facebook API会返回x-rate-limit-remaining和x-rate-limit-reset响应头，可以根据这些信息动态调整等待时间。比如当剩余请求数不足10时，自动等待到重置时间后再继续请求，避免触发429错误。
• 指数退避重试：对429错误或者其他临时错误，使用指数退避策略重试（比如第一次等1s，第二次2s，第三次4s），不要立刻重试。
• 持久化进度：因为处理200万条数据需要很久，建议每隔一段时间把已处理的ID记录下来，中途崩溃后可以从断点继续，不用重新开始。

内容的提问来源于stack exchange，提问作者frabis