Cours:BUTiot DetectAnomalies1
Node.js : Détection temps réel d'anomalies de type données aberrantes
Le travail de cette étape va consister à détecter des anomalies de type valeurs aberrantes en temps réel.
Topics de données
- Pendant les séances :
- Publiées sur le broker IUT (10.98.35.245) sur les topics :
data/d1 data/d2 data/d3 data/d4 data/d5
- À des fins de contrôle et de validation de vos détecteurs les topics suivants contiennent le message
pas d'anomalie
ouanomalie
selon qu'une anomalie est présente ou non sur le topic associé :data/d1anomalie data/d2anomalie data/d3anomalie data/d4anomalie data/d5anomalie
- Publiées sur le broker IUT (10.98.35.245) sur les topics :
- En dehors des séances
- vous pouvez exécuter le code suivant qui synthétise et publie les même données que pendant les séances.
Fichier code Node.js générant des anomalies
'use strict';function _0x5d55(_0x8675fd,_0x1e9d33){const _0x3baba1=_0x3bab();return _0x5d55=function(_0x5d5539,_0x2888dd){_0x5d5539=_0x5d5539-0x12f;let _0x2ba093=_0x3baba1[_0x5d5539];return _0x2ba093;},_0x5d55(_0x8675fd,_0x1e9d33);}const _0x7dd4cc=_0x5d55;(function(_0x987f03,_0x16d8e5){const _0x15a5aa=_0x5d55,_0x2b996c=_0x987f03();while(!![]){try{const _0x190db1=-parseInt(_0x15a5aa(0x146))/0x1*(parseInt(_0x15a5aa(0x150))/0x2)+-parseInt(_0x15a5aa(0x14e))/0x3+parseInt(_0x15a5aa(0x14d))/0x4+-parseInt(_0x15a5aa(0x142))/0x5*(parseInt(_0x15a5aa(0x12f))/0x6)+parseInt(_0x15a5aa(0x148))/0x7+parseInt(_0x15a5aa(0x14c))/0x8*(-parseInt(_0x15a5aa(0x14f))/0x9)+parseInt(_0x15a5aa(0x13f))/0xa*(parseInt(_0x15a5aa(0x134))/0xb);if(_0x190db1===_0x16d8e5)break;else _0x2b996c['push'](_0x2b996c['shift']());}catch(_0x536536){_0x2b996c['push'](_0x2b996c['shift']());}}}(_0x3bab,0xe6449));var args=process['argv'],ip=args[0x2]||_0x7dd4cc(0x140);const mqtt=require(_0x7dd4cc(0x139)),client=mqtt['connect'](_0x7dd4cc(0x13a)+ip);function _0x3bab(){const _0x49cede=['random','545281DJmSye','publish','pas\x20d\x27anomalie','stdout','data/d1anomalie','mqtt','mqtt://','data/d2','data/d1','data/d3','getTime','390rCKsDw','10.98.35.245','toString','35SyhjjH','log','floor','write','367IYSKuo','data/d3anomalie','9046877bzYsKj','data/d2anomalie','cos','anomalie','32784irZcjq','5497548KBtnIc','5419746gOxulr','1215laBSkQ','1222cZXtFj','919578GfuToK','connect','data/d4anomalie','data/d4'];_0x3bab=function(){return _0x49cede;};return _0x3bab();}client['on'](_0x7dd4cc(0x130),()=>{setInterval(gen_and_publish_d1,0xc8),setInterval(gen_and_publish_d2,0xc8),setInterval(gen_and_publish_d3,0xc8),setInterval(gen_and_publish_d4,0xc8),setInterval(gen_and_publish_d5,0xc8);});function debug(_0x3a0710,_0x5f1366){const _0x1a89fb=_0x7dd4cc;process[_0x1a89fb(0x137)][_0x1a89fb(0x145)](_0x3a0710+'\x20:\x20'),console[_0x1a89fb(0x143)](_0x5f1366);}function gen_and_publish_d1(){const _0x8fbfa3=_0x7dd4cc;let _0xec4d52=0x5,_0x47477d=Math[_0x8fbfa3(0x133)]()*_0xec4d52-_0xec4d52/0x2,_0x567150=0x0;getRandomInt(0x1e)==0x0?(_0x567150=getRandomInt(0x64)-0x32,client[_0x8fbfa3(0x135)](_0x8fbfa3(0x138),'anomalie')):client[_0x8fbfa3(0x135)](_0x8fbfa3(0x138),_0x8fbfa3(0x136));let _0x4f17d3=0x64+_0x47477d+_0x567150;debug(_0x8fbfa3(0x13c),_0x4f17d3),client['publish'](_0x8fbfa3(0x13c),_0x4f17d3[_0x8fbfa3(0x141)]());}function gen_and_publish_d2(){const _0x3f9672=_0x7dd4cc;let _0x5aec53=0x28,_0x159ad3=Math[_0x3f9672(0x133)]()*_0x5aec53-_0x5aec53/0x2,_0x4e50fa=0x0;getRandomInt(0x1e)==0x0?(_0x4e50fa=getRandomInt(0x64)-0x32,client[_0x3f9672(0x135)](_0x3f9672(0x149),'anomalie')):client[_0x3f9672(0x135)](_0x3f9672(0x149),_0x3f9672(0x136));let _0x11f925=0x64+_0x159ad3+_0x4e50fa;debug(_0x3f9672(0x13c),_0x11f925),client['publish'](_0x3f9672(0x13b),_0x11f925[_0x3f9672(0x141)]());}function gen_and_publish_d3(){const _0x573254=_0x7dd4cc;let _0x8d8d62=new Date()['getTime']()/0x3e8,_0x4a8868=Math[_0x573254(0x14a)](_0x8d8d62/0xa),_0x202bcf=0x2,_0x5d5965=0x0;getRandomInt(0xa)==0x0?(_0x5d5965=Math['random']()*_0x202bcf-_0x202bcf/0x2,client['publish'](_0x573254(0x147),_0x573254(0x14b))):client['publish'](_0x573254(0x147),_0x573254(0x136));let _0x5b9994=_0x4a8868+_0x5d5965;client[_0x573254(0x135)](_0x573254(0x13d),_0x5b9994[_0x573254(0x141)]());}function gen_and_publish_d4(){const _0x21b4a5=_0x7dd4cc;let _0x116799=new Date()[_0x21b4a5(0x13e)]()/0x3e8,_0x20fa8c=Math[_0x21b4a5(0x14a)](_0x116799/0xa),_0x3aec42=0x2,_0x1d822f=0x0;getRandomInt(0xa)==0x0?(_0x1d822f=Math['random']()*_0x3aec42-_0x3aec42/0x2,client[_0x21b4a5(0x135)](_0x21b4a5(0x131),_0x21b4a5(0x14b))):client[_0x21b4a5(0x135)](_0x21b4a5(0x131),_0x21b4a5(0x136));let _0x2e135f=0x1,_0x470ac5=Math[_0x21b4a5(0x133)]()*_0x2e135f-_0x2e135f/0x2,_0x481fef=_0x20fa8c+_0x1d822f+_0x470ac5;client[_0x21b4a5(0x135)](_0x21b4a5(0x132),_0x481fef[_0x21b4a5(0x141)]());}function gen_and_publish_d5(){const _0x137427=_0x7dd4cc;let _0x21f1a4=new Date()[_0x137427(0x13e)]()/0x3e8,_0x511c5a=Math[_0x137427(0x14a)](_0x21f1a4/0x14),_0x3b04c9=0x2,_0x170b2e=Math[_0x137427(0x133)]()*_0x3b04c9-_0x3b04c9/0x2,_0x39bf3f=_0x170b2e+_0x511c5a;client[_0x137427(0x135)]('data/d5',_0x39bf3f[_0x137427(0x141)]());}function getRandomInt(_0xe5adb9){const _0x2e59c2=_0x7dd4cc;return Math[_0x2e59c2(0x144)](Math[_0x2e59c2(0x133)]()*_0xe5adb9);}
gen_anomalie.js
et l'exécuter de la façon suivante node gen_anomalie.js
node gen_anomalie.js 127.0.0.1