NodeJs:在使用node-cron的cron作业中从未调用过Mongodb查询

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

// MongoDB 连接字符串
const uri = 'mongodb://localhost:27017';
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });

// 连接到 MongoDB
async function connect() {
  try {
    await client.connect();
    console.log('Connected to MongoDB');
  } catch (error) {
    console.error('Failed to connect to MongoDB', error);
  }
}

// 执行查询
async function runQuery() {
  try {
    const database = client.db('testdb');
    const collection = database.collection('testcollection');
    const query = { status: 'active' };
    const result = await collection.find(query).toArray();
    console.log('Query result:', result);
  } catch (error) {
    console.error('Failed to run query', error);
  }
}

// 设置定时任务
cron.schedule('*/5 * * * *', async () => {
  console.log('Running scheduled task...');
  await runQuery();
});

// 连接到 MongoDB 并启动定时任务
connect();