[gelöst] Adapter - Parser / Wartezeiten auslesen

[Glasfaser]

@Alexxx2005

Was hältst du hiervon , dort kannst du die Datenpunkte in VIS anzeigen lassen.

ID oder Name eines State in Vis anzeigen

[Alexxx2005]

Danke das macht einen guten Eindruck, die frage ist nur was muss
hier rein damit er alles bei parser.0 ausliest

   var ip = ip.replace(/parser.0./g, "");

funktioniert nicht.

Grüße Alex

[bahnuhr]

@Homoran sagte in Adapter - Parser soll Wartezeiten auslesen:

@bahnuhr
Hallo Dieter,
Alex liest Daten mit dem Parser aus.
Diese werden in mehreren States unter parser.0.xxx abgelegt.
Diese States will er jetzt in eine Tabelle bekommen und diese dann nach Wert ab/aufsteigend (weiss ich nicht) sortieren.

Ja, und ?
Er kann die einzelnen Datenpunkte doch in ein array schreiben und dieses dann sortieren.
Mangels anderer Idee würde ich es so machen.

[Homoran]

@bahnuhr sagte in Adapter - Parser soll Wartezeiten auslesen:

in ein array schreiben

ich dachte an ein json und dann das json-table widget und dieses sortieren.

Aber da kann ICH nicht

[bahnuhr]

@Homoran sagte in Adapter - Parser soll Wartezeiten auslesen:

json-table widget

kenn ich nicht, muss direkt mal schauen was das für ein widget ist.

mfg

[Homoran]

@bahnuhr
Bin gerade auch auf der Suche um die Settings zu posten.
Finde da aber das SORT nicht mehr.

Muss mal sehen wo ich das hatte.
War das Systeminfo-Skript von @ruhr70

[Glasfaser]

@Homoran

Meinst du das :

Spoiler

var pfad            = "Systeminfos.ioBroker.Prozesse" + "."; // Pfad in dem die Datenpunkte angelegt werden

// Datenpunktnamen:
var idProzesse          = pfad + 'ioBroker_Prozesse';
var idMemAll            = pfad + 'ioBroker_Speicher_gesamt';
var idAnzProzesse       = pfad + 'ioBroker_Anzahl_Prozesse';
var idCpuAll            = pfad + 'ioBroker_CPU_Gesamt';
var idMemPercent        = pfad + 'ioBroker_Speicher_prozentual';
var idInstanzenEinmal   = pfad + 'ioBroker_Instanzen_einmal_aktiv';


// regelmässige Wiederholungen der Abfrage
var cronStr         = "*/2 * * * *";

var abfrage         = 'ps -A aux --sort -pmem | grep " [i]o.*"';




// -----------------------------------------------------------------------------


createState(idProzesse, "", {
    name: 'ioBroker laufende Prozesse Objekt',
    desc: 'ioBroker laufende Prozesse Objekt, Speicherverbrauch',
    type: 'string',
    unit: '',
    role: 'object'
});

createState(idMemAll, 0, {
    name: 'ioBroker Speicherverbrauch gesamt',
    desc: 'ioBroker Speicherverbrauch gesamt (RSS)',
    type: 'number',
    unit: 'MB',
    role: 'value'
});

createState(idAnzProzesse, 0, {
    name: 'ioBroker Anzahl Prozesse',
    desc: 'ioBroker Anzahl aktiver Prozesse',
    type: 'number',
    unit: '',
    role: 'value'
});

createState(idCpuAll, 0.0, {
    name: 'ioBroker CPU-Last gesamt',
    desc: 'ioBroker CPU-Last gesamt',
    type: 'number',
    unit: '%',
    role: 'value'
});

createState(idMemPercent, 0.0, {
    name: 'Speicherverbrauch prozentual',
    desc: 'Speicherverbrauch prozentual',
    type: 'number',
    unit: '%',
    role: 'value'
});

createState(idInstanzenEinmal, true, {
    name: 'keine Instanzen doppelt aktiv',
    desc: 'jeder aktive ioBroker Prozess ist nur einmal aktiv',
    type: 'boolean',
    unit: '',
    role: 'value'
});



// -----------------------------------------------------------------------------


