如何仅在发起GET请求时触发Cron Job，而非服务器启动时？

问题分析 #

你当前的实现存在两个核心问题：

• @Cron装饰器定义的任务默认会在应用启动（或热重载）时自动注册并启用，即便你在方法内尝试停止任务，代码保存触发热重载后，任务会被重新初始化并再次启动
• 首次触发任务后，后续服务器重启时，@Cron任务会默认重新启用，导致自动运行

你的需求是仅当收到GET请求时才启动任务，运行10分钟后停止，且服务器重启/代码热重载不会自动触发任务，当前实现的startTime是类初始化时刻（服务器启动时间）而非请求触发时刻，加上@Cron的自动启用机制，完全不符合预期逻辑。

修正方案 #

改为手动创建CronJob实例，仅在GET请求到达时初始化并启动任务，彻底规避自动触发问题：

import { Injectable, Logger, OnModuleInit } from '@nestjs/common';
import { SchedulerRegistry, CronJob, CronExpression } from '@nestjs/schedule';
import { airQualityModel } from './your-model-path'; // 替换为你的模型实际路径

@Injectable()
export class AirQualityService implements OnModuleInit {
  private readonly logger = new Logger(AirQualityService.name);
  private job: CronJob | null = null;
  private readonly jobName = 'myJob';

  constructor(private readonly schedulerRegistry: SchedulerRegistry) {}

  // 模块初始化时清理残留任务，避免重启时旧任务自动运行
  async onModuleInit() {
    try {
      const existingJob = this.schedulerRegistry.getCronJob(this.jobName);
      existingJob.stop();
      this.schedulerRegistry.deleteCronJob(this.jobName);
    } catch (e) {
      // 任务不存在时忽略
    }
  }

  // 供GET请求调用的任务触发方法
  async triggerParisAirQualityJob() {
    // 防止重复触发正在运行的任务
    if (this.job && this.job.running) {
      this.logger.verbose('Paris air quality job is already running');
      return { message: '任务已在执行中' };
    }

    const startTime = new Date().getTime();
    const numberOfMinutes = 10;
    const endTime = startTime + 1000 * 60 * numberOfMinutes;

    // 手动创建CronJob实例
    this.job = new CronJob(CronExpression.EVERY_MINUTE, async () => {
      this.logger.verbose(`获取巴黎空气质量数据`);
      const result = await this.getCityAirQuality({
        latitude: '48.856613',
        longitude: '2.352222',
      });

      const airQuality = new airQualityModel({
        result,
        datetime: new Date().toLocaleString(),
      });
      await airQuality.save();

      // 到达结束时间后停止并清理任务
      if (new Date().getTime() >= endTime) {
        this.job.stop();
        this.schedulerRegistry.deleteCronJob(this.jobName);
        this.job = null;
        this.logger.verbose('巴黎空气质量任务已停止');
      }
    });

    // 注册并启动任务
    this.schedulerRegistry.addCronJob(this.jobName, this.job);
    this.job.start();
    this.logger.verbose('巴黎空气质量任务已启动');

    return { message: '任务启动成功' };
  }

  // 你的空气质量获取逻辑
  private async getCityAirQuality(coords: { latitude: string; longitude: string }) {
    // 此处替换为实际的API调用或数据获取逻辑
    return {};
  }
}

关键改进点 #

• 移除@Cron装饰器，完全手动控制任务的创建与启动，彻底避免自动触发
• 仅在GET请求调用triggerParisAirQualityJob时才初始化任务，严格遵循按需触发逻辑
• 基于请求触发时刻计算任务结束时间，而非服务器启动时间
• 模块初始化时清理残留任务，防止重启时旧任务自动运行
• 增加任务运行状态检查，避免重复触发

控制器配套示例 #

在控制器中添加GET端点来触发任务：

import { Controller, Get } from '@nestjs/common';
import { AirQualityService } from './air-quality.service';

@Controller('air-quality')
export class AirQualityController {
  constructor(private readonly airQualityService: AirQualityService) {}

  @Get('paris/trigger')
  async triggerParisJob() {
    return this.airQualityService.triggerParisAirQualityJob();
  }
}

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