hastic
/
hastic-server
4
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity
Browse Source

rm alarting

pull/1/head
Alexey Velikiy 6 years ago
parent
0414ff4256
commit
e412642ac2
4 changed files with 109 additions and 95 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      server/src/config.ts
  2. 137
      server/src/controllers/alerts_controller.ts
  3. 4
      server/src/index.ts
  4. 61
      server/src/routes/alerts_router.ts

2
server/src/config.ts
Unescape View File

@ -16,7 +16,7 @@ export const SEGMENTS_DATABASE_PATH = path.join(DATA_PATH, 'segments.db');
export const FILES_DATABASE_PATH = path.join(DATA_PATH, 'files.db'); export const FILES_DATABASE_PATH = path.join(DATA_PATH, 'files.db');
export const DATASETS_PATH = path.join(DATA_PATH, 'datasets'); export const DATASETS_PATH = path.join(DATA_PATH, 'datasets');
export const ANALYTIC_UNITS_PATH = path.join(DATA_PATH, 'analytic_units'); //export const ANALYTIC_UNITS_PATH = path.join(DATA_PATH, 'analytic_units');
export const MODELS_PATH = path.join(DATA_PATH, 'models'); export const MODELS_PATH = path.join(DATA_PATH, 'models');
export const METRICS_PATH = path.join(DATA_PATH, 'metrics'); export const METRICS_PATH = path.join(DATA_PATH, 'metrics');
export const SEGMENTS_PATH = path.join(DATA_PATH, 'segments'); export const SEGMENTS_PATH = path.join(DATA_PATH, 'segments');

137
server/src/controllers/alerts_controller.ts
Unescape View File

@ -1,65 +1,72 @@
import { runPredict } from './analytics_controller'; /**
import { getLabeledSegments } from './segments_controller'; * Alarting is not supported yet
import { AnalyticUnitId } from '../models/analytic_unit'; */
import { sendNotification } from '../services/notification_service';
import { getJsonDataSync, writeJsonDataSync } from '../services/json_service'; throw new console.error("Not supported");
import { ANALYTIC_UNITS_PATH } from '../config';
import * as path from 'path'; // import { runPredict } from './analytics_controller';
import * as fs from 'fs'; // import { getLabeledSegments } from './segments_controller';
// import { AnalyticUnitId } from '../models/analytic_unit';
// import { sendNotification } from '../services/notification_service';
const ALERT_TIMEOUT = 60000; // ms // import { getJsonDataSync, writeJsonDataSync } from '../services/json_service';
const ALERTS_DB_PATH = path.join(ANALYTIC_UNITS_PATH, `alerts_anomalies.json`); // import { ANALYTIC_UNITS_PATH } from '../config';
// import * as path from 'path';
export function getAlertsAnomalies(): AnalyticUnitId[] { // import * as fs from 'fs';
if(!fs.existsSync(ALERTS_DB_PATH)) {
saveAlertsAnomalies([]);
} // const ALERT_TIMEOUT = 60000; // ms
return getJsonDataSync(ALERTS_DB_PATH); // const ALERTS_DB_PATH = path.join(ANALYTIC_UNITS_PATH, `alerts_anomalies.json`);
}
export function saveAlertsAnomalies(units: AnalyticUnitId[]) { // export function getAlertsAnomalies(): AnalyticUnitId[] {
return writeJsonDataSync(ALERTS_DB_PATH, units); // if(!fs.existsSync(ALERTS_DB_PATH)) {
} // saveAlertsAnomalies([]);
// }
function processAlerts(id: AnalyticUnitId) { // return getJsonDataSync(ALERTS_DB_PATH);
let segments = getLabeledSegments(id); // }
const currentTime = new Date().getTime(); // export function saveAlertsAnomalies(units: AnalyticUnitId[]) {
const activeAlert = activeAlerts.has(id); // return writeJsonDataSync(ALERTS_DB_PATH, units);
let newActiveAlert = false; // }
if(segments.length > 0) { // function processAlerts(id: AnalyticUnitId) {
let lastSegment = segments[segments.length - 1]; // let segments = getLabeledSegments(id);
if(lastSegment.finish >= currentTime - ALERT_TIMEOUT) {
newActiveAlert = true; // const currentTime = new Date().getTime();
} // const activeAlert = activeAlerts.has(id);
} // let newActiveAlert = false;
if(!activeAlert && newActiveAlert) { // if(segments.length > 0) {
activeAlerts.add(id); // let lastSegment = segments[segments.length - 1];
sendNotification(id, true); // if(lastSegment.finish >= currentTime - ALERT_TIMEOUT) {
} else if(activeAlert && !newActiveAlert) { // newActiveAlert = true;
activeAlerts.delete(id); // }
sendNotification(id, false); // }
}
} // if(!activeAlert && newActiveAlert) {
// activeAlerts.add(id);
async function alertsTick() { // sendNotification(id, true);
let alertsAnomalies = getAlertsAnomalies(); // } else if(activeAlert && !newActiveAlert) {
for (let predictorId of alertsAnomalies) { // activeAlerts.delete(id);
try { // sendNotification(id, false);
await runPredict(predictorId); // }
processAlerts(predictorId); // }
} catch (e) {
console.error(e); // async function alertsTick() {
} // let alertsAnomalies = getAlertsAnomalies();
} // for (let predictorId of alertsAnomalies) {
setTimeout(alertsTick, 5000); // try {
} // await runPredict(predictorId);
// processAlerts(predictorId);
// } catch (e) {
const activeAlerts = new Set<string>(); // console.error(e);
setTimeout(alertsTick, 5000); // }
// }
// setTimeout(alertsTick, 5000);
// }
// const activeAlerts = new Set<string>();
// setTimeout(alertsTick, 5000);

