Jahresrückblick 2025 – unser neuer Blogbeitrag ist online! ✨

[maxclaudi]

Hallo, schönen guten Morgen :-)
Wer hilft mir bitte.

Als Beispiel 3 empfangene json von einem mqtt Datenpunkt:

{"messageId":9875,"product":"solarFlow","deviceId":"aAbCdEx9","timestamp":1748131755,"properties":{"remainOutTime":1752,"batteryElectric":-34},"packData":[{"power":64,"sn":"CO4ABCDE090104"},{"power": 54,"sn":"CO4ABCDE090110"},{"power":54,"sn":"CO4ABCDE090108"}]}

{"messageId":"123","product":"solarFlow","deviceId":"aAbCdEx9","timestamp":1747980893,"properties":{"electricLevel":100,"solarPower2Cycle":38,"outputHomePowerCycle":39},"packData":[{"maxVol":345,"power":54,"sn":"CO4ABCDE090110"},{"totalVol":5170,"sn":"CO4ABCDE090108"}]}

{"messageId":"123","product":"solarFlow","deviceId":"aAbCdEx9","timestamp":1750661953,"properties":{},"packData":[{"power":476,"socLevel":89,"state":1,"maxTemp":3041,"totalVol":5120,"maxVol":341,"minVol":341,"softVersion":4113,"soh":996,"sn":"CO4ABCDE090108"}]}

packData array soll, wenn Verzeichnis mit Seriennummer noch nicht existiert, das Verzeichnis mit Namen der Seriennummer (z. B. "sn":"CO4ABCDE090108") erstellen.

Dann die Datenpunkte, die die Seriennummer betreffen erstellen und die dazugehörigen Werte schreiben.

Falls das Verzeichnis und die Datenpunkte schon existieren, dann Werte in existierendes Verzeichnis und existierende Datenpunkte schreiben.

Falls Verzeichnis schon existiert und der/die Datenpunkt(e) noch nicht, dann Verzeichnis verwenden und Datenpunkt(e) mit Wert anlegen.

---

Bisher verwende ich folgenden Code um Verzeichnis und Datenpunkte automatisch anzulegen:

for(let i in obj) {
    if(typeof obj[i] == 'object') iter(id + '.' + i, obj[i]);
    else {
        if(existsState(id + '.' + i)) setState(id + '.' + i, obj[i], true);
        else createState(id + '.' + i, obj[i]);
    }
}

Nur ist es natürlich so, dass packData je nach Inhalt Verzeichnis 0, 1 oder 2 für die Daten verwendet und die Seriennummer nicht berücksichtigt.
So stehen dann die Werte von

json-Beispiel 1: "sn":"CO4ABCDE090108" in packData.2.
json-Beispiel 2 "sn":"CO4ABCDE090108" in packData.1.
json-Beispiel 3 "sn":"CO4ABCDE090108" in packData.0.

und überschreiben sich und es kommt vor, dass unter 2 Verzeichnissen dann die Werte eines Akku sind.

Ziel ist, dass anhand der Seriennummer in packData (z. B. "sn":"CO4ABCDE090108") die Verzeichnisse erstellt werden und die Werte, die die Seriennummer betreffen mit übergeben werden.

---

Die Seriennummer z. B. "sn":"CO4ABCDE090108" ist immer in letzter Position der Elemente im array, wie in den Beispielen.

---

Den obigen Code würde ich als Grundlage beibehalten wollen, weil er für alle weiteren eingehenden json gut funktioniert.

Wie am besten obigen Code erweitern?

Schon mal ein liebes Dankeschön.

[haus-automatisierung]

@maxclaudi Sowas?

const data = '{"messageId":9875,"product":"solarFlow","deviceId":"aAbCdEx9","timestamp":1748131755,"properties":{"remainOutTime":1752,"batteryElectric":-34},"packData":[{"power":65,"sn":"CO4ABCDE090104"},{"power": 54,"sn":"CO4ABCDE090110"},{"power":54,"sn":"CO4ABCDE090108"}]}';
const dataObj = JSON.parse(data);

const prefix = '0_userdata.0.blabla';

for (const pack of dataObj.packData) {
    const sn = pack.sn;
    const path = `${prefix}.${sn}`;

    if (!existsObject(path)) {
        setObject(path, {
            type: 'folder',
            common: {
                name: sn,
            },
            native: {},
        });
    }

    for (const [key, value] of Object.entries(pack)) {
        if (key !== 'sn') {
            const statePath = `${path}.${key}`;
            if (existsState(statePath)) {
                setState(statePath, value, true);
            } else {
                createState(statePath, value);
            }
        }
    }
}

[maxclaudi]

@haus-automatisierung

wow :-)

Kann's leider nicht sofort testen, aber sieht gut aus :+1:

Dankeschön schon mal.

[haus-automatisierung]

Du könntest sonst auch noch den Timestamp aus dem Payload mit übernehmen:

const data = '{"messageId":9875,"product":"solarFlow","deviceId":"aAbCdEx9","timestamp":1748131755,"properties":{"remainOutTime":1752,"batteryElectric":-34},"packData":[{"power":66,"sn":"CO4ABCDE090104"},{"power": 54,"sn":"CO4ABCDE090110"},{"power":54,"sn":"CO4ABCDE090108"}]}';
const dataObj = JSON.parse(data);

const prefix = '0_userdata.0.blabla';

const ts = dataObj.timestamp * 1000;

for (const pack of dataObj.packData) {
    const sn = pack.sn;
    const path = `${prefix}.${sn}`;

    if (!existsObject(path)) {
        setObject(path, {
            type: 'folder',
            common: {
                name: sn,
            },
            native: {},
        });
    }

    for (const [key, val] of Object.entries(pack)) {
        if (key !== 'sn') {
            const statePath = `${path}.${key}`;
            if (existsState(statePath)) {
                setState(statePath, { val, ts, ack: true });
            } else {
                createState(statePath, val);
            }
        }
    }
}

[maxclaudi]

@haus-automatisierung
supi :+1:
Schade, dass ich nicht gleich loslegen kann.
Großes Dankeschön schon mal :-)

[maxclaudi]

@haus-automatisierung

Hab das mal versucht.

Wenn ich den mqtt Datenpunkt in einem Blockly trigger und dann die Funktion ausführe:

Funktionsname: separate
Variable: "id": folder (z. B.: 0_userdata.0.Datenpunkte.solarflow.HUB)
Variable: wert: Json nach Objekt, getriggerter JSON-Wert

Funktion:

const data = wert; 
const dataObj = JSON.parse(data);
 
const prefix = id;
 
for (const pack of dataObj.packData) {
    const sn = pack.sn;
    const path = `${prefix}.${sn}`;
 
    if (!existsObject(path)) {
        setObject(path, {
            type: 'folder',
            common: {
                name: sn,
            },
            native: {},
        });
    }
 
    for (const [key, value] of Object.entries(pack)) {
        if (key !== 'sn') {
            const statePath = `${path}.${key}`;
            if (existsState(statePath)) {
                setState(statePath, value, true);
            } else {
                createState(statePath, value);
            }
        }
    }
}

error:
SyntaxError: "[object Object]" is not valid JSON

---

ok, dann Blockly geändert zu:
wert: getriggerter JSON-Wert

error
TypeError: dataObj.packData is not iterable

hmmm?

[haus-automatisierung]

@maxclaudi Dann ist der Wert schon ein Objekt und kein String (JSON) mehr. Also kann JSON.parse weg.

Aber warum überhaupt Blockly? Die 3 Zeilen für den Trigger kannst jetzt auch noch direkt in JS schreiben… :)

[haus-automatisierung]

const prefix = '0_userdata.0.Datenpunkte.solarflow.HUB';

on({ id: '...', change: 'ne' }, async (obj) => {
    const dataObj = typeof obj.state.val === 'string' ? JSON.parse(obj.state.val) : obj.state.val;

    const ts = dataObj.timestamp * 1000;

    for (const pack of dataObj.packData) {
        const sn = pack.sn;
        const path = `${prefix}.${sn}`;

        if (!existsObject(path)) {
            setObject(path, {
                type: 'folder',
                common: {
                    name: sn,
                },
                native: {},
            });
        }

        for (const [key, val] of Object.entries(pack)) {
            if (key !== 'sn') {
                const statePath = `${path}.${key}`;
                if (existsState(statePath)) {
                    setState(statePath, { val, ts, ack: true });
                } else {
                    createState(statePath, val);
                }
            }
        }
    }
});

[maxclaudi]

@haus-automatisierung

Ohne Blockly mit Deinem letzten Code gleiches Problem:

const prefix = '0_userdata.0.Datenpunkte.solarflow.HUB2000';
 
on({ id: 'mqtt.1.A8yh63.xxxxx.properties.report', change: 'ne' }, async (obj) => {
    const dataObj = typeof obj.state.val === 'string' ? JSON.parse(obj.state.val) : obj.state.val;
 
    const ts = dataObj.timestamp * 1000;
 
    for (const pack of dataObj.packData) {
        const sn = pack.sn;
        const path = `${prefix}.${sn}`;
 
        if (!existsObject(path)) {
            setObject(path, {
                type: 'folder',
                common: {
                    name: sn,
                },
                native: {},
            });
        }
 
        for (const [key, val] of Object.entries(pack)) {
            if (key !== 'sn') {
                const statePath = `${path}.${key}`;
                if (existsState(statePath)) {
                    setState(statePath, { val, ts, ack: true });
                } else {
                    createState(statePath, val);
                }
            }
        }
    }
});

error
TypeError: dataObj.packData is not iterable

xxxxxx: wurde nur id unkenntlich gemacht

---

Edit/PS:
Sollte man es mit einem vorgesetzten try versuchen?
"packData" ist nicht immer enthalten.
Das allein wird aber nicht der Fehler sein?

