调用Facebook graph_url_engagement_count触发限流如何控制调用量

报错信息：(#613) Calls to graph_url_engagement_count have exceeded the rate of 10 calls per 3600 seconds.

该限流规则仅针对单个独立链接生效，因此所有优化都围绕单个链接的调用频率管控展开，以下是可直接落地的方案：

方案1：新增本地缓存（优先级最高，成本最低） #

Facebook链接的互动数据更新频率较低，通常1小时内的变动完全可以忽略，直接给单个链接的查询结果加1小时有效期的缓存即可，基本可以避免99%的重复调用。

方案2：同链接请求合并 #

如果业务存在同一时间多个模块查询同一个链接数据的场景，添加pending请求复用逻辑，同一个链接的并发请求只会发起1次接口调用，所有请求共享返回结果。

方案3：限流触发降级兜底 #

如果确实需要高频更新单个链接的数据，在触发限流报错时直接返回最近一次的缓存结果，不要做无意义的重试，避免占用后续的调用额度。

优化后可直接使用的完整代码 #

// 缓存存储结构：key为链接，value为{ data: 互动数据, expireTime: 过期时间戳 }
const linkEngagementCache = new Map();
// 存储pending的请求，避免同链接并发重复调用
const pendingRequests = new Map();
// 缓存有效期设为1小时，也可根据业务需求调整为更长时间
const CACHE_EXPIRE_MS = 3600 * 1000;

const getFacebookStats = async (link) => {
  // 先查缓存，在有效期内直接返回
  const cached = linkEngagementCache.get(link);
  if (cached && Date.now() < cached.expireTime) {
    return cached.data;
  }
  // 有同链接的pending请求，直接复用返回结果
  if (pendingRequests.has(link)) {
    return pendingRequests.get(link);
  }
  // 生成新的请求Promise
  const requestTask = (async () => {
    try {
      const resp = await axios.get(
        `https://graph.facebook.com/v12.0/?id=${encodeURIComponent(link)}&fields=engagement&access_token=${BEARER_TOKEN_FACEBOOK}`
      );
      const engagement = resp.data.engagement;
      // 写入缓存
      linkEngagementCache.set(link, {
        data: engagement,
        expireTime: Date.now() + CACHE_EXPIRE_MS
      });
      return engagement;
    } catch (err) {
      // 触发限流时优先返回历史缓存兜底
      if (err?.response?.data?.error?.code === 613 && cached) {
        return cached.data;
      }
      console.error('Facebook接口查询失败', err);
      throw err;
    } finally {
      // 请求完成后清除pending记录
      pendingRequests.delete(link);
    }
  })();
  pendingRequests.set(link, requestTask);
  return requestTask;
};

额外说明 #

代码中额外添加了encodeURIComponent处理链接参数，避免链接带特殊字符时接口查询异常；如果需要更严格的限流管控，可以额外给每个链接加1小时窗口的调用次数计数器，达到10次阈值后直接返回缓存，无需发起请求即可提前规避限流。

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