如何用SDK遍历列表发起顺序网络请求？Coinbase Node SDK求助

我之前踩过类似的异步遍历坑，大概率是你在循环处理异步请求的方式不对，或者分页逻辑没捋清楚。下面给你一套可行的实现思路和代码示例，亲测能用：

先排查核心问题 #

• 异步遍历方式错误：如果用forEach/map这类方法配合await，其实不会等待每个请求完成，会导致所有请求同时发起，结果顺序混乱甚至被API限流。必须用for...of循环来保证异步操作按顺序执行（或者用Promise.all并行，但要注意速率限制）。
• 分页逻辑没处理到位：Coinbase的交易接口是分页返回的，要通过返回结果里的pagination.next_uri来获取下一页数据，直到收集够10条或者没有更多交易。

正确实现步骤&代码示例 #

首先确保你已经正确初始化了Coinbase客户端（API密钥、权限都配置好），然后按下面的逻辑来写：

// 注意：如果是普通Coinbase而非Pro，安装并引入'coinbase'包
const CoinbasePro = require('coinbase-pro');
const client = new CoinbasePro.AuthenticatedClient(
  '你的API_KEY',
  '你的API_SECRET',
  '你的PASSPHRASE',
  'https://api.pro.coinbase.com' // 根据环境切换URL，比如沙箱环境用https://api-public.sandbox.pro.coinbase.com
);

async function fetchTop10TransactionsPerAccount() {
  try {
    // 获取账户列表（如果已经有账户列表，直接用你的数组即可）
    const accounts = await client.getAccounts();
    const allAccountTransactions = [];

    // 用for...of循环处理异步遍历，确保每个账户的请求依次完成
    for (const account of accounts) {
      let collectedTransactions = [];
      let nextPageUri = null;

      do {
        // 第一次请求不传分页参数，后续用nextPageUri获取下一页
        const transactionResponse = nextPageUri
          ? await client.getTransactions(account.id, { uri: nextPageUri })
          : await client.getTransactions(account.id);
        
        // 合并当前页的交易数据
        collectedTransactions = [...collectedTransactions, ...transactionResponse.data];
        // 更新下一页的URI
        nextPageUri = transactionResponse.pagination.next_uri;

        // 收集够10条就停止分页请求
        if (collectedTransactions.length >= 10) {
          collectedTransactions = collectedTransactions.slice(0, 10);
          break;
        }
      } while (nextPageUri); // 还有下一页就继续请求

      // 将该账户的交易信息存入总数组，带上账户标识方便区分
      allAccountTransactions.push({
        accountId: account.id,
        accountName: account.name,
        top10Transactions: collectedTransactions
      });
    }

    return allAccountTransactions;
  } catch (error) {
    console.error('获取交易时出错:', error);
    throw error;
  }
}

// 调用函数并处理结果
fetchTop10TransactionsPerAccount()
  .then(result => console.log('所有账户的前10条交易:', result))
  .catch(err => console.error(err));

额外注意事项 #

• API速率限制：Coinbase对请求频率有严格限制，如果账户数量较多，建议在循环中加入await new Promise(resolve => setTimeout(resolve, 1000))这类延迟，避免被限流。
• 权限检查：确保你的API密钥拥有view权限，否则无法访问账户和交易数据。
• 错误处理优化：如果不想因为单个账户出错导致整个流程中断，可以在遍历账户的循环内部加入try/catch，捕获单个账户的错误并跳过。

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