4
server/src/index.ts
Unescape View File

@ -1,6 +1,6 @@
import { router as anomaliesRouter } from './routes/analytic_units_router'; import { router as anomaliesRouter } from './routes/analytic_units_router';
import { router as segmentsRouter } from './routes/segments_router'; import { router as segmentsRouter } from './routes/segments_router';
import { router as alertsRouter } from './routes/alerts_router'; //import { router as alertsRouter } from './routes/alerts_router';
import * as AnalyticsController from './controllers/analytics_controller'; import * as AnalyticsController from './controllers/analytics_controller';
@ -33,7 +33,7 @@ app.use(async function(ctx, next) {
var rootRouter = new Router(); var rootRouter = new Router();
rootRouter.use('/analyticUnits', anomaliesRouter.routes(), anomaliesRouter.allowedMethods()); rootRouter.use('/analyticUnits', anomaliesRouter.routes(), anomaliesRouter.allowedMethods());
rootRouter.use('/segments', segmentsRouter.routes(), segmentsRouter.allowedMethods()); rootRouter.use('/segments', segmentsRouter.routes(), segmentsRouter.allowedMethods());
rootRouter.use('/alerts', alertsRouter.routes(), alertsRouter.allowedMethods()); //rootRouter.use('/alerts', alertsRouter.routes(), alertsRouter.allowedMethods());
rootRouter.get('/', async (ctx) => { rootRouter.get('/', async (ctx) => {
ctx.response.body = { ctx.response.body = {
server: 'OK', server: 'OK',

61
server/src/routes/alerts_router.ts
Unescape View File

@ -1,36 +1,43 @@
import * as AnalyticUnit from '../models/analytic_unit'; // /**
import { getAlertsAnomalies, saveAlertsAnomalies } from '../controllers/alerts_controller'; // * Alarting is not supported yet
// */
import * as Router from 'koa-router'; // throw new console.error("Not supported");
function getAlert(ctx: Router.IRouterContext) { // import * as AnalyticUnit from '../models/analytic_unit';
let id: AnalyticUnit.AnalyticUnitId = ctx.request.query.id; // import { getAlertsAnomalies, saveAlertsAnomalies } from '../controllers/alerts_controller';
let alertsAnomalies = getAlertsAnomalies(); // import * as Router from 'koa-router';
let pos = alertsAnomalies.indexOf(id);
let enabled: boolean = (pos !== -1);
ctx.response.body = { enabled };
}
function setAlertEnabled(ctx: Router.IRouterContext) { // function getAlert(ctx: Router.IRouterContext) {
let id: AnalyticUnit.AnalyticUnitId = ctx.request.body.id; // let id: AnalyticUnit.AnalyticUnitId = ctx.request.query.id;
let enabled: boolean = ctx.request.body.enabled;
let alertsAnomalies = getAlertsAnomalies(); // let alertsAnomalies = getAlertsAnomalies();
let pos: number = alertsAnomalies.indexOf(id); // let pos = alertsAnomalies.indexOf(id);
if(enabled && pos == -1) {
alertsAnomalies.push(id);
saveAlertsAnomalies(alertsAnomalies);
} else if(!enabled && pos > -1) {
alertsAnomalies.splice(pos, 1);
saveAlertsAnomalies(alertsAnomalies);
}
ctx.response.body = { status: 'OK' };
}
export const router = new Router(); // let enabled: boolean = (pos !== -1);
// ctx.response.body = { enabled };
// }
router.get('/', getAlert); // function setAlertEnabled(ctx: Router.IRouterContext) {
router.post('/', setAlertEnabled); // let id: AnalyticUnit.AnalyticUnitId = ctx.request.body.id;
// let enabled: boolean = ctx.request.body.enabled;
// let alertsAnomalies = getAlertsAnomalies();
// let pos: number = alertsAnomalies.indexOf(id);
// if(enabled && pos == -1) {
// alertsAnomalies.push(id);
// saveAlertsAnomalies(alertsAnomalies);
// } else if(!enabled && pos > -1) {
// alertsAnomalies.splice(pos, 1);
// saveAlertsAnomalies(alertsAnomalies);
// }
// ctx.response.body = { status: 'OK' };
// }
// export const router = new Router();
// router.get('/', getAlert);
// router.post('/', setAlertEnabled);

Write Preview
Loading…
Cancel
Save