用NODE加载crontab任务

前言

众所周知有诸多平台可以实现定时任务,像:阿里云函数,Github Actions,服务器中的crontab。
如果不希望定时任务过于分散,我们可以全部写在一个文件里,然后用nodejs来加载这个文件,统一调用,实现定时任务。
大多数定时任务改写成Node代码并不复杂!而且可以直接与我的Express项目放一起运行,节省资源开销。

代码

node-cron:是一个非常好用的定时任务库,可以很方便的实现定时任务。
使用起来非常简单,由如下代码所示:

schedule.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
const cron = require("node-cron");
module.exports = (app) => {
//TODO 添加自动删除一个月前的日志
console.log("schedule.js loaded");
cron.schedule("0 */8 * * *", () => {
subcache(app);
});
cron.schedule("*/15 * * * *", () => {
cf2dns().then((result)=>{
leancloud.add("Schedule", {
name: "cf2dns",
result
});
});
});
};

目前实现了cf2dns的功能(仅支持DNSPOD),可以每15min自动更新DNSPOD的Cloudflare优选IP记录。
以下是实现操作DNSPOD上的域名解析记录的相关js代码。

dnspod.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
const axios = require("axios");
const token = process.env.DNSPOD_TOKEN;
const querystring = require("querystring");
// 创建实例时配置默认值
const instance = axios.create({
baseURL: "https://dnsapi.cn"
});

async function get_record(domain, subdomain) {
const api = "/Record.List";
const data = querystring.stringify({
"domain": domain,
"sub_domain": subdomain,
"login_token": token,
"format": "json"
});
const res = await instance.post(api, data);
return res.data.records;
}

async function update_record(domain, record) {
const {id, line, type, name, value} = record;
const api = "/Record.Modify";
const data = querystring.stringify({
domain,
record_id: id,
value,
record_line: line,
record_type: type,
sub_domain: name,
"login_token": token,
"format": "json",
});
const res = await instance.post(api, data);
return res.data;
}

async function add_record(domain, record) {
const {line, type, name, value} = record;
const api = "/Record.Create";
const data = querystring.stringify({
domain,
value,
record_line: line,
record_type: type,
sub_domain: name,
"login_token": token,
"format": "json",
});
const res = await instance.post(api, data);
return res.data;
}

async function del_record(domain, record) {
const {id} = record;
const api = "/Record.Remove";
const data = querystring.stringify({
domain,
record_id: id,
"login_token": token,
"format": "json",
});
const res = await instance.post(api, data);
return res.data;
}

module.exports = {get_record, update_record, add_record, del_record};

定时更新gd.home999.cc域名的Cloudflare优选IP记录,方便快捷。
有时候可能希望调用某个URL,来定时执行某些操作,如果本身是Express应用,可以像写NODE测试用例一样,使用chaiHttp来直接调用。

1
2
3
4
5
6
7
8
9
10
11
12
13
function subcache(app) {
console.log("Running Cron Job:subcache");
chai.use(chaiHttp);
chai.request(app)
.get("/sub/cache")
.end((err, res) => {
leancloud.add("Schedule", {
name: "subcache",
result: res.text
});
console.log(res.text);
});
}

后记

综上,可以很方便的实现定时任务。总有些任务需要定时操作,像数据库定期备份,文件定期缓存等。
通过引入定时任务的js脚本,就能在运行Express应用的同时,自动执行定时任务。