const schedule = require('node-schedule'); const http = require("http"); const Dataapi = require("../models/dataapi"); const mysql = require("../utils/mysql_db"); // 定义规则 let rule = new schedule.RecurrenceRule(); // rule.minute = [1,11,21,31,41,51] rule.second = [30, 60]; // 每隔 10 秒执行一次 var deviceMap = {}; var rule1 = new schedule.RecurrenceRule(); var times1 = [1, 6, 11, 16, 21, 26, 31, 36, 41, 46, 51, 56]; rule1.second = times1; // schedule.scheduleJob(rule1, function () { // httpGet(); // }); module.exports = { async job_() { }, async getDeviceStatus() { }, }; // schedule.scheduleJob('5 5 * * * *', function () { // httpGet(); // }); function httpGet() { var uri = `http://www.baidu.com`; http.get(uri, function (res) { console.log("访问个人微博状态码: " + res.statusCode); }).on('error', function (e) { console.log("个人微博 error: " + e.message); }); }