Node.js新手求助：如何将嵌套异步函数结果传递至父函数

问题根源 #

Mongoose的数据库查询是异步操作——你在异步回调外部直接访问companies变量时，查询还没跑完，自然拿不到数据。必须等异步操作执行完，才能用它返回的结果。

解决方案：用async/await理顺异步逻辑 #

async/await能把异步代码写得像同步代码一样，新手好理解也好上手。

错误写法示例（你当前的问题场景） #

function buildSearchReply() {
  let search_reply = {};
  // 异步查Companies集合，回调里能打印数据
  Companies.find({}, (err, companies) => {
    console.log(companies);
  });
  // 这里执行时，上面的find还没结束，companies根本没值
  search_reply.name = companies[0]['name'];
  return search_reply;
}

改成async/await的正确写法 #

// 把函数声明为async
async function buildSearchReply() {
  let search_reply = {};
  try {
    // 用await等查询完成，直接拿到companies数据
    const companies = await Companies.find({});
    // 现在companies已经有数据了，正常访问就行
    search_reply.name = companies[0]['name'];
    
    // 顺带处理Data和Companies的配对逻辑
    const dataList = await Data.find({});
    // 比如按Data里的companyId匹配Companies的_id
    const pairedData = dataList.map(item => {
      const matchedCompany = companies.find(company => company._id.toString() === item.companyId);
      return {
        ...item.toObject(),
        companyName: matchedCompany ? matchedCompany.name : '未知企业'
      };
    });
    search_reply.pairedData = pairedData;
  } catch (err) {
    // 捕获查询时的错误，避免程序崩掉
    console.error('数据库查询出错：', err);
    search_reply.error = '查询失败';
  }
  return search_reply;
}

// 调用async函数时，要么用await（得放在async函数里），要么用.then()
async function main() {
  const result = await buildSearchReply();
  console.log(result);
}
main();

关键注意点 #

• 所有需要等异步结果的操作，都要加await，而且必须放在async函数里。
• 用try/catch包着异步操作，处理数据库可能抛出的错误。
• 如果你的Data集合里本来就有指向Companies的关联字段（比如companyId是ObjectId类型），可以直接用Mongoose的populate自动关联，不用手动配对：

// 先确保Data的Schema里定义了关联
const dataSchema = new mongoose.Schema({
  companyId: {
    type: mongoose.Schema.Types.ObjectId,
    ref: 'Companies' // 指定关联Companies集合
  },
  // 其他字段...
});

async function getPairedData() {
  try {
    // 查询Data的同时，自动把companyId换成对应的企业name
    const pairedData = await Data.find({}).populate('companyId', 'name');
    console.log(pairedData[0].companyId.name);
    return {
      pairedData,
      name: pairedData[0]?.companyId?.name || '无匹配企业'
    };
  } catch (err) {
    console.error('关联查询出错：', err);
    return { error: '查询失败' };
  }
}

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