Result-Funktion von InfluxDB-Adapter richtig nutzen
-
@etzeste13 Wie hast du das Script verändert, zeig mal.
-
Hi, sry für die späte Antwort, ich kam leider nicht eher dazu hier weiterzumachen...
Hier das geänderte Script.//Die Ost-Süd-West- Leistungen von der letzen Stunde zusammenrechnen und abspeichern schedule("*/60 * * * *", function () { // die Werte von Osten abfragen und abspeichern. let end = new Date().getTime(); // definiert aktuellen Zeitpunkt. //console.log(end); let Stundenertrag = 0; let Time_to_next_value_in_ms = 0; let x_s = 0; sendTo('influxdb.0', 'getHistory', { // ist der Aufruf der Datenbank-Fuktion get History vom Influx.DB Adapter 0 id: '0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-OST', // Datenpunkt der ausgelesen wird options: { // die optionen anhand deren ausgelesen werden soll start: end - 3600000, // Startpunkt ist aktuelle Zeitpunkt - 1Stunde in ms end: end, // auslesen bis jetzt in ms count: 180, //bis zu 180 Werte auslesen, da generell alle 30sek geschrieben wird aggregate: 'none' // or 'none' to get raw values // aggregate: none definiert die eigentlichen Werte ausgegeben werden sollen } }, function (result) { for (var i = 0; i < result.result.length; i++) { //console.log(result.result[i].ts) //timestamp des Ergebnisses der Nr[i] ausgeben if (i == 0) { // im ersten Durchlauf muss mann die 30sec manuell angeben, da sonst bei der berechnung [i-1] ein Fehler auftritt Time_to_next_value_in_ms = 30000; } else { Time_to_next_value_in_ms = result.result[i].ts - result.result[i-1].ts; } //console.log(Time_to_next_value_in_ms); Stundenertrag = Stundenertrag + result.result[i].val / (3600000 / Time_to_next_value_in_ms); //die 3.600.000ms / die MS zum Vorgängerwert addiert, ergeben die W/h x_s = x_s + 1; // x_s nur zur Kontrolle, damit ich sehe wie viele Werte addiert wurden } Stundenertrag = Math.round(Stundenertrag); //Ergebnis auf ganze Zahl runden console.log('Stundenertrag_OST: ' + Stundenertrag + ', gelesene Einträge: ' + x_s); // PV-Ertrag der letzten Stunde + die Anzahl der Datenpunkte ins LOG schreiben setState("0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-OST_letzte_Stunde", Stundenertrag, true); //PV-Ertrag der letzten Stunde in Datenpunkt schreiben }); // die Werte von Süden abfragen und abspeichern. end = new Date().getTime(); // definiert aktuellen Zeitpunkt. //console.log(end); Stundenertrag = 0; Time_to_next_value_in_ms = 0; x_s = 0; sendTo('influxdb.0', 'getHistory', { // ist der Aufruf der Datenbank-Fuktion get History vom Influx.DB Adapter 0 id: '0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-SÜD', // Datenpunkt der ausgelesen wird options: { // die optionen anhand deren ausgelesen werden soll start: end - 3600000, // Startpunkt ist aktuelle Zeitpunkt - 1Stunde in ms end: end, // auslesen bis jetzt in ms count: 180, //bis zu 180 Werte auslesen, da generell alle 30sek geschrieben wird aggregate: 'none' // or 'none' to get raw values // aggregate: none definiert die eigentlichen Werte ausgegeben werden sollen } }, function (result) { for (var i = 0; i < result.result.length; i++) { //console.log(result.result[i].ts) //timestamp des Ergebnisses der Nr[i] ausgeben if (i == 0) { // im ersten Durchlauf muss mann die 30sec manuell angeben, da sonst bei der berechnung [i-1] ein Fehler auftritt Time_to_next_value_in_ms = 30000; } else { Time_to_next_value_in_ms = result.result[i].ts - result.result[i-1].ts; } //console.log(Time_to_next_value_in_ms); Stundenertrag = Stundenertrag + result.result[i].val / (3600000 / Time_to_next_value_in_ms); //die 3.600.000ms / die MS zum Vorgängerwert addiert, ergeben die W/h x_s = x_s + 1; // x_s nur zur Kontrolle, damit ich sehe wie viele Werte addiert wurden } Stundenertrag = Math.round(Stundenertrag); //Ergebnis auf ganze Zahl runden console.log('Stundenertrag_SUED: ' + Stundenertrag + ', gelesene Einträge: ' + x_s); // PV-Ertrag der letzten Stunde + die Anzahl der Datenpunkte ins LOG schreiben setState("0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-SÜD_letzte_Stunde", Stundenertrag, true); //PV-Ertrag der letzten Stunde in Datenpunkt schreiben }); // die Werte von WEST abfragen und abspeichern. end = new Date().getTime(); // definiert aktuellen Zeitpunkt. //console.log(end); Stundenertrag = 0; Time_to_next_value_in_ms = 0; x_s = 0; sendTo('influxdb.0', 'getHistory', { // ist der Aufruf der Datenbank-Fuktion get History vom Influx.DB Adapter 0 id: '0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-WEST', // Datenpunkt der ausgelesen wird options: { // die optionen anhand deren ausgelesen werden soll start: end - 3600000, // Startpunkt ist aktuelle Zeitpunkt - 1Stunde in ms end: end, // auslesen bis jetzt in ms count: 180, //bis zu 180 Werte auslesen, da generell alle 30sek geschrieben wird aggregate: 'none' // or 'none' to get raw values // aggregate: none definiert die eigentlichen Werte ausgegeben werden sollen } }, function (result) { for (var i = 0; i < result.result.length; i++) { //console.log(result.result[i].ts) //timestamp des Ergebnisses der Nr[i] ausgeben if (i == 0) { // im ersten Durchlauf muss mann die 30sec manuell angeben, da sonst bei der berechnung [i-1] ein Fehler auftritt Time_to_next_value_in_ms = 30000; } else { Time_to_next_value_in_ms = result.result[i].ts - result.result[i-1].ts; } //console.log(Time_to_next_value_in_ms); Stundenertrag = Stundenertrag + result.result[i].val / (3600000 / Time_to_next_value_in_ms); //die 3.600.000ms / die MS zum Vorgängerwert addiert, ergeben die W/h x_s = x_s + 1; // x_s nur zur Kontrolle, damit ich sehe wie viele Werte addiert wurden } Stundenertrag = Math.round(Stundenertrag); //Ergebnis auf ganze Zahl runden console.log('Stundenertrag_WEST: ' + Stundenertrag + ', gelesene Einträge: ' + x_s); // PV-Ertrag der letzten Stunde + die Anzahl der Datenpunkte ins LOG schreiben setState("0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-WEST_letzte_Stunde", Stundenertrag, true); //PV-Ertrag der letzten Stunde in Datenpunkt schreiben }); }); -
@etzeste13 Ich würde die sendTo ineinander verschachteln.
/Die Ost-Süd-West- Leistungen von der letzen Stunde zusammenrechnen und abspeichern schedule("*/60 * * * *", function () { // die Werte von Osten abfragen und abspeichern. let end = new Date().getTime(); // definiert aktuellen Zeitpunkt. //console.log(end); let Stundenertrag = 0; let Time_to_next_value_in_ms = 0; let x_s = 0; sendTo('influxdb.0', 'getHistory', { // ist der Aufruf der Datenbank-Fuktion get History vom Influx.DB Adapter 0 id: '0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-OST', // Datenpunkt der ausgelesen wird options: { // die optionen anhand deren ausgelesen werden soll start: end - 3600000, // Startpunkt ist aktuelle Zeitpunkt - 1Stunde in ms end: end, // auslesen bis jetzt in ms count: 180, //bis zu 180 Werte auslesen, da generell alle 30sek geschrieben wird aggregate: 'none' // or 'none' to get raw values // aggregate: none definiert die eigentlichen Werte ausgegeben werden sollen } }, function (result) { for (var i = 0; i < result.result.length; i++) { //console.log(result.result[i].ts) //timestamp des Ergebnisses der Nr[i] ausgeben if (i == 0) { // im ersten Durchlauf muss mann die 30sec manuell angeben, da sonst bei der berechnung [i-1] ein Fehler auftritt Time_to_next_value_in_ms = 30000; } else { Time_to_next_value_in_ms = result.result[i].ts - result.result[i-1].ts; } //console.log(Time_to_next_value_in_ms); Stundenertrag = Stundenertrag + result.result[i].val / (3600000 / Time_to_next_value_in_ms); //die 3.600.000ms / die MS zum Vorgängerwert addiert, ergeben die W/h x_s = x_s + 1; // x_s nur zur Kontrolle, damit ich sehe wie viele Werte addiert wurden } Stundenertrag = Math.round(Stundenertrag); //Ergebnis auf ganze Zahl runden console.log('Stundenertrag_OST: ' + Stundenertrag + ', gelesene Einträge: ' + x_s); // PV-Ertrag der letzten Stunde + die Anzahl der Datenpunkte ins LOG schreiben setState("0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-OST_letzte_Stunde", Stundenertrag, true); //PV-Ertrag der letzten Stunde in Datenpunkt schreiben // die Werte von Süden abfragen und abspeichern. end = new Date().getTime(); // definiert aktuellen Zeitpunkt. //console.log(end); Stundenertrag = 0; Time_to_next_value_in_ms = 0; x_s = 0; sendTo('influxdb.0', 'getHistory', { // ist der Aufruf der Datenbank-Fuktion get History vom Influx.DB Adapter 0 id: '0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-SÜD', // Datenpunkt der ausgelesen wird options: { // die optionen anhand deren ausgelesen werden soll start: end - 3600000, // Startpunkt ist aktuelle Zeitpunkt - 1Stunde in ms end: end, // auslesen bis jetzt in ms count: 180, //bis zu 180 Werte auslesen, da generell alle 30sek geschrieben wird aggregate: 'none' // or 'none' to get raw values // aggregate: none definiert die eigentlichen Werte ausgegeben werden sollen } }, function (result) { for (var i = 0; i < result.result.length; i++) { //console.log(result.result[i].ts) //timestamp des Ergebnisses der Nr[i] ausgeben if (i == 0) { // im ersten Durchlauf muss mann die 30sec manuell angeben, da sonst bei der berechnung [i-1] ein Fehler auftritt Time_to_next_value_in_ms = 30000; } else { Time_to_next_value_in_ms = result.result[i].ts - result.result[i-1].ts; } //console.log(Time_to_next_value_in_ms); Stundenertrag = Stundenertrag + result.result[i].val / (3600000 / Time_to_next_value_in_ms); //die 3.600.000ms / die MS zum Vorgängerwert addiert, ergeben die W/h x_s = x_s + 1; // x_s nur zur Kontrolle, damit ich sehe wie viele Werte addiert wurden } Stundenertrag = Math.round(Stundenertrag); //Ergebnis auf ganze Zahl runden console.log('Stundenertrag_SUED: ' + Stundenertrag + ', gelesene Einträge: ' + x_s); // PV-Ertrag der letzten Stunde + die Anzahl der Datenpunkte ins LOG schreiben setState("0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-SÜD_letzte_Stunde", Stundenertrag, true); //PV-Ertrag der letzten Stunde in Datenpunkt schreiben // die Werte von WEST abfragen und abspeichern. end = new Date().getTime(); // definiert aktuellen Zeitpunkt. //console.log(end); Stundenertrag = 0; Time_to_next_value_in_ms = 0; x_s = 0; sendTo('influxdb.0', 'getHistory', { // ist der Aufruf der Datenbank-Fuktion get History vom Influx.DB Adapter 0 id: '0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-WEST', // Datenpunkt der ausgelesen wird options: { // die optionen anhand deren ausgelesen werden soll start: end - 3600000, // Startpunkt ist aktuelle Zeitpunkt - 1Stunde in ms end: end, // auslesen bis jetzt in ms count: 180, //bis zu 180 Werte auslesen, da generell alle 30sek geschrieben wird aggregate: 'none' // or 'none' to get raw values // aggregate: none definiert die eigentlichen Werte ausgegeben werden sollen } }, function (result) { for (var i = 0; i < result.result.length; i++) { //console.log(result.result[i].ts) //timestamp des Ergebnisses der Nr[i] ausgeben if (i == 0) { // im ersten Durchlauf muss mann die 30sec manuell angeben, da sonst bei der berechnung [i-1] ein Fehler auftritt Time_to_next_value_in_ms = 30000; } else { Time_to_next_value_in_ms = result.result[i].ts - result.result[i-1].ts; } //console.log(Time_to_next_value_in_ms); Stundenertrag = Stundenertrag + result.result[i].val / (3600000 / Time_to_next_value_in_ms); //die 3.600.000ms / die MS zum Vorgängerwert addiert, ergeben die W/h x_s = x_s + 1; // x_s nur zur Kontrolle, damit ich sehe wie viele Werte addiert wurden } Stundenertrag = Math.round(Stundenertrag); //Ergebnis auf ganze Zahl runden console.log('Stundenertrag_WEST: ' + Stundenertrag + ', gelesene Einträge: ' + x_s); // PV-Ertrag der letzten Stunde + die Anzahl der Datenpunkte ins LOG schreiben setState("0_userdata.0.PV_Anlagen.MTBG-38_1.Leistung-WEST_letzte_Stunde", Stundenertrag, true); //PV-Ertrag der letzten Stunde in Datenpunkt schreiben }); }); }); }); -
@mcu
wie soll ich das machen? ich muss ja die einzelnen Datenpunkte einzeln aus der influxDB holen... oder nicht ? -
@etzeste13 Ich habe es doch schon gemacht.
Damit wird der nächste sendTo-Befehl erst ausgelöst, wenn die Daten vom 1. da sind, usw.. -
@MCU bitte entschuldige die vlt. blöde Frage, aber ich finde den Unterschied im Code einfach nicht.... kannst du mir kurz schreiben was du geändert hast.... Scheint als ob ich den Wald vor lauter Bäumen nicht finde...
-
@etzeste13
Also es sind 3 sendToVorher:
sendTo{ } sendTo{ } sendTo{ }Nachher:
sendTo{ sendTo{ sendTo{ } } } -
@mcu
Alles klar, jetzt hab ichs... danke dir. Ich werde es morgen testen, wenn wieder die Sonne scheint.... bzw. es hell wird, von Sonne aktuell keine Spur...
-
vielen Dank für deinen Input... jetzt funktioniert es wie es gedacht war.
Kannst du mir vielleicht noch den Grund erklären warum das jetzt funktioniert?vG Etze
-
@etzeste13
Vorherwurden die sendTo Funktionen direkt nacheinander ausgelöst. Es wurde nicht darauf gewartet, bis die Daten verarbeitet wurden.Nachherwurden die Funktionen immer erst dann aufgerufen, wenn die Daten aus der vorherigen Funktion, auch wirklich verarbeitet gewesen sind.
