[gelöst] Adapter - Parser / Wartezeiten auslesen

Homoran

@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.

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 :


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 :

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

NetzwerkGeräte.PNG

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

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

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

Community Forum

NEWS

[gelöst] Adapter - Parser / Wartezeiten auslesen

Support us

679

32.6k

82.3k

1.3m