function doppelteProzesse(arr) {
   var mehrfacheProzesse = [];
   var anzProzesse = (arr.length);
   var anzProzessAktiv = 0;
   for (var i = 0; i < anzProzesse; i++) {
       if (mehrfacheProzesse.indexOf(arr[i].command) == -1) {
           anzProzessAktiv = zaehleProzesse(arr,arr[i].command);
           if (anzProzessAktiv > 1) {
               log("Prozess: " + arr[i].command+", mehrfach aktiv: " + anzProzessAktiv +" mal","warn");
               mehrfacheProzesse.push(arr[i].command);
               mehrfacheProzesse.push(anzProzessAktiv);
           }
       }
   }    
   return mehrfacheProzesse;
}

function zaehleProzesse(arr,command) {
   var count = 0;
   var anzProzesse = (arr.length);
   for (var i = 0; i < anzProzesse; i++) {
       if(arr[i].command === command) {
           count++;
       }
   }    
   return count;
}


function writeJson(json) {
   return JSON.stringify(json);    // JSON in String umwandeln, damit das JSON in einem Datenpunkt geschrieben werden kann
}


function getMemAbsolut(json) {
   var anzProzesse = (json.length);
   var mem = 0;
   for (var i = 0; i < anzProzesse; i++) {
       mem = mem + json[i].rss;
   }    
   return mem;
}

function getCpu(json) {
   var anzProzesse = (json.length);
   var cpu = 0.0;
   for (var i = 0; i < anzProzesse; i++) {
       cpu = cpu + json[i].cpu;
   }    
   return cpu;
}

function getMem(json) {
   var anzProzesse = (json.length);
   var mem = 0.0;
   for (var i = 0; i < anzProzesse; i++) {
       mem = mem + json[i].mem;
   }    
   return mem;
}


function createArrayJson(arr) {
   var jsonArr     = [];
   var anzDP       = 11;                       // Anzahl Datenreihen in der Abfrage
   var anzProzesse = (arr.length-1)/anzDP;

   for (var i = 0; i < anzProzesse; i++) {
       jsonArr.push({
           command:    arr[10 + i*anzDP],              // ioBroker Prozess (COMMAND = Kommando, mit dem der Prozess gestartet wurde)
           pid:        arr[ 1 + i*anzDP],              // Prozess ID
           cpu:        parseFloat(arr[ 2 + i*anzDP]),  // aktueller CPU-Last in %
           mem:        parseFloat(arr[ 3 + i*anzDP]),  // aktueller Verbrauch physikalischer Speicher %
           vmem:       parseInt(arr[ 4 + i*anzDP]),    // 
           rss:        parseInt(arr[ 5 + i*anzDP]),    // physikalische Speichernutzung
           start:      arr[ 8 + i*anzDP],              // Startzeitpunkt des Prozesses
           time:       arr[ 9 + i*anzDP]               // bisher verbrauchte CPU Zeit
       });
   }
   return jsonArr;
}


function abfrageConsole() {
   exec(abfrage, function(err, stdout, stderr) {
       if (err) {
           log(err,"error");
           return;
       }
       stdout = stdout.replace(/\n+/g, " "); // neue Zeile gegen Leerzeichen ersetzen
       stdout = stdout.split(/ +/g);         // array erstellen, Lerzeichen als Trenner
       
       var anzProzesse = (stdout.length-1) / 11;
       
       //log(stdout);
       //log("Anzahl laufender ioBroker Prozesse: " + anzProzesse);
       
       var jsonArr = createArrayJson(stdout);
       var mem         = Math.floor(getMemAbsolut(jsonArr)/1024);
       var cpu         = Math.floor(getCpu(jsonArr)*10)/10;
       var memPercent  = Math.floor(getMem(jsonArr)*10)/10;

       var doppeltArr = doppelteProzesse(jsonArr);
       
       if(doppeltArr.length === 0) {
           setState(idInstanzenEinmal, "✅" );
       } else {
           setState(idInstanzenEinmal, "❌" );
       }
       
        
       setState(idProzesse     ,writeJson(jsonArr));
       setState(idMemAll       ,mem);
       setState(idAnzProzesse  ,anzProzesse);
       setState(idCpuAll       ,cpu);
       setState(idMemPercent   ,memPercent);
   });
}


