-
Notifications
You must be signed in to change notification settings - Fork 7
/
init.js
40 lines (38 loc) · 1.08 KB
/
init.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
/*
* @Author: strick
* @LastEditors: strick
* @Date: 2021-09-06 12:49:20
* @LastEditTime: 2021-09-06 12:53:00
* @Description:
* @FilePath: /strick/shin-server/init.js
*/
import queue from './utils/queue';
import services from './services';
export default () => {
//处理性能数据
queue.process('handlePerformance', (job, done) => {
services.webMonitor.createPerformance(job.data.performance)
.then(() => done())
.catch((err) => {
logger.error(err);
done(err);
});
});
//处理监控数据
const taskName = 'handleMonitor';
queue.process(taskName, (job, done) => {
logger.trace(`${taskName} job begin`, job.id);
services.webMonitor.handleMonitor(job.data.monitor)
.then(() => {
done();
logger.trace(`${taskName} job completed`, job.id);
job.remove(function(){//手动移除
logger.trace(`${taskName} job removed`, job.id);
});
})
.catch((err) => {
logger.error(err);
done(err);
});
});
}