循环中用async/await与Promise.all调用递归函数的问题排查

核心问题是你的递归分页函数没有正确返回完整的Promise链——虽然函数内部能拿到数据，但没有把最终结果通过Promise传递出去，导致Promise.all接收到的是一堆resolved为undefined的Promise。

解决步骤与代码示例 #

1. 编写正确返回Promise的递归分页函数

确保递归函数的每一个分支都返回Promise，并且最终resolve到聚合后的完整数据：

// 单个分页的GraphQL请求函数
async function fetchAccountStatsPage(accountId, cursor = null) {
  // 替换成你的实际GraphQL请求逻辑
  const res = await fetch('/graphql', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      query: `
        query AccountStats($accountId: ID!, $cursor: String) {
          accountStats(accountId: $accountId, after: $cursor) {
            items { /* 你的统计字段：比如 totalAmount, count 等 */ }
            pageInfo {
              hasNextPage
              endCursor
            }
          }
        }
      `,
      variables: { accountId, cursor }
    })
  });
  const { data } = await res.json();
  return data.accountStats;
}

// 递归聚合所有分页数据的函数
async function fetchAllAccountStats(accountId) {
  // 内部递归函数，负责累加数据
  async function recursiveFetch(cursor, accumulated) {
    const page = await fetchAccountStatsPage(accountId, cursor);
    const newAccumulated = [...accumulated, ...page.items];

    if (page.pageInfo.hasNextPage) {
      // 有下一页时，递归调用并返回Promise链
      return recursiveFetch(page.pageInfo.endCursor, newAccumulated);
    } else {
      // 无下一页时，返回最终累加的数据
      return newAccumulated;
    }
  }

  // 初始调用，返回整个递归流程的Promise
  return recursiveFetch(null, []);
}

2. 并行处理所有账户的请求

遍历账户数组，为每个账户生成对应的递归分页Promise，再用Promise.all等待所有请求完成：

// 假设你的账户对象数组
const accounts = [{ id: 'acc_001' }, { id: 'acc_002' }, { id: 'acc_003' }];

// 生成每个账户的统计请求Promise
const statsPromises = accounts.map(account => fetchAllAccountStats(account.id));

// 并行执行并获取所有结果
Promise.all(statsPromises)
  .then(allAccountStats => {
    // allAccountStats 就是各账户的统计结果数组，顺序与accounts一致
    console.log('所有账户统计数据:', allAccountStats);
  })
  .catch(error => {
    console.error('请求失败:', error);
  });

关键注意事项 #

• 避免Promise链断裂：递归函数的每一步都要确保返回Promise，不能在分支里只执行逻辑而不返回值。
• 并发限制：如果账户数量较多，要注意API的并发限流规则——可以手动实现分批处理（比如每次处理5个账户，完成后再处理下一批），避免触发限流。
• 错误处理：如果需要个别请求失败不影响整体，可以用Promise.allSettled替代Promise.all，之后再过滤成功的结果。

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