---

edit:
wie geschrieben, hier funktioniert die iteration.

for(let i in obj) {
    if(typeof obj[i] == 'object') iter(id + '.' + i, obj[i]);
    else {
        if(existsState(id + '.' + i)) setState(id + '.' + i, obj[i], true);
        else createState(id + '.' + i, obj[i]);
    }
}

da bekommt obj den getriggerten Datenpunkt konvertiert mit "Json nach Objekt"

[haus-automatisierung]

@maxclaudi sagte in Wie json automatisch Datenpunkte in richtige Verzeichnise?:

Ohne Blockly mit Deinem letzten Code gleiches Problem:

Ne, ist ein anderes Problem (und eine ganz andere Meldung) :) Einen Schritt weiter.

@maxclaudi sagte in Wie json automatisch Datenpunkte in richtige Verzeichnise?:

"packData" ist nicht immer enthalten.

Ah okay, die Beispiele oben haben immer ein Array enthalten.

const prefix = '0_userdata.0.Datenpunkte.solarflow.HUB';

on({ id: '...', change: 'ne' }, async (obj) => {
    try {
        const newVal = obj.state.val;
        const dataObj = typeof newVal === 'string' ? JSON.parse(newVal) : newVal;

        if (dataObj.packData && Array.isArray(dataObj.packData)) {
            const ts = dataObj.timestamp * 1000;

            for (const pack of dataObj.packData) {
                const sn = pack.sn;
                const path = `${prefix}.${sn}`;

                if (!existsObject(path)) {
                    setObject(path, {
                        type: 'folder',
                        common: {
                            name: sn,
                        },
                        native: {},
                    });
                }

                for (const [key, val] of Object.entries(pack)) {
                    if (key !== 'sn') {
                        const statePath = `${path}.${key}`;
                        if (existsState(statePath)) {
                            setState(statePath, { val, ts, ack: true });
                        } else {
                            createState(statePath, val);
                        }
                    }
                }
            }
        }
    } catch (err) {
        console.error(err);
    }
});

[maxclaudi]

@haus-automatisierung

:-) Dankeschön :+1:

Script ist mal gestartet und keine Fehler.
es läuft :-)

nur der Datenpunkt sn mit der Nummer fehlt.
So wie das Verzeichnis nun benannt wird, sollte der Datenpunkt selbst (sn) mit der Nummer auch vorhanden sein.

Schlimm ist das nicht, wenn der Rest funktioniert.

Mal Daten sammeln und abwarten.
Hast mir sehr geholfen und einiges an Zeit erspart.

Vielen, vielen Dank dafür :-)

[haus-automatisierung]

@maxclaudi sagte in Wie json automatisch Datenpunkte in richtige Verzeichnise?:

Einzige was ist, dass mir der Datenpunkt sn mit der Nummer fehlt.

Hatte ich ja explizit übersprungen, weil redundant (in der ID ja bereits enthalten). Aber hier:

const prefix = '0_userdata.0.Datenpunkte.solarflow.HUB';

on({ id: '...', change: 'ne' }, async (obj) => {
    try {
        const newVal = obj.state.val;
        const dataObj = typeof newVal === 'string' ? JSON.parse(newVal) : newVal;

        if (dataObj.packData && Array.isArray(dataObj.packData)) {
            const ts = dataObj.timestamp * 1000;

            for (const pack of dataObj.packData) {
                const sn = pack.sn;
                const path = `${prefix}.${sn}`;

                if (!existsObject(path)) {
                    setObject(path, {
                        type: 'folder',
                        common: {
                            name: sn,
                        },
                        native: {},
                    });
                }

                for (const [key, val] of Object.entries(pack)) {
                    const statePath = `${path}.${key}`;
                    if (existsState(statePath)) {
                        setState(statePath, { val, ts, ack: true });
                    } else {
                        createState(statePath, val);
                    }
                }
            }
        }
    } catch (err) {
        console.error(err);
    }
});

[maxclaudi]

@haus-automatisierung
musste einige gets publishen.

Jetzt wird auch die sn übertragen.

Leider werden jetzt alle anderen states nicht mehr aktualisiert.
Nur packData.

ist ja auch klar,

if (dataObj.packData && Array.isArray(dataObj.packData)

muss dann noch erweitert werden, dass alles andere OHNE packData wie bisher angelegt und aktualisiert wird.

[haus-automatisierung]

@maxclaudi Mach doch mal ein Beispiel wie die Struktur aussehen sollte. Geht es nur um die „properties“? Die scheinen ja unabhängig von der Seriennummer zu sein und müssten dann separat gepflegt werden

[maxclaudi]

@haus-automatisierung

Die Struktur ist enorm.

Sie ändert sich auch immer mal wieder, weil Neues dazu kommt und Einiges selten oder gar nicht mehr aktualisiert wird.

Muss nur noch Deinen großartigen Code mit meinem kombinieren und noch etwas anpassen.

Ein ganz großes und herzliches Dankeschön :-)