NestJS中如何从嵌套数组创建Promise并行执行并生成指定结果

核心问题分析 #

• 问题本质是RxJS Observable未转换为Promise，导致直接返回流对象而非实际API响应数据；
• 未正确利用Promise.all实现并行请求，也没组装出shipmentNumber + trackingDetails的预期结构。

解决方案步骤 #

1. 将Observable转换为Promise #

NestJS的HttpService返回RxJS Observable，需转为Promise才能配合Promise.all使用。RxJS 7+推荐用firstValueFrom（获取第一个发射值，适配HTTP单次响应场景）或lastValueFrom，替代已废弃的toPromise()。

2. 并行执行所有API请求 #

用Promise.all批量处理订单的API调用，实现无依赖请求的并行执行，大幅提升效率。

3. 组装预期结果结构 #

在每个请求的Promise回调中直接组装shipmentNumber与对应trackingDetails，最终得到符合需求的结果数组。

代码示例 #

基础订单结构处理 #

假设订单数组结构如下：

interface Order {
  shipmentNumber: string;
  // 其他订单字段，如订单ID、客户信息等
}

处理函数实现：

import { firstValueFrom } from 'rxjs';
import { HttpService } from '@nestjs/axios';

@Injectable()
export class OrderService {
  constructor(private readonly httpService: HttpService) {}

  // 你的API调用方法，返回Observable
  private trackSalesOrder(order: Order) {
    return this.httpService.get(`/api/tracking/${order.shipmentNumber}`);
  }

  async processOrders(orders: Order[]) {
    // 为每个订单创建API请求Promise
    const requestPromises = orders.map(async (order) => {
      // 将Observable转为Promise，获取响应数据（根据实际API结构调整data路径）
      const response = await firstValueFrom(this.trackSalesOrder(order));
      const trackingDetails = response.data;

      // 组装预期结构
      return {
        shipmentNumber: order.shipmentNumber,
        trackingDetails: trackingDetails
      };
    });

    // 并行执行所有Promise，等待全部完成
    const finalResult = await Promise.all(requestPromises);

    return finalResult;
  }
}

嵌套订单结构处理 #

如果订单是嵌套结构（如单个订单包含多个shipment）：

interface Shipment {
  shipmentNumber: string;
}

interface NestedOrder {
  orderId: string;
  shipments: Shipment[];
}

async processNestedOrders(nestedOrders: NestedOrder[]) {
  // 扁平化提取所有shipment
  const allShipments = nestedOrders.flatMap(order => order.shipments);

  const requestPromises = allShipments.map(async (shipment) => {
    const response = await firstValueFrom(this.trackSalesOrder(shipment));
    return {
      shipmentNumber: shipment.shipmentNumber,
      trackingDetails: response.data
    };
  });

  return await Promise.all(requestPromises);
}

错误处理优化 #

避免单个请求失败导致全部任务终止，可在每个Promise中添加错误捕获：

const requestPromises = orders.map(async (order) => {
  try {
    const response = await firstValueFrom(this.trackSalesOrder(order));
    return {
      shipmentNumber: order.shipmentNumber,
      trackingDetails: response.data,
      success: true
    };
  } catch (error) {
    // 记录错误日志，返回失败标记
    console.error(`查询${order.shipmentNumber}跟踪信息失败:`, error);
    return {
      shipmentNumber: order.shipmentNumber,
      error: (error as Error).message,
      success: false
    };
  }
});

关键说明 #

• 并行效率：Promise.all同时发起所有请求，效率远高于串行遍历（for await...of），仅适用于无依赖的独立请求场景；
• Observable转Promise：必须转换后才能用await获取实际数据，否则返回的是Observable流对象，无法直接得到API响应；
• RxJS版本兼容：若使用RxJS 6及以下，可临时用toPromise()，但建议升级到RxJS 7+使用firstValueFrom。

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