Задание Cron выполняется несколько раз в среде кластера в Node js

я настроил среду кластера серверов Node JS, чтобы полностью использовать все ядра моего сервера. Существует Cron Job, который запускается каждый день в 08 часов для выполнения некоторых задач. Но из-за кластеризации он запускается 4 раза (сервер 4 ядра) каждый день в 08 часов. Как я могу решить эту проблему, чтобы запускать Cron Job только один раз в день?

if(cluster.isMaster) {
    var numWorkers = require('os').cpus().length;

    console.log('Master cluster setting up ' + numWorkers + ' workers...');

    for(var i = 0; i < numWorkers; i++) {
        cluster.fork();
    }

    cluster.on('exit', function(worker, code, signal) {
        console.log('Worker ' + worker.process.pid + ' died with code: ' + code + ', and signal: ' + signal);
        cluster.fork();
    });
} else {

    var CronJob = require('cron').CronJob;
    new CronJob('01 30 08 * * 0-6', function() {
      console.log('Running Schedular');
      //Performing tasks
    }, null, true, 'America/Los_Angeles');

    var server = app.listen(port, function() {
        console.log('Process ' + process.pid + ' is listening to all incoming requests');
    });
}

person Abhishek Agarwal    schedule 24.06.2018    source источник


Ответы (2)


Привет. Пожалуйста, найдите следующие изменения, я только что изменил задание cron на условие if.

var CronJob = require('cron').CronJob;
if(cluster.isMaster) {
    var numWorkers = require('os').cpus().length;

    console.log('Master cluster setting up ' + numWorkers + ' workers...');

    for(var i = 0; i < numWorkers; i++) {
        cluster.fork();
    }

    cluster.on('exit', function(worker, code, signal) {
        console.log('Worker ' + worker.process.pid + ' died with code: ' + code + ', and signal: ' + signal);
        cluster.fork();
    });

    new CronJob('01 30 08 * * 0-6', function() {
      console.log('Running Schedular');
      //Performing tasks
    }, null, true, 'America/Los_Angeles');

} else {

    var server = app.listen(port, function() {
        console.log('Process ' + process.pid + ' is listening to all incoming requests');
    });
}
person Veeresh Digasangi    schedule 06.07.2018

Пусть главный кластер обрабатывает задание cron, а не один из рабочих потоков.

person michgboxy    schedule 18.07.2019