61 lines
1.4 KiB
JavaScript
61 lines
1.4 KiB
JavaScript
const io = require('@pm2/io')
|
|
|
|
const stats = {
|
|
rpsAvrg: 0,
|
|
responseTimeAvrg: 0,
|
|
times: {}
|
|
}
|
|
|
|
const rtOP = io.metric({
|
|
name: 'response time',
|
|
unit: 'ms'
|
|
})
|
|
|
|
// const usersCountIO = io.metric({
|
|
// name: 'Users count',
|
|
// unit: 'user'
|
|
// })
|
|
|
|
setInterval(() => {
|
|
if (Object.keys(stats.times).length > 1) {
|
|
const time = Object.keys(stats.times).shift()
|
|
|
|
const sumResponseTime = stats.times[time].reduce((a, b) => a + b, 0)
|
|
const lastResponseTimeAvrg = (sumResponseTime / stats.times[time].length) || 0
|
|
if (stats.responseTimeAvrg > 0) stats.responseTimeAvrg = Math.round((stats.responseTimeAvrg + lastResponseTimeAvrg) / 2)
|
|
else stats.responseTimeAvrg = lastResponseTimeAvrg
|
|
|
|
console.log('response time avrg total:', stats.responseTimeAvrg)
|
|
|
|
rtOP.set(stats.responseTimeAvrg)
|
|
|
|
// db.Stats.create({
|
|
// rps,
|
|
// responseTime: lastResponseTimeAvrg,
|
|
// date: new Date()
|
|
// })
|
|
|
|
delete stats.times[time]
|
|
}
|
|
}, 1000)
|
|
|
|
// setInterval(async () => {
|
|
// const usersCount = await db.User.count({
|
|
// updatedAt: {
|
|
// $gte: new Date(Date.now() - 24 * 60 * 60 * 1000)
|
|
// }
|
|
// })
|
|
|
|
// usersCountIO.set(usersCount)
|
|
// }, 60 * 1000)
|
|
|
|
module.exports = async (ctx, next) => {
|
|
const startMs = new Date()
|
|
|
|
return next().then(() => {
|
|
const now = Math.floor(new Date() / 1000)
|
|
|
|
if (!stats.times[now]) stats.times[now] = []
|
|
stats.times[now].push(new Date() - startMs)
|
|
})
|
|
} |