function abfragen() {
   abfrageConsole();
}

// regelmässige Wiederholungen
// -----------------------------------------------------------------------------
schedule(cronStr, abfragen);


// main
// -----------------------------------------------------------------------------
function main() {
   abfragen();
}


// Start Skript:
// -----------------------------------------------------------------------------

setTimeout(main,    500);

…...
Dieses habe ich Ihm vorgeschlagen :

ID oder Name eines State in Vis anzeigen

[Homoran]

@Glasfaser
Ja!

und ich habe damals irgendwas geändert, damit die Tabell nicht nach mem sondern nach cpu sortiert wurde.

Das kommt davon wenn man davon nix versteht und trotzdem bastelt

EDIT.
Habe es gefunden - war im Skript, nicht im widget

var abfrage         = 'ps -A aux --sort -pcpu | grep " [i]o.*"';

[Alexxx2005]

Also mit :

Spoiler

var cacheSelector = $('state[id=parser.0.*]');

var htmlString ="<table><tr><td>NAME   </td><td>IP   </td><td>   </td></tr>";

var cacheSelector = $('[id=parser.0.*]');

//console.log(cacheSelector);

var counter =0;

cacheSelector.each(function(id, i) {

counter = counter+1

var devicename = getObject(id).common.name;

var ip = id.replace(/_/g, ".");

var ip = ip.replace(/parser.0./g, "");

// log(id + " : " + devicename + " : " + ip );

var devicenameName=devicename;

devicename="Netzwerk.Gerät"+counter.toString()+".NameGerät";

createState(devicename, 'empty', { name: 'Name des Geräts', desc: '', type: 'string', role: '',read: true, write: true });

setStateDelayed(devicename, devicenameName, 800);

devicename="Netzwerk.Gerät"+counter.toString()+".IPAdresse";

setStateDelayed(devicename, ip, 800);

createState(devicename, 'empty', { name: 'IP des Geräts', desc: '', type: 'string', role: '',read: true, write: true });

var wert1 = getState(id).val;

if (wert1) wert1 = "";

if (!wert1) wert1= "";

htmlString=htmlString.concat("<tr><td>" + devicenameName + "   </td><td>" + ip + "   </td><td>" + wert1 + "</td></tr>");

});

//log(counter);

createState('Netzwerk.StringHTML', 0, {name: 'StringHTML', desc: '', type: 'string', role: '',read: true, write: true });

createState('Netzwerk.Anzahl', 0, { name: 'Anzahl', desc: 'Anzahl der Geräte', type: 'number', unit: '', min: '0', max: '255', role: '',read: true, write: true });

setStateDelayed('Netzwerk.Anzahl', counter, 800);

setStateDelayed('Netzwerk.StringHTML', htmlString.concat("</table>"), 800);

bekomme ich mal eine Ladung Netzwerk Geräte mit den Namen der Bahnen

das ist schon mal ok in dem String HTML kommt auch die Ausgabe

Im Prinzip bräuchte ich ein Ordner und im String HTML sollte Bahn , Wartezeit
stehen (das würde ich noch hinbekommen)

Aber Absteigende Sortierung und Grüner Pfeil für geöffnet (ab 1Minute aufwärts)
oder ein rotes Kreuz bei Ausgabe "Null Minuten" (für geschlossen) sowas checke ich nicht,
da kann nur @liv-in-sky helfen.

Achja , der parser.0 zeigt die Bahnen wie folgt an :

Grüße Alex

[liv-in-sky]

@Alexxx2005

hab es nur überflogen - bin zeitlich etwas eng - vielleicht hilft das weiter

probier mal das hier - es wird alle 30 sekunden gecheckt und dann ausgegeben

mit sortierung

Spoiler

var cacheSelector = $('state[id=parser.0.*]');



var cacheSelector = $('[id=parser.0.*]');


