我试图在预定的时间运行API调用。我通过网站进行了研究,发现该软件包来自npmjs,称为节点计划。通过在要求的时间调用代码,可以按预期工作。我遇到的问题是:

假设我有一个时间列表,例如:["10:00","11:00","13:00"]

一旦启动服务器,它将在需要的时间执行。但是,如果我想动态更改时间表怎么办?

正是我想做的:


调用API并从数据库获取时间
为这些时间分别设置cron时间表。
动态添加新时间到数据库


我想要的是:动态地将此新添加的时间添加到cron-schedule

index.js

const express = require('express');
const schedule = require('node-schedule');
const app = express();
const port = 5000;

var date = new Date(2019, 5, 04, 14, 05, 20);// API call here
var j = schedule.scheduleJob(date, function(){
  console.log('The world is going to end today.');
});

app.get('/test', (req, res) => {
  var date = new Date(2019, 5, 04, 14, 11, 0); // Will call API here
  var q = schedule.scheduleJob(date, function(){
   console.log('Hurray!!');
  });
  res.send('hello there');
});

app.listen(port, () => console.log(`Example app listening on port ${port}!`));


上面写的代码就是我所拥有的,而且相当混乱。我要传达的是,在运行index.js文件API时会调用cron-schedule并执行它。现在,如果有一些新值添加到数据库中,我想重新运行它。

重新运行index.js是我的另一种选择,但我认为这样做是不正确的。我想到的下一个选项是调用另一个端点,该端点在上面称为/test,最终将再次运行cron。

请让我知道一些建议或解决方案,以便我纠正错误。

最佳答案

尽管您必须根据定义需要执行任务的功能或需要指定以其他方式执行它们的时间(设置例如,一周中的特定日期)。

var times = [];
var tasks = [];

function addTask(time, fn) {
    var timeArr = time.split(':');
    var cronString = timeArr[1] + ' ' + timeArr[0] + ' * * *';
    // according to https://github.com/node-schedule/node-schedule#cron-style-scheduling
    var newTask = schedule.scheduleJob(cronString, fn);

    // check if there was a task defined for this time and overwrite it
    // this code would not allow inserting two tasks that are executed at the same time
    var idx = times.indexOf(time);
    if (idx > -1) tasks[idx] = newTask;
    else {
        times.push(time);
        tasks.push(newTask);
    }
}

function cancelTask(time) {
    // https://github.com/node-schedule/node-schedule#jobcancelreschedule
    var idx = times.indexOf(time);
    if (idx > -1) {
        tasks[idx].cancel();
        tasks.splice(idx, 1);
        times.splice(idx, 1);
    }
}

function init(tasks) {
    for (var i in tasks){
        addTask(i, tasks[i]);
    }
}

init({
    "10:00": function(){ console.log("It's 10:00"); },
    "11:00": function(){ console.log("It's 11:00"); },
    "13:00": function(){ console.log("It's 13:00"); }
});

app.post('/addTask', (req, res) => {
    if (!req.body.time.match(/^(0[0-9]|1[0-9]|2[0-3]|[0-9]):[0-5][0-9]$/)) {
        // regex from https://stackoverflow.com/a/7536768/8296184
        return res.status(400).json({'success': false, 'code': 'ERR_TIME'});
    }
    function fn() {
        // I suppose you will not use this feature just to do console.logs
        // and not sure how you plan to do the logic to create new tasks
        console.log("It's " + req.body.time);
    }
    addTask(req.body.time, fn);
    res.status(200).json({'success': true});
});

关于javascript - 在预定时间调用API,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/56441097/

10-12 17:40
查看更多