[gelöst] Influxdb2 API Query, Ergebnis weiterverarbeiten

[Ralph 0]

Hallo,

nach einigermaßen langwierigen Bemühungen habe ich es geschafft, Ergebnisse aus meiner Influxdb2 mittels API-Query zu erhalten. Bei der Weiterverarbeitung habe ich aber noch ein Problem.
Ich möchte aus dem Ergebnis der Abfrage die Summe der Werte in einen anderen Datenpunkt zurückschreiben.

Die Abfrage sieht so aus:

queryApi.queryRows(`from(bucket: "iobroker") |> range(start: -15m) |> filter(fn: (r) => r["_measurement"] == "0_userdata.0.Heizstab_Leistung" and r["_field"] == "value") `, {
    next: (row, tableMeta) => {
        const o = tableMeta.toObject(row)
        pushRow(o);
    },
    error: (error) => {console.error(error)}, complete: () => {
        for (i = 0; i<myarray.length; i++) {
            myresult = (myarray[i]);
            console.log(myresult + myarray[i]); //Werte aufsummieren
        }},
})   
console.log("Result: " + myresult);

function pushRow(row) {
    myarray.push(row['_value']);
}

Zeile 12 ergibt natürlich kein Ergebnis, weil diese im Script schon verarbeitet wird, wenn die Query noch nicht durchgelaufen ist.
Zeile 9 gibt mir die Ergebnisse aus, aber natürlich für jeden Durchlauf.
Ich würde jetzt gern nur das letzte Ergebnis dieses Durchlaufs (hier also die Summe der 15 min) in einen anderen Datenpunkt zurückschreiben.

Als Zwischenlösung habe ich über die Entprellzeit im Influx-Adapter zumindest verhindert, dass alle Werte gespeichert werden, bei mehreren Abfragen dieser Art belastet das aber die Datenbank unnötig.

Ich vermute, ich müsste das komplette Ergebnis der Query nehmen und anschließend (ab Zeile 12) verarbeiten, hab ich aber bisher nicht hinbekommen.

Hat da jemand von euch vielleicht eine Lösung parat?

Ralph

[Ralph 0]

Moin,

hab jetzt für mich eine Lösung gefunden und wollte die mal hier einstellen, vielleicht hilft's ja mal irgendjemandem weiter.

Ich bin von der Api-Query zum sendTo-Command gewechselt, der Weg sollte aber für die Api-Query vermutlich auch funktionieren, hab ich aber nicht ausprobiert.

Wenn ich so im Nachhinein drauf gucke - eigentlich ganz einfach :-).
Geht wahrscheinlich noch eleganter aber funktioniert für mich erstmal.

function mysum(mybucket, mytime, mymeasurement, mymeasurement_json){
    sendTo('influxdb.1', 'query', 'from(bucket: "'+mybucket+'") |> range(start: -'+mytime+') |> filter(fn: (r) => r["_measurement"] == "'+mymeasurement+'" and r["_field"] == "value")', function (result) {
        if (result.error) {
            console.error(result.error);
        } else {
            setState(mymeasurement_json, JSON.stringify(result));
        }
    });
    var ergebnis = 0.0, myjson = JSON.parse(getState(mymeasurement_json).val);
    for (var i = 0; i<myjson.result[0].length; i++) {
        ergebnis = ergebnis + myjson.result[0][i]._value;
    }
    return(ergebnis);
}