schedule( "*/30 * * * * *",  function () {   
 
var sortArr=[];
var htmlString ="<table><tr><td>NAME   </td><td>IP   </td><td>   </td></tr>";

//console.log(cacheSelector);



var counter =0;

cacheSelector.each(function(id, i) {

counter = counter+1

var devicename = getObject(id).common.name;

var ip = id.replace(/_/g, ".");

var ip = ip.replace(/parser.0./g, "");

// log(id + " : " + devicename + " : " + ip );

var devicenameName=devicename;

devicename="Netzwerk.Gerät"+counter.toString()+".NameGerät";

createState(devicename, 'empty', { name: 'Name des Geräts', desc: '', type: 'string', role: '',read: true, write: true });

setStateDelayed(devicename, devicenameName, 800);


devicename="Netzwerk.Gerät"+counter.toString()+".IPAdresse";

setStateDelayed(devicename, ip, 800);

createState(devicename, 'empty', { name: 'IP des Geräts', desc: '', type: 'string', role: '',read: true, write: true });

var wert1 = getState(id).val;
var wert0 = getState(id).val;

if (wert1) wert1 = "✅";

if (!wert1) wert1= "❌";

let help = [devicename,ip,wert0,wert1];
sortArr.push(help);
//log(sortArr[0]);

});

function numSort(a, b) { 
   
  return parseInt(a[2]) - parseInt(b[2]);
} 

sortArr.sort(numSort);
         



       for (var i=0; i<sortArr.length;i++) {
           htmlString=htmlString+"<tr><td>" + sortArr[i][0] + "   </td><td>" + sortArr[i][1] + "   </td><td>" + sortArr[i][2] + "   </td><td>" + sortArr[i][3] + "</td></tr>";
       }      

//htmlString=htmlString.concat("<tr><td>" + devicenameName + "   </td><td>" + ip + "   </td><td>" + wert1 + "</td></tr>");

//log(counter);

createState('Netzwerk.StringHTML', 0, {name: 'StringHTML', desc: '', type: 'string', role: '',read: true, write: true });

createState('Netzwerk.Anzahl', 0, { name: 'Anzahl', desc: 'Anzahl der Geräte', type: 'number', unit: '', min: '0', max: '255', role: '',read: true, write: true });

setStateDelayed('Netzwerk.Anzahl', counter, 800);
setStateDelayed('Netzwerk.StringHTML', htmlString.concat("</table>"), 800);
});

[Alexxx2005]

@liv-in-sky

Jawohl das sieht schon mal gut aus, habe soweit mal alles angepasst was ich
machen konnte

Spoiler

var cacheSelector = $('state[id=parser.0.]');
var cacheSelector = $('[id=parser.0.]');
schedule( "*/30 * * * * *", function () {
var sortArr=[];
var htmlString ="<table><tr><td>Bahn </td><td>Wartezeit in Minuten </td><td> </td></tr>";
//console.log(cacheSelector);
var counter =0;
cacheSelector.each(function(id, i) {
counter = counter+1
var devicename = getObject(id).common.name;
var ip = id.replace(/_/g, ".");
var ip = ip.replace(/parser.0./g, "");
// log(id + " : " + devicename + " : " + ip );
var devicenameName=devicename;
devicename="Park.Wartezeit"+counter.toString()+".Bahn";
createState(devicename, 'empty', { name: 'Name der Bahn', desc: '', type: 'string', role: '',read: true, write: true });
setStateDelayed(devicename, devicenameName, 800);
devicename="Park.Wartezeit"+counter.toString()+".Bahn";
setStateDelayed(devicename, ip, 800);
createState(devicename, 'empty', { name: 'Bahn', desc: '', type: 'string', role: '',read: true, write: true });
var wert1 = getState(id).val;
var wert0 = getState(id).val;
if (wert1) wert1 = "";
if (!wert1) wert1= "";
let help = [devicename,ip,wert0,wert1];
sortArr.push(help);
//log(sortArr[0]);
});
function numSort(a, b) {

return parseInt(a[2]) - parseInt(b[2]);

}

sortArr.sort(numSort);

   for (var i=0; i<sortArr.length;i++) {

       htmlString=htmlString+"<tr><td>" + sortArr[i][0] + "   </td><td>" + sortArr[i][1] + "   </td><td>" + sortArr[i][2] + "   </td><td>" + sortArr[i][3] + "</td></tr>";

   }      

//htmlString=htmlString.concat("<tr><td>" + devicenameName + " </td><td>" + ip + " </td><td>" + wert1 + "</td></tr>");
//log(counter);
createState('Park.StringHTML', 0, {name: 'StringHTML', desc: '', type: 'string', role: '',read: true, write: true });
createState('Park.Anzahl', 0, { name: 'Anzahl', desc: 'Anzahl der Geräte', type: 'number', unit: '', min: '0', max: '255', role: '',read: true, write: true });
setStateDelayed('Park.Anzahl', counter, 800);
setStateDelayed('Park.StringHTML', htmlString.concat("</table>"), 800);
});

