NestJs Cron定时任务调用HttpService请求未执行问题排查

NestJS 中 @nestjs/axios 包提供的 HttpService 所有请求方法返回的都是 RxJS 的冷 Observable，冷 Observable 只有在被主动订阅时才会执行内部的实际请求逻辑。你当前的代码只在 Cron 方法中返回了 Observable 实例，没有触发订阅动作，因此 http 请求相关的逻辑永远不会执行。

你可以选择以下任意一种方案修复问题：

方案1：在 Cron 方法中直接订阅 Observable #

在调用 getPCFHealth 后调用 subscribe 方法触发执行，同时需要添加错误回调避免未捕获异常导致进程崩溃：

@Cron(CronExpression.EVERY_5_SECONDS)
triggerDataloaderCron() {
  this.logger.debug('called every 5 seconds');
  this.healthService.getPCFHealth().subscribe({
    next: (res) => this.logger.debug('Health check success', res),
    error: (err) => this.logger.error('Health check failed', err)
  });
}

方案2：将 Observable 转为 Promise 用 async/await 处理 #

如果你更熟悉常规 JS 异步语法，可以用 RxJS 提供的 firstValueFrom 方法将 Observable 转为 Promise，配合 async/await 和 try/catch 处理逻辑：

import { firstValueFrom } from 'rxjs';

@Cron(CronExpression.EVERY_5_SECONDS)
async triggerDataloaderCron() {
  this.logger.debug('called every 5 seconds');
  try {
    const res = await firstValueFrom(this.healthService.getPCFHealth());
    this.logger.debug('Health check success', res);
  } catch (err) {
    this.logger.error('Health check failed', err);
  }
}

• 你的整体实现思路没有问题，只是遗漏了 RxJS 冷 Observable 需要订阅才会执行的特性。
• 不建议在 getHealth 方法内部直接订阅 Observable，否则调用方无法拿到返回结果，也无法灵活处理不同场景的错误逻辑，最佳实践是将 Observable 返回给调用方，由调用方决定处理方式。

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