使用async-await在MongoDB删除集合后执行任务的问题排查

哈哈，这个坑我之前也踩过！核心问题是你把RxJS的Observable和Promise搞混了，async-await只认Promise，而你现在await的是subscribe()的返回值，根本不会等HTTP请求完成，所以后续代码直接提前执行了。

为什么你的代码没按预期工作？ #

• await 只能等待 Promise 完成，但 this.saveInformationService.deleteRiskRatingInformation().subscribe(...) 返回的是RxJS的 Subscription 对象（用来取消订阅的），不是Promise。所以你的await等于白加，代码会直接跳过等待，立刻执行后面的console.log。
• 你在subscribe回调里写的日志确实会在请求完成后触发，但外面的后续任务根本不会等这个回调，所以执行顺序完全乱了。

正确的实现方法 #

有两种常用方式，根据你的习惯选：

方法1：把Observable转成Promise（推荐用async-await的场景） #

RxJS提供了firstValueFrom/lastValueFrom（RxJS 7+官方推荐），可以把Observable转换成Promise，这样就能正常用async-await了。

修改你的组件代码：

// 先导入需要的方法
import { firstValueFrom } from 'rxjs';

async deleteRiskRatingData2() {
  try {
    // 把Observable转成Promise，await会等待请求完成
    const data = await firstValueFrom(this.saveInformationService.deleteRiskRatingInformation());
    console.log('Deleting risk Rating');
    console.log(this.riskRatingTable);
    // 所有后续任务放在这里，保证在请求完成后执行
    console.log('TASKS TO BE EXECUTED AFTER DROPPING COLLECTION');
  } catch (err) {
    // 别忘了处理请求失败的情况
    console.error('删除集合失败:', err);
  }
}

如果你的RxJS版本是6.x，也可以用toPromise()，但它已经被官方废弃，优先用firstValueFrom。

方法2：在subscribe回调里执行后续任务 #

如果你不想转Promise，也可以把所有后续逻辑塞进subscribe的回调里，强制保证执行顺序：

deleteRiskRatingData2() {
  this.saveInformationService
    .deleteRiskRatingInformation()
    .subscribe({
      next: (data: string) => {
        console.log('Deleting risk Rating');
        console.log(this.riskRatingTable);
        // 后续任务必须放在这里
        console.log('TASKS TO BE EXECUTED AFTER DROPPING COLLECTION');
      },
      error: (err) => {
        console.error('删除失败:', err);
      }
    });
}

这种方式适合简单场景，但如果后续还有多层异步操作，容易陷入回调地狱，复杂流程还是推荐第一种方法。

额外小优化 #

你的后端用RiskRating.remove({}, ...)在MongoDB新版本里已经被废弃了，推荐更规范的写法：

• 如果是删除集合里所有文档：用deleteMany({})
• 如果是直接删除整个集合（更高效）：用drop()

修改后端server.js：

router.route('/dropRiskRatingCollection').get((req, res) => {
  // 直接删除整个集合，比删所有文档更快
  RiskRating.collection.drop((err) => {
    if (err) console.log(err);
    else res.json("Risk Rating Collection has been dropped!");
  });
});

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