Node.js Express中Async/Await未等待执行的问题排查

你的代码存在几个核心问题，导致getCars无法正确返回结果，进而无法在/cars路由中返回数据：

1. fs.readFile回调版本无法被await：
   你使用的是回调形式的fs.readFile，它不会返回Promise，所以外层的await完全不起作用，getCars会直接执行完毕返回undefined，不会等待文件读取和后续处理完成。

2. emailCars未初始化：
   你直接通过emailCars = [...emailCars, ...]拼接数组，但emailCars从未被声明和初始化，会触发引用错误。

3. 错误使用原数组而非处理后的数组：
   你对filtered数组做了过滤和排序，但最终取的是result[car][0]和result[car][1]——这是未处理的原数组元素，不是你过滤排序后的结果。

4. 回调内的return无法传递到外层函数：
   你在fs.readFile的回调里return emailCars，但这个返回值不会被外层的async函数捕获，外层函数已经提前返回了。

修复后的代码 #

1. 修正getCars函数 #

const fs = require('fs').promises;
const path = require('path');

const getCars = async () => {
  // 初始化结果数组
  let emailCars = [];
  // 使用Promise化的readFile配合await读取文件
  const data = await fs.readFile(path.join(__dirname, 'cars.json'));
  const cars = JSON.parse(data);

  // 分组逻辑保持不变
  const groupBy = (xs, f) => {
    return xs.reduce(
      (r, v, i, a, k = f(v)) => ((r[k] || (r[k] = [])).push(v), r),
      {}
    );
  };

  const result = groupBy(cars, (c) => c.locationName);

  // 遍历分组后的地点
  for (const location of Object.keys(result)) {
    console.log(location);
    // 过滤出包含arrivalDate的车辆
    let filtered = result[location].filter(obj => 'arrivalDate' in obj);

    // 按日期倒序排序（最新的在前）
    filtered.sort((a, b) => {
      const keyA = new Date(a.arrivalDate.split(' ')[0]);
      const keyB = new Date(b.arrivalDate.split(' ')[0]);
      return keyB - keyA;
    });

    // 取前2条，自动处理数组长度不足2的情况
    const topCars = filtered.slice(0, 2);
    emailCars.push({ [location]: topCars });
  }

  console.log('returning', emailCars);
  return emailCars;
};

2. 优化路由的错误处理 #

app.get('/cars', async (req, res) => {
  try {
    const result = await getCars();
    console.log('result:', result);
    res.send(result);
  } catch (error) {
    console.error(error);
    // 给客户端返回明确的错误响应
    res.status(500).send({ error: '获取车辆数据失败' });
  }
});

额外优化点 #

• 用path.join(__dirname, 'cars.json')替代字符串拼接路径，避免不同系统的路径分隔符问题。
• 用'arrivalDate' in obj替代Object.keys(obj).includes('arrivalDate')，判断属性存在的效率更高。
• 排序时直接通过keyB - keyA实现倒序，省去额外的reverse()调用。

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