hallo, also ich glaube, das ich dieses async und await oder CreateState nicht verstanden habe, oder anderswo ist der Wurm drin:-)

Für ein ECharts - Balkendiagramm möchte ich Daten einer InfluxBD abfragen und als Json String bereitstellen.

Ich hatte mit vorgestellt, das der Datenpunkt (zeile 16) bei jedem Durchlauf Init() neu angelegt wird, also leer ist.
Das ist leider nicht so denn Daten werden an die bestehende angehangen.

let flux =  
    'import "date"' +
    ' import "timezone"' +
    ' option location = timezone.location(name: "Europe/Berlin")'+
    ' from(bucket: "iobroker")' +
    ' |> range(start: -7d)' +
    ' |> filter(fn: (r) => r["_measurement"] == "zaehlerstand.strom")' +
    ' |> filter(fn: (r) => r["_field"] == "value")'+
    ' |> difference(nonNegative: true, columns: ["_value"])'+
    ' |> aggregateWindow(every: 1d, fn: sum, createEmpty: true,timeSrc: "_start")'+
    ' |> map( fn: (r) => ({r with fluxts: (uint(v: r._time) / uint(v: 1000 * 1000 * 1000 ))}))'+
    ' |> fill(column: "_value", value: 0.0)';
    //' |> cumulativeSum(columns: ["_value"])';
    //' |> keep(columns: ["_time", "_value","fluxts"])';

let idJson = '0_userdata.0.test.json';
let obj = JSON.parse(getState(idJson).val);

// Datenpunkte anlegen ... 
async function init() {
    createState(idJson, '[]',true, { type: 'string', name: 'Verbrauchswerte' });
};

// Daten holen ... 
async function getData () {
     sendTo('influxdb.1', 'query', flux, function (result) {
        if (result.error) {
            console.error(result.error);
        } else  {
        // show result
            obj.splice(0,0);
            for (var i = 0; i < result.result[0].length; i++) {
                var resMonat = result.result[0][i].fluxts; 
                var resWert = result.result[0][i]._value;
                obj.push({ ts: resMonat, val: resWert });
            }
            console.log(obj);
            setState(idJson, JSON.stringify(obj),true);
        }
    });
};

await init(); // einmal ausführen

schedule('{"time":{"start":"00:00","end":"24:00","mode":"minutes","interval":1},"period":{"days":1}}', async function () {
    await init();
    await getData();
});