Das Ergebniss :

wenn ich nun bei :

let help = [devicename,ip,wert0,wert1];

den devicename, lösche erhalte ich diese Ausgabe :

das würde meiner Vorstellung entsprechen, allerdings passt nun
die Sortierung nicht mehr und nach dem Haken kommt ein
"undefined"

Leider verstehe ich nicht warum das jetzt kommt bzw. was ich noch
löschen muss damit es nicht mehr kommt.

Und was müßte man noch ändern für eine "absteigende Sortierung"

Danke,

Grüße Alex

[liv-in-sky]

@Alexxx2005

hier wird sotiert - wenn du die werte im array änderst kommt es zu problemen

function numSort(a, b) { 
    
   return parseInt(a[2]) - parseInt(b[2]);
} 

sortArr.sort(numSort);

hier wird das array geschrieben:

let help = [devicename,ip,wert0,wert1];

devicename = 0, ip =1, wert0 =2 wert1=3

in der sortierung wird auf wert [2] sortiert - das hat sich ja geändert, weil du etwas nicht mehr ins array schreibst - wenn der devicename fehlt, ist ip =0, wert0 = 1 und wert1=2 --> du musst die 2 auf die 1 ändern in der sortierung

bei der ausgabe: es fehlt auch da der devicename also musst du auch dort den punktsortArr[i][3] löschen, da der nicht mehr existiert (undefined) - das array geht nur von 0 bis 2 (3 werte) nicht von 0 bis 3 (4 werte)

   htmlString=htmlString+"<tr><td>" + sortArr[i][0] + "   </td><td>" + sortArr[i][1] + "   </td><td>" + sortArr[i][2] +  "</td></tr>";

---

die sortierung umdrehen: versuch mal

function numSort(a, b) { 
    
   return   parseInt(b[2]) - parseInt(a[2]);
} 

also b[2] und a[2] austauschen - bzw. steht da ja jetzt b[1]-a[1], da wir das oben umgestellt haben

[Alexxx2005]

Danke sehr gut erklärt, nun habe ich es verstanden, hätte jetzt noch zwei Fragen :

jede Bahn die nicht im Betrieb ist wird mit "null" und "X" ausgegeben,

Ist es möglich das dies in der Liste ganz unten oder ganz oben ausgegeben wird.
Ebenfalls würde mich noch interessieren ob es möglich ist die Tabelle :

zwei Spaltig zu gespalten damit die Zeilen nicht zu lang werden und es ins VIS geht

Grüße Alex

[liv-in-sky]

@Alexxx2005 das null ist irgendwie falsch - da müßte 0 stehen - dann würde es auch sortiert werden

paste mal dein momentanes script

[liv-in-sky]

@Alexxx2005 und zeige mal, was in den parser.0 datenpunkten steht - ist da schon de fehler vom parsen ? "null" ist ein "fehler" und bedeutet nicht 0

den müßte man dann noch abfangen im script

[Homoran]

@liv-in-sky sagte in Adapter - Parser soll Wartezeiten auslesen:

da müßte 0 stehen

unendlich wäre sinnvoller

[liv-in-sky]

@Homoran unendlich oder "not available"

[Homoran]

@liv-in-sky
Wenn es in Zahlen ausgedrückt werden soll ist bei geschlossen die Wartezeit unendlich oder pragmatich 999(9999) je nach anzahl der Stellen

[liv-in-sky]

@Homoran jo - da hast du wohl recht

[Alexxx2005]

@liv-in-sky

Das "Null" steht drin weil die Bahn heute nicht geloggt wird kp.
Sie erscheint auch nicht auf der Homepage , wenn ich z.b. einen
falschen Link eingebe kommt ebenfalls "Null"

Dachte man kann beim parser bei Ersatz eine Ersatzzahl definieren
aber das funktioniert nicht.

Grüße Alex