Erster Werte des Tages aus History auslesen

Hallo,
passend zum Thema habe ich eine ähnliche Lösung gefunden, die vielleicht auch in Zukunft anderen hilft, die wie ich Probleme mit 'getHistory' haben.
Die gewünschten Daten können auch mit folgenden Befehl ausgegeben werden:


sendTo('influxdb.0', 'query', 'SELECT max("value") FROM "***" WHERE time > now() - 7d'

In diesem Beispiel wird der maximale Wert (max("value")) des Datenpunktes ("***") der letzten 7 Tage ("now() - 7d") ausgegeben. So funktioniert es bei mir wunderbar.
Aber Achtung: Die Ausgabe erfolgt als Array.

MCU

@Chrille1507 Fehlt noch ne Klammer am Ende?

Chrille1507

@MCU Jein. Bei mir geht es dann mit einer Function weiter. Soll ich die Klammer ergänzen?

MCU

@Chrille1507 Oder auch die komplette function, nur so ist es etwas verwirrend?

Chrille1507

@MCU Gerne. Anbei eine komplette Funktion als Beispiel.

schedule('* * * * *', function() {
    sendTo('influxdb.0', 'query', 'SELECT max("value") FROM "Beipiel" WHERE time > now() - 7d', function(result) {
        setState("Beispiel_Datenpunkt", JSON.stringify(result.result[0])); 
        });
});

In diesem Beispiel würde jede Minute (schedule '* * * * *') der höchste Wert (max("value")) der letzten 7 Tage (time > now() - 7d) in einen Beispiel-Datenpunkt geschrieben werden.

glitzi

Hallo,

ist es eigentlich schlecht wenn ich

var berechnung

in zwei funktionen nutze?

Denn seltsamer weise schreibt er mir gelegentlich eine 0 um 00:00 Uhr in den Tageswert!

// Wasserzähler summieren

createState('WasserzählerSumme', function () {
  on({id: "mqtt.0.ESP_Easy.Wasser.Count"/*ESP_Easy/Wasser/Count*/, change: "any"}, function (obj) {
    var value = obj.state.val;
    var oldValue = obj.oldState.val;
   
       var berechnung = Math.round((getState('javascript.0.WasserzählerSumme').val + (getState("mqtt.0.ESP_Easy.Wasser.Count").val / 60))*100 ) / 100;
     //  log(berechnung);
    setState('javascript.0.WasserzählerSumme', berechnung, true);
    
  });
});

// Wasser Tageswert
schedule1 =  schedule('{"time":{"exactTime":true,"start":"23:59"},"period":{"days":1}}', function () {

createState('Wasserzähler_Tageswert');

sendTo('influxdb.0', 'getHistory', {
    id: 'javascript.0.WasserzählerSumme',
    options: {
        start:      getDateObject('00:00').getTime(),
        count:      1,
        aggregate: 'none' // or 'none' to get raw values
    }
}, function (result) {
    var berechnung = Math.round((getState('javascript.0.WasserzählerSumme').val - result.result[0].val) * 100) / 100;
    setState('javascript.0.Wasserzähler_Tageswert', berechnung, true);
    log("Wasser Tageswert geschrieben"+ berechnung);
});
});

//Wasser Tageswert hochlaufend
on({id: ['mqtt.0.ESP_Easy.Wasser.Count','javascript.0.Tick_1m'], change: "any"}, function (obj) {
     
createState('Wasserzähler_Tageswert_hochlaufend');

sendTo('influxdb.0', 'getHistory', {
    id: 'javascript.0.WasserzählerSumme',
    options: {
        start:      getDateObject('00:00').getTime(),
        count:      1,
        aggregate: 'none' // or 'none' to get raw values
    }
}, function (result) {
    //log(result.result[0].val + ' ' + formatDate(result.result[0].ts, 'DD.MM.YYYY hh:mm:ss'));
    //log(getState('javascript.0.WasserzählerSumme').val);
    var berechnung = Math.round((getState('javascript.0.WasserzählerSumme').val - result.result[0].val) * 100) / 100;
    setState('javascript.0.Wasserzähler_Tageswert_hochlaufend', berechnung, true);  
});
});

//Wasser Minutenwert
schedule3 = schedule('* * * * *', function () {

createState('Wasserzähler_Minutenwert');
var end = new Date().getTime();
sendTo('influxdb.0', 'getHistory', {
    id: 'javascript.0.WasserzählerSumme',
    options: {
        start:      end - 60000,
        count:      1,
        aggregate: 'none' // or 'none' to get raw values
    }
}, function (result) {
    //log(result.result[0].val + ' ' + formatDate(result.result[0].ts, 'DD.MM.YYYY hh:mm:ss'));
    //log(getState('javascript.0.WasserzählerSumme').val);
    var berechnung = Math.round((getState('javascript.0.WasserzählerSumme').val - result.result[0].val) * 100) / 100;
    setState('javascript.0.Wasserzähler_Minutenwert', berechnung, true);  
});
});

paul53

@glitzi sagte:

ist es eigentlich schlecht wenn ich
var berechnung
in zwei funktionen nutze?

Nein, die Variable ist lokal innerhalb der jeweiligen Funktion gültig.

glitzi

@paul53
Eventuell eine Idee warum der Tageswert gelegentlich um 0:00 Uhr geschrieben wird?

paul53

@glitzi sagte:

Idee warum der Tageswert gelegentlich um 0:00 Uhr geschrieben wird?

Nein. Nimm mal einen normalen CRON-String

schedule1 =  schedule('59 23 * * *', function () {

paul53

@glitzi
Übrigens: Das Script verbraucht viel zu viel Ressourcen (dreimal Datenbankabfrage). Das kann man viel einfacher ohne Datenbank-Abfrage mit nur einem Datenpunkt-Trigger, einem Schedule und 4 Datenpunkten lösen:

Zählerstand
Zählerstand Tageswechsel
Verbrauch gestern
laufender Verbrauch heute

const idCount = 'mqtt.0.ESP_Easy.Wasser.Count';
const path = '0_userdata.0.Wasser.'
const idStand = path + 'Zaehlerstand';
const idTagesstand = path + 'Stand_Tageswechsel';
const idGestern = path + 'Verbrauch_gestern';
const idHeute = path + 'Verbrauch_heute';

var stand = 0; // aktuellen Zählerstand eintragen !
if(existsState(idStand)) stand = getState(idStand).val;
else createState(idStand, stand, {type: 'number', unit: 'm³', role: 'value'});
var tag = 0; // aktuellen Stand bei letztem Tageswechsel eintragen !
if(existsState(idTagesstand)) tag = getState(idTagesstand).val;
else createState(idTagesstand, tag, {type: 'number', unit: 'm³', role: 'value'});
var heute = stand - tag;
createState(idHeute, heute, {type: 'number', unit: 'm³', role: 'value'});
createState(idGestern, heute, {type: 'number', unit: 'm³', role: 'value'});

on({id: idCount}, function(dp) {
    stand = stand + dp.state.val / 60; 
    setState(idStand, Math.round(stand * 100) / 100, true);
    heute = stand - tag;
    setState(idHeute, Math.round(heute * 100) / 100, true);
});

schedule('59 23 * * *', function() {
    setState(idGestern, Math.round(heute * 100) / 100, true);
    setState(idHeute, 0, true);
    tag = stand;
    setState(idTagesstand, Math.round(tag * 100) / 100, true);
});

EDIT: Schedule geändert auf 23:59 Uhr.

glitzi

@paul53

Danke, sehr elegant gelöst...

komme von openHAB, und das hat beim Neustart immer die Werte vergessen, daher der Ansatz mit der Datenbank.

Agria4800

@paul53 Ich habe eine Frage zu deinem Script, welches ich etws Zweckentfremden möchte:
Hier triggerst du auf die Aktualisierung des DP von iD Count (Denke ich zumindest) und führst idStand und idHeute aus mit jeder Aktualisierung.
Wie kann ich das in ein Schedule setzen, welches einfach 1 min. vor dem bereits vorhandenen ausgeführt wird, aber ohne eine Aktualisierung, also eine reine Ausführung ?
Mir geht es darum, das ich einen Tageswert (idCount) am Ende des Tages z.B.23:57 schreiben möchte (idHeute+idStand) und 2 min später 23:59 den Rest mit idGestern, idHeute auf 0 und idTagesstand ausführen,
kannst du mir dabei helfen ?

Hier on({id: idCount}, function(dp) hatte ich schon ein Schedule gesetzt, aber meine Aktualisierung ist nicht in der Zeit, daher passiert nichts... daher benötige ich die einfache Ausführung per Zeit.

on({id: idCount}, function(dp) {
    stand = stand + dp.state.val / 60; 
    setState(idStand, Math.round(stand * 100) / 100, true);
    heute = stand - tag;
    setState(idHeute, Math.round(heute * 100) / 100, true);
});

Gruß Benny

Community Forum

NEWS

Erster Werte des Tages aus History auslesen

Support us

573

32.7k

82.4k

1.3m