open-source/qinglong
1
0
Fork 0
mirror of https://github.com/whyour/qinglong.git synced 2026-06-30 20:35:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改任务最大内存占用200兆

Browse Source
This commit is contained in:
whyour
2022-03-26 16:53:03 +08:00
parent da922678a1
commit 117822fe7c
1 changed files with 46 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files
back/services/schedule.ts
+46 -36
View File
@@ -16,6 +16,8 @@ export default class ScheduleService {
private intervalSchedule = new ToadScheduler();
private maxBuffer = 200 * 1024 * 1024;
constructor(@Inject('logger') private logger: winston.Logger) {}
async createCronTask({ id = 0, command, name, schedule = '' }: Crontab) {
@@ -32,25 +34,29 @@ export default class ScheduleService {
_id,
nodeSchedule.scheduleJob(id + '', schedule, async () => {
try {
exec(command, async (error, stdout, stderr) => {
if (error) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
command,
new Date().toLocaleString(),
error,
);
}
exec(
command,
{ maxBuffer: this.maxBuffer },
async (error, stdout, stderr) => {
if (error) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
command,
new Date().toLocaleString(),
error,
);
}
if (stderr) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
command,
new Date().toLocaleString(),
stderr,
);
}
});
if (stderr) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
command,
new Date().toLocaleString(),
stderr,
);
}
},
);
} catch (error) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
@@ -83,25 +89,29 @@ export default class ScheduleService {
);
const task = new Task(name, async () => {
try {
exec(command, async (error, stdout, stderr) => {
if (error) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
command,
new Date().toLocaleString(),
error,
);
}
exec(
command,
{ maxBuffer: this.maxBuffer },
async (error, stdout, stderr) => {
if (error) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
command,
new Date().toLocaleString(),
error,
);
}
if (stderr) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
command,
new Date().toLocaleString(),
stderr,
);
}
});
if (stderr) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',
command,
new Date().toLocaleString(),
stderr,
);
}
},
);
} catch (error) {
await this.logger.info(
'执行任务%s失败，时间：%s, 错误信息：%j',