Cours:BUTiot TNS

Retour à la page du cours

Classification multivariée temps réel

Le travail de cette étape va consister à

• lire des données temps réel caractérisant l'état d'un réseau (latence et débit)
• A partir d'un ensemble de données d'entrainement, mettre en place un classifieur permettant de détecter des anomalies sur ce réseau

Lecture des données d'entrainement et apprentissage

• Source des données : https://www.kaggle.com/datasets/rishitdagli/anomaly-detection-sample-dataset

A faire :

• Créer une nouvelle "application" node.js
• Télécharger le zip des données, décompresser, placer les deux fichiers tr_server_data.csv et gt_server_data.csv dans le dossier de l'application.
• Lire ces données au format CSV, par exemple avec :

const fs = require("node:fs");

// training
let tr = fs.readFileSync("tr_server_data.csv", "utf-8")
    .split('\n') // découpe des lignes
    .map(l => l.split(',').map (v => parseFloat(v))); // découpe autour de la virgule et conv. en flottant
tr.pop(); // Les deux dernières lignes sont à rejeter.
tr.pop();

• Mise en place du classifieur KNN (entrainement et test):

const knnClassifier = require('@tensorflow-models/knn-classifier');
const tf = require('@tensorflow/tfjs');

// Create the classifier.
const classifier = knnClassifier.create();

// Train the classifier
for (let k = 0; k < gt.length; k++) {
    classifier.addExample(
        tf.tensor(tr[k]),
        gt[k]
    );
}

// Test the classifier
for (let k = 0; k < gt.length; k++) {
    classifier.predictClass(
        tf.tensor(tr[k]),
        1
    ).then(v => console.log(v.classIndex + " / " + gt[k]));
}

Classification temps réel

• Données publiées sur le broker habituel :
  • data/latence en ms
  • data/debit en mb/s
  • data/gt = ground truth (vérité terrain) : est-ce une anomalie ?

A faire (en node.js) :

1. lire ces données avec mqtt