如何通过Node.js的Cron定时任务实现MongoDB每日数据批量修改

步骤1：安装依赖 #

先装所需的npm包，cron用来调度定时任务，mongodb是官方MongoDB驱动：

npm install cron mongodb

步骤2：编写核心实现代码 #

下面是完整的可运行示例，包含MongoDB连接、定时任务配置和数据修改逻辑：

const { MongoClient } = require('mongodb');
const { CronJob } = require('cron');

// 替换成你的MongoDB连接信息
const mongoUri = 'mongodb://localhost:27017';
const dbName = 'your_db_name';
const collectionName = 'your_collection_name';

// Cron表达式：每日凌晨0点执行
// 格式：秒 分 时 日 月 周
const cronSchedule = '0 0 * * *';

async function startScheduledTask() {
  let client;
  try {
    // 建立MongoDB连接
    client = await MongoClient.connect(mongoUri);
    const db = client.db(dbName);
    const collection = db.collection(collectionName);
    console.log('MongoDB连接成功');

    // 创建定时任务
    const job = new CronJob(
      cronSchedule,
      async function() {
        console.log('开始执行定时数据修改');
        try {
          // 这里是你的修改逻辑：示例为把状态为pending的记录改为processed
          const updateResult = await collection.updateMany(
            { status: 'pending' }, // 匹配条件
            { 
              $set: { 
                status: 'processed',
                updatedAt: new Date()
              } 
            }, // 要修改的字段
            { upsert: false } // 不存在匹配记录时不插入新数据
          );
          console.log(`成功修改 ${updateResult.modifiedCount} 条记录`);
        } catch (err) {
          console.error('数据修改失败:', err);
        }
      },
      null, // 任务停止时的回调（可选）
      true, // 立即启动任务
      'Asia/Shanghai' // 时区，根据业务需求调整
    );

    console.log(`定时任务已启动，将在每日指定时间执行`);
  } catch (err) {
    console.error('MongoDB连接失败:', err);
  } finally {
    // 不要在此关闭client，因为定时任务需要持续保持连接
    // 若需关闭，可在任务停止逻辑中处理
  }
}

// 启动任务
startScheduledTask();

关键细节说明 #

• Cron表达式调整：如果要改执行时间，比如每日14点30分，表达式改成0 30 14 * * *；每周一凌晨执行则是0 0 * * 1。
• 定制修改逻辑：根据你的预设条件，修改updateMany的匹配参数和更新字段，比如可以按日期范围、特定字段值筛选记录。
• 时区设置：务必把时区参数设为和业务时间一致，避免任务执行时间偏移。
• 错误处理：代码里加了连接和修改环节的错误捕获，方便异常时排查问题。

运行与测试 #

直接执行脚本：

node your_script_name.js

测试阶段可以临时把Cron表达式改成*/5 * * * *（每5分钟执行一次），快速验证数据修改是否符合预期。

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