Skip to content
  • Home
  • Aktuell
  • Tags
  • 0 Ungelesen 0
  • Kategorien
  • Unreplied
  • Beliebt
  • GitHub
  • Docu
  • Hilfe
Skins
  • Light
  • Brite
  • Cerulean
  • Cosmo
  • Flatly
  • Journal
  • Litera
  • Lumen
  • Lux
  • Materia
  • Minty
  • Morph
  • Pulse
  • Sandstone
  • Simplex
  • Sketchy
  • Spacelab
  • United
  • Yeti
  • Zephyr
  • Dark
  • Cyborg
  • Darkly
  • Quartz
  • Slate
  • Solar
  • Superhero
  • Vapor

  • Standard: (Kein Skin)
  • Kein Skin
Einklappen
ioBroker Logo

Community Forum

donate donate
  1. ioBroker Community Home
  2. Deutsch
  3. Off Topic
  4. Grafana
  5. JSON in Grafana einbinden

NEWS

  • Weihnachtsangebot 2025! 🎄
    BluefoxB
    Bluefox
    7
    1
    53

  • UPDATE 31.10.: Amazon Alexa - ioBroker Skill läuft aus ?
    apollon77A
    apollon77
    48
    3
    8.9k

  • Monatsrückblick – September 2025
    BluefoxB
    Bluefox
    13
    1
    2.3k

JSON in Grafana einbinden

Geplant Angeheftet Gesperrt Verschoben Grafana
39 Beiträge 2 Kommentatoren 3.0k Aufrufe 2 Watching
  • Älteste zuerst
  • Neuste zuerst
  • Meiste Stimmen
Antworten
  • In einem neuen Thema antworten
Anmelden zum Antworten
Dieses Thema wurde gelöscht. Nur Nutzer mit entsprechenden Rechten können es sehen.
  • CodierknechtC Codierknecht

    @stefu87_ch
    Dein JSON sieht ja auch völlig anders aus. Du hast ein Array von Objekten mit jeweils 2 Properties.
    Mein JSON ist ein Objekt mit X Properties.

    Da gibt's in Grafana jede Menge Manipulationsmöglichkeiten über die "Transformations". Da muss man mal kreativ werden und rumspielen :grin:

    Oder Du postest hier mal Dein JSON (in Code-Tags </>).

    S Offline
    S Offline
    stefu87_CH
    schrieb am zuletzt editiert von
    #15

    @codierknecht
    Also habe diesen Code so von einer Internetseite kopiert gehabt vor längere Zeit.

    const idVerbrauch = '0_userdata.0.Wohnungsverbrauch.Tagesverbrauch_kwh'; // ID zuweisen!
    
    const idTable = '0_userdata.0.Wohnungsverbrauch.TagesverbrauchTest'; // ID anpassen!
    
     schedule('59 23 * * *', function() {
    
        var arr = [];
    
        if(getState(idTable).val) arr = JSON.parse(getState(idTable).val);
    
        const obj = {
    
            Datum: formatDate(new Date(), 'W, DD.MM.YYYY'),
    
            Verbrauch: getState(idVerbrauch).val.toFixed(3)
    
        }
    
        arr.push(obj);
    
        if(arr.length > 23) arr.shift(); // max. 23 Zeilen
    
        setState(idTable, JSON.stringify(arr), true);
    
    });
    
    
    

    8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
    Gigabyte mit Proxmox
    LXC Container mit Iobroker

    CodierknechtC 1 Antwort Letzte Antwort
    0
    • S stefu87_CH

      @codierknecht
      Also habe diesen Code so von einer Internetseite kopiert gehabt vor längere Zeit.

      const idVerbrauch = '0_userdata.0.Wohnungsverbrauch.Tagesverbrauch_kwh'; // ID zuweisen!
      
      const idTable = '0_userdata.0.Wohnungsverbrauch.TagesverbrauchTest'; // ID anpassen!
      
       schedule('59 23 * * *', function() {
      
          var arr = [];
      
          if(getState(idTable).val) arr = JSON.parse(getState(idTable).val);
      
          const obj = {
      
              Datum: formatDate(new Date(), 'W, DD.MM.YYYY'),
      
              Verbrauch: getState(idVerbrauch).val.toFixed(3)
      
          }
      
          arr.push(obj);
      
          if(arr.length > 23) arr.shift(); // max. 23 Zeilen
      
          setState(idTable, JSON.stringify(arr), true);
      
      });
      
      
      
      CodierknechtC Offline
      CodierknechtC Offline
      Codierknecht
      Developer Most Active
      schrieb am zuletzt editiert von
      #16

      @stefu87_ch
      Der schreibt Dir jeden Abend einen neuen Eintrag in ein JSON-Array.
      Über die Sinnhaftigkeit von sowas mag man streiten. Dafür gibt's diverse History-Adapter (SQL, Influx, History).

      Das JS umzuschreiben könnte auch schwierig werden, da der Aufbau ja komplett anders aussehen muss und die Werte der Vergangenheit dann erstmal weg sind (es sei denn, man treibt da noch Zusatzaufwand).

      Versuch's mal hiermit. Ist allerdings nur so dahingeschrieben und ungetestet.

      const idVerbrauch = '0_userdata.0.Wohnungsverbrauch.Tagesverbrauch_kwh'; // ID zuweisen!
      const idTable = '0_userdata.0.Wohnungsverbrauch.TagesverbrauchTest'; // ID anpassen!
      const idGrafana = '0_userdata.0.Wohnungsverbrauch.TagesverbrauchGrafana';
       
      schedule('59 23 * * *', function() {
          var arr = [];
      
          if (getState(idTable).val) arr = JSON.parse(getState(idTable).val);
       
          const obj = {
              Datum: formatDate(new Date(), 'W, DD.MM.YYYY'),
              Verbrauch: getState(idVerbrauch).val.toFixed(3)
          }
       
          arr.push(obj);
       
          if(arr.length > 23) arr.shift(); // max. 23 Zeilen
       
          setState(idTable, JSON.stringify(arr), true);
          
          let values = {};
          for (const item of arr) {
            values[item.Datum] = parseFloat(item.Verbrauch);
          }
          setState(idGrafana, JSON.stringify(values), true);
          
      });
      

      "Any fool can write code that a computer can understand. Good programmers write code that humans can understand." (Martin Fowler, "Refactoring")

      Proxmox 9.1.1 LXC|8 GB|Core i7-6700
      HmIP|ZigBee|Tasmota|Unifi
      Zabbix Certified Specialist
      Konnte ich Dir helfen? Dann benutze bitte das Voting unten rechts im Beitrag

      S 1 Antwort Letzte Antwort
      0
      • CodierknechtC Codierknecht

        @stefu87_ch
        Der schreibt Dir jeden Abend einen neuen Eintrag in ein JSON-Array.
        Über die Sinnhaftigkeit von sowas mag man streiten. Dafür gibt's diverse History-Adapter (SQL, Influx, History).

        Das JS umzuschreiben könnte auch schwierig werden, da der Aufbau ja komplett anders aussehen muss und die Werte der Vergangenheit dann erstmal weg sind (es sei denn, man treibt da noch Zusatzaufwand).

        Versuch's mal hiermit. Ist allerdings nur so dahingeschrieben und ungetestet.

        const idVerbrauch = '0_userdata.0.Wohnungsverbrauch.Tagesverbrauch_kwh'; // ID zuweisen!
        const idTable = '0_userdata.0.Wohnungsverbrauch.TagesverbrauchTest'; // ID anpassen!
        const idGrafana = '0_userdata.0.Wohnungsverbrauch.TagesverbrauchGrafana';
         
        schedule('59 23 * * *', function() {
            var arr = [];
        
            if (getState(idTable).val) arr = JSON.parse(getState(idTable).val);
         
            const obj = {
                Datum: formatDate(new Date(), 'W, DD.MM.YYYY'),
                Verbrauch: getState(idVerbrauch).val.toFixed(3)
            }
         
            arr.push(obj);
         
            if(arr.length > 23) arr.shift(); // max. 23 Zeilen
         
            setState(idTable, JSON.stringify(arr), true);
            
            let values = {};
            for (const item of arr) {
              values[item.Datum] = parseFloat(item.Verbrauch);
            }
            setState(idGrafana, JSON.stringify(values), true);
            
        });
        
        S Offline
        S Offline
        stefu87_CH
        schrieb am zuletzt editiert von
        #17

        @codierknecht sagte in JSON in Grafana einbinden:

        '0_userdata.0.Wohnungsverbrauch.TagesverbrauchGrafana

        Muss ich diesen noch selber anlegen, oder passiert das dann automatisch?

        8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
        Gigabyte mit Proxmox
        LXC Container mit Iobroker

        CodierknechtC 1 Antwort Letzte Antwort
        0
        • S stefu87_CH

          @codierknecht sagte in JSON in Grafana einbinden:

          '0_userdata.0.Wohnungsverbrauch.TagesverbrauchGrafana

          Muss ich diesen noch selber anlegen, oder passiert das dann automatisch?

          CodierknechtC Offline
          CodierknechtC Offline
          Codierknecht
          Developer Most Active
          schrieb am zuletzt editiert von
          #18

          @stefu87_ch sagte in JSON in Grafana einbinden:

          Muss ich diesen noch selber anlegen, oder passiert das dann automatisch?

          Den musst Du selbst anlegen. Typ "Text/String".

          "Any fool can write code that a computer can understand. Good programmers write code that humans can understand." (Martin Fowler, "Refactoring")

          Proxmox 9.1.1 LXC|8 GB|Core i7-6700
          HmIP|ZigBee|Tasmota|Unifi
          Zabbix Certified Specialist
          Konnte ich Dir helfen? Dann benutze bitte das Voting unten rechts im Beitrag

          S 1 Antwort Letzte Antwort
          0
          • CodierknechtC Codierknecht

            @stefu87_ch sagte in JSON in Grafana einbinden:

            Muss ich diesen noch selber anlegen, oder passiert das dann automatisch?

            Den musst Du selbst anlegen. Typ "Text/String".

            S Offline
            S Offline
            stefu87_CH
            schrieb am zuletzt editiert von
            #19

            @codierknecht Ok werde es mal testen und schauen ob heute Nacht etwas passiert.

            Wie würdest du den das umsetzen ohne die JSON Tabelle, sondern eben mit z.B. Influx das er immer um 23:59 den Wert speichert samt Datum?

            8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
            Gigabyte mit Proxmox
            LXC Container mit Iobroker

            CodierknechtC 1 Antwort Letzte Antwort
            0
            • S stefu87_CH

              @codierknecht Ok werde es mal testen und schauen ob heute Nacht etwas passiert.

              Wie würdest du den das umsetzen ohne die JSON Tabelle, sondern eben mit z.B. Influx das er immer um 23:59 den Wert speichert samt Datum?

              CodierknechtC Offline
              CodierknechtC Offline
              Codierknecht
              Developer Most Active
              schrieb am zuletzt editiert von
              #20

              @stefu87_ch sagte in JSON in Grafana einbinden:

              Wie würdest du den das umsetzen ohne die JSON Tabelle, sondern eben mit z.B. Influx das er immer um 23:59 den Wert speichert samt Datum?

              Ich habe dafür einen eigenen DP für den Tagesverbrauch. Der wird per SQL historisiert.
              In den DP wird per Script um 23:59:45 Uhr der Wert reingeschrieben. So habe ich die Werte mit passendem Datum in der DB. Damit lassen sich dann ohne viel Aufwand auch Monats- oder Jahresverbräuche bestimmen.

              "Any fool can write code that a computer can understand. Good programmers write code that humans can understand." (Martin Fowler, "Refactoring")

              Proxmox 9.1.1 LXC|8 GB|Core i7-6700
              HmIP|ZigBee|Tasmota|Unifi
              Zabbix Certified Specialist
              Konnte ich Dir helfen? Dann benutze bitte das Voting unten rechts im Beitrag

              S 1 Antwort Letzte Antwort
              0
              • CodierknechtC Codierknecht

                @stefu87_ch sagte in JSON in Grafana einbinden:

                Wie würdest du den das umsetzen ohne die JSON Tabelle, sondern eben mit z.B. Influx das er immer um 23:59 den Wert speichert samt Datum?

                Ich habe dafür einen eigenen DP für den Tagesverbrauch. Der wird per SQL historisiert.
                In den DP wird per Script um 23:59:45 Uhr der Wert reingeschrieben. So habe ich die Werte mit passendem Datum in der DB. Damit lassen sich dann ohne viel Aufwand auch Monats- oder Jahresverbräuche bestimmen.

                S Offline
                S Offline
                stefu87_CH
                schrieb am zuletzt editiert von
                #21

                @codierknecht
                Also für den Tagesverbauch habe ich auch einen Datenpunkt der alle 15min aktualisiert wird. Und um 23:59 schreibt eben der gezeigte Code dann dies in die JSON Tabelle.

                Könnte ich den mit dem bestehen Datenpunkt sowas weiter verarbeiten so wie du das machst?

                8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                Gigabyte mit Proxmox
                LXC Container mit Iobroker

                CodierknechtC 1 Antwort Letzte Antwort
                0
                • S stefu87_CH

                  @codierknecht
                  Also für den Tagesverbauch habe ich auch einen Datenpunkt der alle 15min aktualisiert wird. Und um 23:59 schreibt eben der gezeigte Code dann dies in die JSON Tabelle.

                  Könnte ich den mit dem bestehen Datenpunkt sowas weiter verarbeiten so wie du das machst?

                  CodierknechtC Offline
                  CodierknechtC Offline
                  Codierknecht
                  Developer Most Active
                  schrieb am zuletzt editiert von
                  #22

                  @stefu87_ch sagte in JSON in Grafana einbinden:

                  Könnte ich den mit dem bestehen Datenpunkt sowas weiter verarbeiten so wie du das machst?

                  Eben nicht, weil der ja alle 15 Minuten aktualisier wird.
                  Lege Dir einen neuen an (Typ: Zahl) und historisiere den. Da schreibst Du einfach um 23:59 Uhr den aktuellen Wert aus dem über Tag hochgezählten DP rein.

                  "Any fool can write code that a computer can understand. Good programmers write code that humans can understand." (Martin Fowler, "Refactoring")

                  Proxmox 9.1.1 LXC|8 GB|Core i7-6700
                  HmIP|ZigBee|Tasmota|Unifi
                  Zabbix Certified Specialist
                  Konnte ich Dir helfen? Dann benutze bitte das Voting unten rechts im Beitrag

                  S 2 Antworten Letzte Antwort
                  0
                  • CodierknechtC Codierknecht

                    @stefu87_ch sagte in JSON in Grafana einbinden:

                    Könnte ich den mit dem bestehen Datenpunkt sowas weiter verarbeiten so wie du das machst?

                    Eben nicht, weil der ja alle 15 Minuten aktualisier wird.
                    Lege Dir einen neuen an (Typ: Zahl) und historisiere den. Da schreibst Du einfach um 23:59 Uhr den aktuellen Wert aus dem über Tag hochgezählten DP rein.

                    S Offline
                    S Offline
                    stefu87_CH
                    schrieb am zuletzt editiert von
                    #23

                    @codierknecht Also müsste ich diesen Code hier ganz am Schluss anpassen statt alle 15min das es 23:59 ist?

                    *
                     * @copyright 2021 Stephan Kreyenborg <stephan@kreyenborg.koeln>
                     *
                     * @author 2021 Stephan Kreyenborg <stephan@kreyenborg.koeln>
                     *
                     * Dieses Skript dient zur freien Verwendung in ioBroker zur Verbrauchserfassung der Shelly Geräte.
                     * Jegliche Verantwortung liegt beim Benutzer. Das Skript wurde unter Berücksichtigung der bestmöglichen Nutzung
                     * und Performance entwickelt.
                     * Der Entwickler versichert, das keine böswilligen Systemeingriffe im originalen Skript vorhanden sind.
                     *
                     * Sollte das Skript wider Erwarten nicht korrekt funktionieren, so hast Du jederzeit die Möglichkeit, Dich auf
                     * https://www.kreyenborg.koeln
                     * für Unterstützung zu melden. Jedes Skript besitzt seine eigene Kommentarseite, auf der,
                     * nach zeitlicher Möglichkeit des Autors, Hilfe angeboten wird. Ein Anrecht hierauf besteht nicht!
                     * 
                     * Ansprüche gegenüber Dritten bestehen nicht. 
                     * 
                     * Skript Name:      Shelly-Verbrauch
                     * Skript Version:   1.60
                     * Erstell-Datum:    08. Oktober 2021 | Update: 20. Juli 2022
                     * 
                     */
                    // Datenpunkte neu erstellen
                    var ueberschreiben = false;
                    // Hauptdatenpunkt unterhalb javascript
                    var datenpunkt = "ShellyVerbrauch."; // Abschließender Punkt !!! WICHTIG !!!
                    // Verbrauchs Objekte der einzelnen Shelly
                    var objekt = ["gesamt", "dieses_jahr", "letztes_jahr", "letzter_monat", "dieser_monat", "letzte_woche",
                        "diese_woche", "gestern", "heute", "alter_wert", "aktueller_wert"
                    ];
                    // Beschreibung der Objekte
                    var beschreibung = ["Gesamter Vebrauch des Shelly", "Verbrauch aktuelles Jahr", "Verbrauch letztes Jahr",
                        "Verbrauch letzten Monat", "Verbrauch aktueller Monat", "Verbrauch letzte Woche", "Verbrauch diese Woche",
                        "Verbrauch gestern", "Verbrauch heute", "Messwert alt", "Messwert neu"
                    ];
                    // Datenpunkt der Shelly (Standard: shelly.0)
                    var shelly_dp = "shelly.1";
                    // Datenpunkte der Shelly (!!! Bitte nicht ändern !!!)
                    var shellyDps = $('state[id=' + shelly_dp + '.*.*.Energy]');
                    // Datenpunkte der Shelly 3EM DP
                    var shelly3EMDps = $('state[id=' + shelly_dp + '.*.*.TotalActiveEnergy]');
                    // Datenpunkte der Shelly 3EM DP - Total
                    var shelly3EMTotalDps = $('state[id=' + shelly_dp + '.*.*.ConsumedPower]');
                    // Datenpunkte der Shelly 3EM DP - Total
                    var shelly3EMTotalReturned = $('state[id=' + shelly_dp + '.*.*.Total_Returned]');
                    // Datenpunkte der Shelly Namen (!!! Bitte nicht ändern !!!)
                    var shellyDpsName = $('state[id=' + shelly_dp + '.*.name]');
                    // Shelly Verbrauch aktualisieren - nachts um 00:00 Uhr
                    function shelly_vebrauch_tag() {
                        // Nochmals das Tagesupdate durchlaufen, damit die restlichen Werte gelesen werden
                        shelly_verbrauch_update();
                        // Datumsvariable
                        var heute = new Date();
                        // Heute zu Gestern verschieben. Täglich um 00:00 Uhr
                        verschiebe_verbrauch_objekt("heute", "gestern");
                        log("Shelly Verbrauch: Werte für gestern und heute aktualisiert!");
                        // aktuelle Woche in letzte Woche verschieben. Am Montag um 00:00 Uhr
                        if (heute.getDay() === 1) {
                            verschiebe_verbrauch_objekt("diese_woche", "letzte_woche");
                            log("Shelly Verbrauch: Werte für diese und letzte Woche aktualisiert!");
                        }
                        // aktueller Monat in letzten Monat verschieben. Am 1. des Monats um 00:00 Uhr
                        if (heute.getDate() === 1) {
                            verschiebe_verbrauch_objekt("dieser_monat", "letzter_monat");
                            log("Shelly Verbrauch: Werte für diesen und letzten Monat aktualisiert!");
                        }
                        // aktuelles Jahr in letztes Jahr verschieben. Am 1. des Monats am 1. Monat um 00:00 Uhr
                        if (heute.getDate() === 1 && heute.getMonth() === 0) {
                            verschiebe_verbrauch_objekt("dieses_jahr", "letztes_jahr");
                            log("Shelly Verbrauch: Werte für dieses und letztes Jahr aktualisiert!");
                        }
                    }
                    // Tagesverbrauch alle 15 Min von der Original Variable des Shelly in eigene Variable kopieren
                    function shelly_verbrauch_update() {
                        var anzahl_updates = 0;
                        var anzahl_reboots = 0;
                        var anzahl_gleich = 0;
                        shellyDps.each(function (id, i) {
                            var shelly_verbrauch = getState(id).val;
                            // Einige Shelly haben keine Verbrauchswerte (noch nicht)
                            if (shelly_verbrauch != null) {
                                // Hole aktuellen Wert, um zu kontrollieren, ob ein Reboot stattgefunden hat
                                var aktueller_wert = getState(shelly_DP(id) + "aktueller_wert").val;
                                var alter_wert = 0;
                                // Prüfe alten und neuen Wert
                                if (shelly_verbrauch > aktueller_wert) {
                                    // Verbrauchswert ist größer als alter Wert -> es wurde kein Reboot durchgeführt
                                    setState(shelly_DP(id) + "alter_wert", aktueller_wert, true);
                                    alter_wert = aktueller_wert;
                                    anzahl_updates++;
                                }
                                if (aktueller_wert > shelly_verbrauch) {
                                    // Verbrauchswert ist kleiner als alter Wert -> es wurde ein Reboot durchgeführt
                                    setState(shelly_DP(id) + "alter_wert", 0, true);
                                    alter_wert = 0;
                                    anzahl_reboots++;
                                }
                                if (shelly_verbrauch == aktueller_wert) {
                                    // Verbrauchswert ist gleich wie alter Wert -> kein Update notwendig
                                    alter_wert = aktueller_wert;
                                    anzahl_gleich++;
                                }
                                setState(shelly_DP(id) + "aktueller_wert", shelly_verbrauch, true);
                                // Alter und neuer Wert -> aktuelle Differenz
                                var verbrauch = parseFloat(shelly_verbrauch) - alter_wert;
                                // Tagesverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "heute", verbrauch);
                                // Wochenverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "diese_woche", verbrauch);
                                // Monatsverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "dieser_monat", verbrauch);
                                // Jahresverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "dieses_jahr", verbrauch);
                                // Gesamten Vebrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "gesamt", verbrauch);
                            }
                        });
                        shelly3EMDps.each(function (id, i) {
                            var shelly_verbrauch = getState(id).val;
                            // Einige Shelly haben keine Verbrauchswerte (noch nicht)
                            if (shelly_verbrauch != null) {
                                // Hole aktuellen Wert, um zu kontrollieren, ob ein Reboot stattgefunden hat
                                var aktueller_wert = getState(shelly_DP(id) + "aktueller_wert").val;
                                var alter_wert = 0;
                                // Prüfe alten und neuen Wert
                                if (shelly_verbrauch > aktueller_wert) {
                                    // Verbrauchswert ist größer als alter Wert -> es wurde kein Reboot durchgeführt
                                    setState(shelly_DP(id) + "alter_wert", aktueller_wert, true);
                                    alter_wert = aktueller_wert;
                                    anzahl_updates++;
                                }
                                if (aktueller_wert > shelly_verbrauch) {
                                    // Verbrauchswert ist kleiner als alter Wert -> es wurde ein Reboot durchgeführt
                                    setState(shelly_DP(id) + "alter_wert", 0, true);
                                    alter_wert = 0;
                                    anzahl_reboots++;
                                }
                                if (shelly_verbrauch == aktueller_wert) {
                                    // Verbrauchswert ist gleich wie alter Wert -> kein Update notwendig
                                    alter_wert = aktueller_wert;
                                    anzahl_gleich++;
                                }
                                setState(shelly_DP(id) + "aktueller_wert", shelly_verbrauch, true);
                                // Alter und neuer Wert -> aktuelle Differenz
                                var verbrauch = parseFloat(shelly_verbrauch) - alter_wert;
                                // Tagesverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "heute", verbrauch);
                                // Wochenverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "diese_woche", verbrauch);
                                // Monatsverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "dieser_monat", verbrauch);
                                // Jahresverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "dieses_jahr", verbrauch);
                                // Gesamten Vebrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "gesamt", verbrauch);
                            }
                        });
                        shelly3EMTotalDps.each(function (id, i) {
                            var shelly_verbrauch = getState(id).val;
                            // Einige Shelly haben keine Verbrauchswerte (noch nicht)
                            if (shelly_verbrauch != null) {
                                // Hole aktuellen Wert, um zu kontrollieren, ob ein Reboot stattgefunden hat
                                var aktueller_wert = getState(shelly_DP(id) + "aktueller_wert").val;
                                var alter_wert = 0;
                                // Prüfe alten und neuen Wert
                                if (shelly_verbrauch > aktueller_wert) {
                                    // Verbrauchswert ist größer als alter Wert -> es wurde kein Reboot durchgeführt
                                    setState(shelly_DP(id) + "alter_wert", aktueller_wert, true);
                                    alter_wert = aktueller_wert;
                                    anzahl_updates++;
                                }
                                if (aktueller_wert > shelly_verbrauch) {
                                    // Verbrauchswert ist kleiner als alter Wert -> es wurde ein Reboot durchgeführt
                                    setState(shelly_DP(id) + "alter_wert", 0, true);
                                    alter_wert = 0;
                                    anzahl_reboots++;
                                }
                                if (shelly_verbrauch == aktueller_wert) {
                                    // Verbrauchswert ist gleich wie alter Wert -> kein Update notwendig
                                    alter_wert = aktueller_wert;
                                    anzahl_gleich++;
                                }
                                setState(shelly_DP(id) + "aktueller_wert", shelly_verbrauch, true);
                                // Alter und neuer Wert -> aktuelle Differenz
                                var verbrauch = parseFloat(shelly_verbrauch) - alter_wert;
                                // Tagesverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "heute", verbrauch);
                                // Wochenverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "diese_woche", verbrauch);
                                // Monatsverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "dieser_monat", verbrauch);
                                // Jahresverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "dieses_jahr", verbrauch);
                                // Gesamten Vebrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id), "gesamt", verbrauch);
                            }
                        });
                        shelly3EMTotalReturned.each(function (id, i) {
                            var shelly_verbrauch = getState(id).val;
                            // Einige Shelly haben keine Verbrauchswerte (noch nicht)
                            if (shelly_verbrauch != null) {
                                // Hole aktuellen Wert, um zu kontrollieren, ob ein Reboot stattgefunden hat
                                var aktueller_wert = getState(shelly_DP(id, true) + "aktueller_wert").val;
                                var alter_wert = 0;
                                // Prüfe alten und neuen Wert
                                if (shelly_verbrauch > aktueller_wert) {
                                    // Verbrauchswert ist größer als alter Wert -> es wurde kein Reboot durchgeführt
                                    setState(shelly_DP(id, true) + "alter_wert", aktueller_wert, true);
                                    alter_wert = aktueller_wert;
                                    anzahl_updates++;
                                }
                                if (aktueller_wert > shelly_verbrauch) {
                                    // Verbrauchswert ist kleiner als alter Wert -> es wurde ein Reboot durchgeführt
                                    setState(shelly_DP(id, true) + "alter_wert", 0, true);
                                    alter_wert = 0;
                                    anzahl_reboots++;
                                }
                                if (shelly_verbrauch == aktueller_wert) {
                                    // Verbrauchswert ist gleich wie alter Wert -> kein Update notwendig
                                    alter_wert = aktueller_wert;
                                    anzahl_gleich++;
                                }
                                setState(shelly_DP(id, true) + "aktueller_wert", shelly_verbrauch, true);
                                // Alter und neuer Wert -> aktuelle Differenz
                                var verbrauch = parseFloat(shelly_verbrauch) - alter_wert;
                                // Tagesverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id, true), "heute", verbrauch);
                                // Wochenverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id, true), "diese_woche", verbrauch);
                                // Monatsverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id, true), "dieser_monat", verbrauch);
                                // Jahresverbrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id, true), "dieses_jahr", verbrauch);
                                // Gesamten Vebrauch aktualisieren
                                aktualisiere_vebrauch_objekt(shelly_DP(id, true), "gesamt", verbrauch);
                            }
                        });
                        aktualisiere_namen();
                        log("Shelly Verbrauch: Verbrauchswerte aktualisiert: " + anzahl_updates + " | Reboots korrigiert: " + anzahl_reboots + " | Unveränderte Werte: " + anzahl_gleich);
                    }
                    // aktualisiert das jeweilige Verbrauchs-Objekt und addiert den Verbrauch dazu
                    function aktualisiere_vebrauch_objekt(dp, objekt, wert) {
                        // Hole alten Verbrauch
                        let alter_verbrauch = getState(dp + objekt).val;
                        let verbrauch = 0;
                        // Kein Wert vorhanden - nutze den übermittelten Wert
                        if (alter_verbrauch < 1 || alter_verbrauch == null) {
                            verbrauch = parseFloat(wert)
                        } else {
                            verbrauch = parseFloat(alter_verbrauch) + parseFloat(wert);
                        }
                        setState(dp + objekt, parseFloat(verbrauch.toFixed(2)), true);
                    }
                    // Verschiebt das jeweilige Verbrauchs-Objekt und nullt den Ursprung (Tag, Woche, Monat, Jahr)
                    function verschiebe_verbrauch_objekt(von, nach) {
                        $('state[id=*.' + datenpunkt + '*.*.' + von + ']').each(function (id, i) {
                            // Temporärer Gruppen-Datenpunkt
                            var tmp_dp = id.slice(0, -(von.length));
                            var verbrauch = getState(id).val;
                            if (verbrauch != null) {
                                setState(tmp_dp + nach, verbrauch, true);
                            }
                            // Setze "von" zurück
                            setState(id, 0, true);
                        });
                    }
                    // Funktion um die aktuellen Namen des Shelly abzuholen
                    function aktualisiere_namen() {
                        if (typeof extendObject === "function") {
                            shellyDpsName.each(function (id, i) {
                                if (existsState(id)) {
                                    setState(shelly_DP_Name(id), String(getState(id).val), true);
                                    extendObject("javascript.0." + shelly_DP_Name_Main(id), {
                                        common: {
                                            name: String(getState(id).val),
                                            desc: String(getState(id).val)
                                        },
                                        type: "channel"
                                    });
                                }
                            });
                        }
                    }
                    // Erstelle die benötigten Datenpunkte
                    function datenpunkte_erstellen() {
                        // Anzahl der gefundenen Shelly
                        var anzahl = shellyDps.length;
                        shellyDps.each(function (id, j) {
                            var initial_wert = 0.0;
                            for (var i = 0; i < objekt.length; i++) {
                                // Startwerte werden nur bei alter_wert und aktueller_wert eingetragen
                                if (i > 8) {
                                    initial_wert = getState(id).val;
                                }
                                createState(shelly_DP(id) + objekt[i], initial_wert, ueberschreiben, {
                                    name: beschreibung[i],
                                    desc: beschreibung[i],
                                    type: "number",
                                    role: "value.power",
                                    unit: "Wh"
                                });
                            }
                        });
                        // Anzahl der gefundenen Shelly 3EM
                        var anzahl_3em = shelly3EMDps.length;
                        shelly3EMDps.each(function (id, j) {
                            var initial_wert = 0.0;
                            for (var i = 0; i < objekt.length; i++) {
                                // Startwerte werden nur bei alter_wert und aktueller_wert eingetragen
                                if (i > 8) {
                                    initial_wert = getState(id).val;
                                }
                                createState(shelly_DP(id) + objekt[i], initial_wert, ueberschreiben, {
                                    name: beschreibung[i],
                                    desc: beschreibung[i],
                                    type: "number",
                                    role: "value.power",
                                    unit: "Wh"
                                });
                            }
                        });
                        // Anzahl der gefundenen Shelly 3EM - Total
                        var anzahl_3em_total = shelly3EMTotalDps.length;
                        shelly3EMTotalDps.each(function (id, j) {
                            var initial_wert = 0.0;
                            for (var i = 0; i < objekt.length; i++) {
                                // Startwerte werden nur bei alter_wert und aktueller_wert eingetragen
                                if (i > 8) {
                                    initial_wert = getState(id).val;
                                }
                                createState(shelly_DP(id) + objekt[i], initial_wert, ueberschreiben, {
                                    name: beschreibung[i],
                                    desc: beschreibung[i],
                                    type: "number",
                                    role: "value.power",
                                    unit: "Wh"
                                });
                            }
                        });
                        // Anzahl der gefundenen Shelly 3EM - Total
                        var anzahl_3em_total_returned = shelly3EMTotalReturned.length;
                        shelly3EMTotalReturned.each(function (id, j) {
                            var initial_wert = 0.0;
                            for (var i = 0; i < objekt.length; i++) {
                                // Startwerte werden nur bei alter_wert und aktueller_wert eingetragen
                                if (i > 8) {
                                    initial_wert = getState(id).val;
                                }
                                createState(shelly_DP(id, true) + objekt[i], initial_wert, ueberschreiben, {
                                    name: beschreibung[i],
                                    desc: beschreibung[i],
                                    type: "number",
                                    role: "value.power",
                                    unit: "Wh"
                                });
                            }
                        });
                        // Alle Datenpunkte erstellt. Frage ersten Verbrauch ab!
                        log("Shelly Verbrauch: Datenpunkte erstellt! Erster Verbrauch steht nach 30 Sekunden zur Verfügung! Anzahl gefundener Shelly Datenpunkte: " + (anzahl_3em + anzahl + anzahl_3em_total + anzahl_3em_total_returned));
                        setTimeout(shelly_verbrauch_update, 30000);
                        // Datenpunkte für die Namen der Shelly erstellen
                        shellyDpsName.each(function (id, j) {
                            createState(shelly_DP_Name(id), "", ueberschreiben, {
                                name: "Name des Shelly",
                                desc: "Name des Shelly",
                                type: "string",
                                role: "value",
                                unit: ""
                            });
                        });
                    }
                    /**
                     * Wenn 3EM DP, dann anderen Wert zurückgeben
                     * @param {any} dp
                     * @param {boolean} extended
                     */
                    function shelly_DP(dp, extended = false) {
                        dp = dp.split(".");
                        dp = datenpunkt + dp[2] + "." + dp[3];
                        if (extended) {
                            dp = dp + "_Returned.";
                        } else {
                            dp = dp + ".";
                        }
                        return dp;
                    }
                    function shelly_DP_Name(dp) {
                        dp = dp.split(".");
                        dp = datenpunkt + dp[2] + "." + dp[3];
                        return dp;
                    }
                    function shelly_DP_Name_Main(dp) {
                        dp = dp.split(".");
                        dp = datenpunkt + dp[2];
                        return dp;
                    }
                    function shelly_verbrauch_erster_start() {
                        log("Shelly Verbrauch: Erster Start des Skriptes! Datenpunkte werden erstellt!");
                        // Datenpunkte werden erstellt
                        datenpunkte_erstellen();
                    }
                    // Erster Start und Initialisierung
                    shelly_verbrauch_erster_start();
                    // Alle 15 Minuten das Skript für den Tagesverbrauch ausführen
                    schedule('*/15 * * * *', shelly_verbrauch_update);
                    // Nachts um 24 Uhr werden die Werte in andere Variablen gespeichert, um den Verlauf zu erstellen
                    schedule('0 0 * * *', shelly_vebrauch_tag);
                    

                    8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                    Gigabyte mit Proxmox
                    LXC Container mit Iobroker

                    CodierknechtC 1 Antwort Letzte Antwort
                    0
                    • CodierknechtC Codierknecht

                      @stefu87_ch sagte in JSON in Grafana einbinden:

                      Könnte ich den mit dem bestehen Datenpunkt sowas weiter verarbeiten so wie du das machst?

                      Eben nicht, weil der ja alle 15 Minuten aktualisier wird.
                      Lege Dir einen neuen an (Typ: Zahl) und historisiere den. Da schreibst Du einfach um 23:59 Uhr den aktuellen Wert aus dem über Tag hochgezählten DP rein.

                      S Offline
                      S Offline
                      stefu87_CH
                      schrieb am zuletzt editiert von
                      #24

                      @codierknecht Versuche es mal auf eine einfache Weise, das ich den Wert per CRON in den DP schreibe.

                      8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                      Gigabyte mit Proxmox
                      LXC Container mit Iobroker

                      1 Antwort Letzte Antwort
                      0
                      • S stefu87_CH

                        @codierknecht Also müsste ich diesen Code hier ganz am Schluss anpassen statt alle 15min das es 23:59 ist?

                        *
                         * @copyright 2021 Stephan Kreyenborg <stephan@kreyenborg.koeln>
                         *
                         * @author 2021 Stephan Kreyenborg <stephan@kreyenborg.koeln>
                         *
                         * Dieses Skript dient zur freien Verwendung in ioBroker zur Verbrauchserfassung der Shelly Geräte.
                         * Jegliche Verantwortung liegt beim Benutzer. Das Skript wurde unter Berücksichtigung der bestmöglichen Nutzung
                         * und Performance entwickelt.
                         * Der Entwickler versichert, das keine böswilligen Systemeingriffe im originalen Skript vorhanden sind.
                         *
                         * Sollte das Skript wider Erwarten nicht korrekt funktionieren, so hast Du jederzeit die Möglichkeit, Dich auf
                         * https://www.kreyenborg.koeln
                         * für Unterstützung zu melden. Jedes Skript besitzt seine eigene Kommentarseite, auf der,
                         * nach zeitlicher Möglichkeit des Autors, Hilfe angeboten wird. Ein Anrecht hierauf besteht nicht!
                         * 
                         * Ansprüche gegenüber Dritten bestehen nicht. 
                         * 
                         * Skript Name:      Shelly-Verbrauch
                         * Skript Version:   1.60
                         * Erstell-Datum:    08. Oktober 2021 | Update: 20. Juli 2022
                         * 
                         */
                        // Datenpunkte neu erstellen
                        var ueberschreiben = false;
                        // Hauptdatenpunkt unterhalb javascript
                        var datenpunkt = "ShellyVerbrauch."; // Abschließender Punkt !!! WICHTIG !!!
                        // Verbrauchs Objekte der einzelnen Shelly
                        var objekt = ["gesamt", "dieses_jahr", "letztes_jahr", "letzter_monat", "dieser_monat", "letzte_woche",
                            "diese_woche", "gestern", "heute", "alter_wert", "aktueller_wert"
                        ];
                        // Beschreibung der Objekte
                        var beschreibung = ["Gesamter Vebrauch des Shelly", "Verbrauch aktuelles Jahr", "Verbrauch letztes Jahr",
                            "Verbrauch letzten Monat", "Verbrauch aktueller Monat", "Verbrauch letzte Woche", "Verbrauch diese Woche",
                            "Verbrauch gestern", "Verbrauch heute", "Messwert alt", "Messwert neu"
                        ];
                        // Datenpunkt der Shelly (Standard: shelly.0)
                        var shelly_dp = "shelly.1";
                        // Datenpunkte der Shelly (!!! Bitte nicht ändern !!!)
                        var shellyDps = $('state[id=' + shelly_dp + '.*.*.Energy]');
                        // Datenpunkte der Shelly 3EM DP
                        var shelly3EMDps = $('state[id=' + shelly_dp + '.*.*.TotalActiveEnergy]');
                        // Datenpunkte der Shelly 3EM DP - Total
                        var shelly3EMTotalDps = $('state[id=' + shelly_dp + '.*.*.ConsumedPower]');
                        // Datenpunkte der Shelly 3EM DP - Total
                        var shelly3EMTotalReturned = $('state[id=' + shelly_dp + '.*.*.Total_Returned]');
                        // Datenpunkte der Shelly Namen (!!! Bitte nicht ändern !!!)
                        var shellyDpsName = $('state[id=' + shelly_dp + '.*.name]');
                        // Shelly Verbrauch aktualisieren - nachts um 00:00 Uhr
                        function shelly_vebrauch_tag() {
                            // Nochmals das Tagesupdate durchlaufen, damit die restlichen Werte gelesen werden
                            shelly_verbrauch_update();
                            // Datumsvariable
                            var heute = new Date();
                            // Heute zu Gestern verschieben. Täglich um 00:00 Uhr
                            verschiebe_verbrauch_objekt("heute", "gestern");
                            log("Shelly Verbrauch: Werte für gestern und heute aktualisiert!");
                            // aktuelle Woche in letzte Woche verschieben. Am Montag um 00:00 Uhr
                            if (heute.getDay() === 1) {
                                verschiebe_verbrauch_objekt("diese_woche", "letzte_woche");
                                log("Shelly Verbrauch: Werte für diese und letzte Woche aktualisiert!");
                            }
                            // aktueller Monat in letzten Monat verschieben. Am 1. des Monats um 00:00 Uhr
                            if (heute.getDate() === 1) {
                                verschiebe_verbrauch_objekt("dieser_monat", "letzter_monat");
                                log("Shelly Verbrauch: Werte für diesen und letzten Monat aktualisiert!");
                            }
                            // aktuelles Jahr in letztes Jahr verschieben. Am 1. des Monats am 1. Monat um 00:00 Uhr
                            if (heute.getDate() === 1 && heute.getMonth() === 0) {
                                verschiebe_verbrauch_objekt("dieses_jahr", "letztes_jahr");
                                log("Shelly Verbrauch: Werte für dieses und letztes Jahr aktualisiert!");
                            }
                        }
                        // Tagesverbrauch alle 15 Min von der Original Variable des Shelly in eigene Variable kopieren
                        function shelly_verbrauch_update() {
                            var anzahl_updates = 0;
                            var anzahl_reboots = 0;
                            var anzahl_gleich = 0;
                            shellyDps.each(function (id, i) {
                                var shelly_verbrauch = getState(id).val;
                                // Einige Shelly haben keine Verbrauchswerte (noch nicht)
                                if (shelly_verbrauch != null) {
                                    // Hole aktuellen Wert, um zu kontrollieren, ob ein Reboot stattgefunden hat
                                    var aktueller_wert = getState(shelly_DP(id) + "aktueller_wert").val;
                                    var alter_wert = 0;
                                    // Prüfe alten und neuen Wert
                                    if (shelly_verbrauch > aktueller_wert) {
                                        // Verbrauchswert ist größer als alter Wert -> es wurde kein Reboot durchgeführt
                                        setState(shelly_DP(id) + "alter_wert", aktueller_wert, true);
                                        alter_wert = aktueller_wert;
                                        anzahl_updates++;
                                    }
                                    if (aktueller_wert > shelly_verbrauch) {
                                        // Verbrauchswert ist kleiner als alter Wert -> es wurde ein Reboot durchgeführt
                                        setState(shelly_DP(id) + "alter_wert", 0, true);
                                        alter_wert = 0;
                                        anzahl_reboots++;
                                    }
                                    if (shelly_verbrauch == aktueller_wert) {
                                        // Verbrauchswert ist gleich wie alter Wert -> kein Update notwendig
                                        alter_wert = aktueller_wert;
                                        anzahl_gleich++;
                                    }
                                    setState(shelly_DP(id) + "aktueller_wert", shelly_verbrauch, true);
                                    // Alter und neuer Wert -> aktuelle Differenz
                                    var verbrauch = parseFloat(shelly_verbrauch) - alter_wert;
                                    // Tagesverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "heute", verbrauch);
                                    // Wochenverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "diese_woche", verbrauch);
                                    // Monatsverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "dieser_monat", verbrauch);
                                    // Jahresverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "dieses_jahr", verbrauch);
                                    // Gesamten Vebrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "gesamt", verbrauch);
                                }
                            });
                            shelly3EMDps.each(function (id, i) {
                                var shelly_verbrauch = getState(id).val;
                                // Einige Shelly haben keine Verbrauchswerte (noch nicht)
                                if (shelly_verbrauch != null) {
                                    // Hole aktuellen Wert, um zu kontrollieren, ob ein Reboot stattgefunden hat
                                    var aktueller_wert = getState(shelly_DP(id) + "aktueller_wert").val;
                                    var alter_wert = 0;
                                    // Prüfe alten und neuen Wert
                                    if (shelly_verbrauch > aktueller_wert) {
                                        // Verbrauchswert ist größer als alter Wert -> es wurde kein Reboot durchgeführt
                                        setState(shelly_DP(id) + "alter_wert", aktueller_wert, true);
                                        alter_wert = aktueller_wert;
                                        anzahl_updates++;
                                    }
                                    if (aktueller_wert > shelly_verbrauch) {
                                        // Verbrauchswert ist kleiner als alter Wert -> es wurde ein Reboot durchgeführt
                                        setState(shelly_DP(id) + "alter_wert", 0, true);
                                        alter_wert = 0;
                                        anzahl_reboots++;
                                    }
                                    if (shelly_verbrauch == aktueller_wert) {
                                        // Verbrauchswert ist gleich wie alter Wert -> kein Update notwendig
                                        alter_wert = aktueller_wert;
                                        anzahl_gleich++;
                                    }
                                    setState(shelly_DP(id) + "aktueller_wert", shelly_verbrauch, true);
                                    // Alter und neuer Wert -> aktuelle Differenz
                                    var verbrauch = parseFloat(shelly_verbrauch) - alter_wert;
                                    // Tagesverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "heute", verbrauch);
                                    // Wochenverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "diese_woche", verbrauch);
                                    // Monatsverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "dieser_monat", verbrauch);
                                    // Jahresverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "dieses_jahr", verbrauch);
                                    // Gesamten Vebrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "gesamt", verbrauch);
                                }
                            });
                            shelly3EMTotalDps.each(function (id, i) {
                                var shelly_verbrauch = getState(id).val;
                                // Einige Shelly haben keine Verbrauchswerte (noch nicht)
                                if (shelly_verbrauch != null) {
                                    // Hole aktuellen Wert, um zu kontrollieren, ob ein Reboot stattgefunden hat
                                    var aktueller_wert = getState(shelly_DP(id) + "aktueller_wert").val;
                                    var alter_wert = 0;
                                    // Prüfe alten und neuen Wert
                                    if (shelly_verbrauch > aktueller_wert) {
                                        // Verbrauchswert ist größer als alter Wert -> es wurde kein Reboot durchgeführt
                                        setState(shelly_DP(id) + "alter_wert", aktueller_wert, true);
                                        alter_wert = aktueller_wert;
                                        anzahl_updates++;
                                    }
                                    if (aktueller_wert > shelly_verbrauch) {
                                        // Verbrauchswert ist kleiner als alter Wert -> es wurde ein Reboot durchgeführt
                                        setState(shelly_DP(id) + "alter_wert", 0, true);
                                        alter_wert = 0;
                                        anzahl_reboots++;
                                    }
                                    if (shelly_verbrauch == aktueller_wert) {
                                        // Verbrauchswert ist gleich wie alter Wert -> kein Update notwendig
                                        alter_wert = aktueller_wert;
                                        anzahl_gleich++;
                                    }
                                    setState(shelly_DP(id) + "aktueller_wert", shelly_verbrauch, true);
                                    // Alter und neuer Wert -> aktuelle Differenz
                                    var verbrauch = parseFloat(shelly_verbrauch) - alter_wert;
                                    // Tagesverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "heute", verbrauch);
                                    // Wochenverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "diese_woche", verbrauch);
                                    // Monatsverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "dieser_monat", verbrauch);
                                    // Jahresverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "dieses_jahr", verbrauch);
                                    // Gesamten Vebrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id), "gesamt", verbrauch);
                                }
                            });
                            shelly3EMTotalReturned.each(function (id, i) {
                                var shelly_verbrauch = getState(id).val;
                                // Einige Shelly haben keine Verbrauchswerte (noch nicht)
                                if (shelly_verbrauch != null) {
                                    // Hole aktuellen Wert, um zu kontrollieren, ob ein Reboot stattgefunden hat
                                    var aktueller_wert = getState(shelly_DP(id, true) + "aktueller_wert").val;
                                    var alter_wert = 0;
                                    // Prüfe alten und neuen Wert
                                    if (shelly_verbrauch > aktueller_wert) {
                                        // Verbrauchswert ist größer als alter Wert -> es wurde kein Reboot durchgeführt
                                        setState(shelly_DP(id, true) + "alter_wert", aktueller_wert, true);
                                        alter_wert = aktueller_wert;
                                        anzahl_updates++;
                                    }
                                    if (aktueller_wert > shelly_verbrauch) {
                                        // Verbrauchswert ist kleiner als alter Wert -> es wurde ein Reboot durchgeführt
                                        setState(shelly_DP(id, true) + "alter_wert", 0, true);
                                        alter_wert = 0;
                                        anzahl_reboots++;
                                    }
                                    if (shelly_verbrauch == aktueller_wert) {
                                        // Verbrauchswert ist gleich wie alter Wert -> kein Update notwendig
                                        alter_wert = aktueller_wert;
                                        anzahl_gleich++;
                                    }
                                    setState(shelly_DP(id, true) + "aktueller_wert", shelly_verbrauch, true);
                                    // Alter und neuer Wert -> aktuelle Differenz
                                    var verbrauch = parseFloat(shelly_verbrauch) - alter_wert;
                                    // Tagesverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id, true), "heute", verbrauch);
                                    // Wochenverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id, true), "diese_woche", verbrauch);
                                    // Monatsverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id, true), "dieser_monat", verbrauch);
                                    // Jahresverbrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id, true), "dieses_jahr", verbrauch);
                                    // Gesamten Vebrauch aktualisieren
                                    aktualisiere_vebrauch_objekt(shelly_DP(id, true), "gesamt", verbrauch);
                                }
                            });
                            aktualisiere_namen();
                            log("Shelly Verbrauch: Verbrauchswerte aktualisiert: " + anzahl_updates + " | Reboots korrigiert: " + anzahl_reboots + " | Unveränderte Werte: " + anzahl_gleich);
                        }
                        // aktualisiert das jeweilige Verbrauchs-Objekt und addiert den Verbrauch dazu
                        function aktualisiere_vebrauch_objekt(dp, objekt, wert) {
                            // Hole alten Verbrauch
                            let alter_verbrauch = getState(dp + objekt).val;
                            let verbrauch = 0;
                            // Kein Wert vorhanden - nutze den übermittelten Wert
                            if (alter_verbrauch < 1 || alter_verbrauch == null) {
                                verbrauch = parseFloat(wert)
                            } else {
                                verbrauch = parseFloat(alter_verbrauch) + parseFloat(wert);
                            }
                            setState(dp + objekt, parseFloat(verbrauch.toFixed(2)), true);
                        }
                        // Verschiebt das jeweilige Verbrauchs-Objekt und nullt den Ursprung (Tag, Woche, Monat, Jahr)
                        function verschiebe_verbrauch_objekt(von, nach) {
                            $('state[id=*.' + datenpunkt + '*.*.' + von + ']').each(function (id, i) {
                                // Temporärer Gruppen-Datenpunkt
                                var tmp_dp = id.slice(0, -(von.length));
                                var verbrauch = getState(id).val;
                                if (verbrauch != null) {
                                    setState(tmp_dp + nach, verbrauch, true);
                                }
                                // Setze "von" zurück
                                setState(id, 0, true);
                            });
                        }
                        // Funktion um die aktuellen Namen des Shelly abzuholen
                        function aktualisiere_namen() {
                            if (typeof extendObject === "function") {
                                shellyDpsName.each(function (id, i) {
                                    if (existsState(id)) {
                                        setState(shelly_DP_Name(id), String(getState(id).val), true);
                                        extendObject("javascript.0." + shelly_DP_Name_Main(id), {
                                            common: {
                                                name: String(getState(id).val),
                                                desc: String(getState(id).val)
                                            },
                                            type: "channel"
                                        });
                                    }
                                });
                            }
                        }
                        // Erstelle die benötigten Datenpunkte
                        function datenpunkte_erstellen() {
                            // Anzahl der gefundenen Shelly
                            var anzahl = shellyDps.length;
                            shellyDps.each(function (id, j) {
                                var initial_wert = 0.0;
                                for (var i = 0; i < objekt.length; i++) {
                                    // Startwerte werden nur bei alter_wert und aktueller_wert eingetragen
                                    if (i > 8) {
                                        initial_wert = getState(id).val;
                                    }
                                    createState(shelly_DP(id) + objekt[i], initial_wert, ueberschreiben, {
                                        name: beschreibung[i],
                                        desc: beschreibung[i],
                                        type: "number",
                                        role: "value.power",
                                        unit: "Wh"
                                    });
                                }
                            });
                            // Anzahl der gefundenen Shelly 3EM
                            var anzahl_3em = shelly3EMDps.length;
                            shelly3EMDps.each(function (id, j) {
                                var initial_wert = 0.0;
                                for (var i = 0; i < objekt.length; i++) {
                                    // Startwerte werden nur bei alter_wert und aktueller_wert eingetragen
                                    if (i > 8) {
                                        initial_wert = getState(id).val;
                                    }
                                    createState(shelly_DP(id) + objekt[i], initial_wert, ueberschreiben, {
                                        name: beschreibung[i],
                                        desc: beschreibung[i],
                                        type: "number",
                                        role: "value.power",
                                        unit: "Wh"
                                    });
                                }
                            });
                            // Anzahl der gefundenen Shelly 3EM - Total
                            var anzahl_3em_total = shelly3EMTotalDps.length;
                            shelly3EMTotalDps.each(function (id, j) {
                                var initial_wert = 0.0;
                                for (var i = 0; i < objekt.length; i++) {
                                    // Startwerte werden nur bei alter_wert und aktueller_wert eingetragen
                                    if (i > 8) {
                                        initial_wert = getState(id).val;
                                    }
                                    createState(shelly_DP(id) + objekt[i], initial_wert, ueberschreiben, {
                                        name: beschreibung[i],
                                        desc: beschreibung[i],
                                        type: "number",
                                        role: "value.power",
                                        unit: "Wh"
                                    });
                                }
                            });
                            // Anzahl der gefundenen Shelly 3EM - Total
                            var anzahl_3em_total_returned = shelly3EMTotalReturned.length;
                            shelly3EMTotalReturned.each(function (id, j) {
                                var initial_wert = 0.0;
                                for (var i = 0; i < objekt.length; i++) {
                                    // Startwerte werden nur bei alter_wert und aktueller_wert eingetragen
                                    if (i > 8) {
                                        initial_wert = getState(id).val;
                                    }
                                    createState(shelly_DP(id, true) + objekt[i], initial_wert, ueberschreiben, {
                                        name: beschreibung[i],
                                        desc: beschreibung[i],
                                        type: "number",
                                        role: "value.power",
                                        unit: "Wh"
                                    });
                                }
                            });
                            // Alle Datenpunkte erstellt. Frage ersten Verbrauch ab!
                            log("Shelly Verbrauch: Datenpunkte erstellt! Erster Verbrauch steht nach 30 Sekunden zur Verfügung! Anzahl gefundener Shelly Datenpunkte: " + (anzahl_3em + anzahl + anzahl_3em_total + anzahl_3em_total_returned));
                            setTimeout(shelly_verbrauch_update, 30000);
                            // Datenpunkte für die Namen der Shelly erstellen
                            shellyDpsName.each(function (id, j) {
                                createState(shelly_DP_Name(id), "", ueberschreiben, {
                                    name: "Name des Shelly",
                                    desc: "Name des Shelly",
                                    type: "string",
                                    role: "value",
                                    unit: ""
                                });
                            });
                        }
                        /**
                         * Wenn 3EM DP, dann anderen Wert zurückgeben
                         * @param {any} dp
                         * @param {boolean} extended
                         */
                        function shelly_DP(dp, extended = false) {
                            dp = dp.split(".");
                            dp = datenpunkt + dp[2] + "." + dp[3];
                            if (extended) {
                                dp = dp + "_Returned.";
                            } else {
                                dp = dp + ".";
                            }
                            return dp;
                        }
                        function shelly_DP_Name(dp) {
                            dp = dp.split(".");
                            dp = datenpunkt + dp[2] + "." + dp[3];
                            return dp;
                        }
                        function shelly_DP_Name_Main(dp) {
                            dp = dp.split(".");
                            dp = datenpunkt + dp[2];
                            return dp;
                        }
                        function shelly_verbrauch_erster_start() {
                            log("Shelly Verbrauch: Erster Start des Skriptes! Datenpunkte werden erstellt!");
                            // Datenpunkte werden erstellt
                            datenpunkte_erstellen();
                        }
                        // Erster Start und Initialisierung
                        shelly_verbrauch_erster_start();
                        // Alle 15 Minuten das Skript für den Tagesverbrauch ausführen
                        schedule('*/15 * * * *', shelly_verbrauch_update);
                        // Nachts um 24 Uhr werden die Werte in andere Variablen gespeichert, um den Verlauf zu erstellen
                        schedule('0 0 * * *', shelly_vebrauch_tag);
                        
                        CodierknechtC Offline
                        CodierknechtC Offline
                        Codierknecht
                        Developer Most Active
                        schrieb am zuletzt editiert von Codierknecht
                        #25

                        @stefu87_ch
                        Hier stand Quatsch :-(

                        "Any fool can write code that a computer can understand. Good programmers write code that humans can understand." (Martin Fowler, "Refactoring")

                        Proxmox 9.1.1 LXC|8 GB|Core i7-6700
                        HmIP|ZigBee|Tasmota|Unifi
                        Zabbix Certified Specialist
                        Konnte ich Dir helfen? Dann benutze bitte das Voting unten rechts im Beitrag

                        S 1 Antwort Letzte Antwort
                        0
                        • CodierknechtC Codierknecht

                          @stefu87_ch
                          Hier stand Quatsch :-(

                          S Offline
                          S Offline
                          stefu87_CH
                          schrieb am zuletzt editiert von
                          #26

                          @codierknecht Versuche es mal so:

                          869245ae-6f22-4517-9809-a377a80690da-grafik.png

                          8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                          Gigabyte mit Proxmox
                          LXC Container mit Iobroker

                          CodierknechtC 1 Antwort Letzte Antwort
                          0
                          • S stefu87_CH

                            @codierknecht Versuche es mal so:

                            869245ae-6f22-4517-9809-a377a80690da-grafik.png

                            CodierknechtC Offline
                            CodierknechtC Offline
                            Codierknecht
                            Developer Most Active
                            schrieb am zuletzt editiert von
                            #27

                            @stefu87_ch
                            Ich würde für den Zeitplan ein CRON verwenden und nicht den Wizard.
                            Ist besser lesbar und funktioniert nach meiner Erfahrung zuverlässiger.

                            "Any fool can write code that a computer can understand. Good programmers write code that humans can understand." (Martin Fowler, "Refactoring")

                            Proxmox 9.1.1 LXC|8 GB|Core i7-6700
                            HmIP|ZigBee|Tasmota|Unifi
                            Zabbix Certified Specialist
                            Konnte ich Dir helfen? Dann benutze bitte das Voting unten rechts im Beitrag

                            S 1 Antwort Letzte Antwort
                            1
                            • CodierknechtC Codierknecht

                              @stefu87_ch
                              Ich würde für den Zeitplan ein CRON verwenden und nicht den Wizard.
                              Ist besser lesbar und funktioniert nach meiner Erfahrung zuverlässiger.

                              S Offline
                              S Offline
                              stefu87_CH
                              schrieb am zuletzt editiert von
                              #28

                              @codierknecht das heisst, wenn die Werte dann in der History sind, für jeden Tag, können dann in Grafana als Graphische Balken dargestellt werden?

                              8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                              Gigabyte mit Proxmox
                              LXC Container mit Iobroker

                              CodierknechtC 1 Antwort Letzte Antwort
                              0
                              • S stefu87_CH

                                @codierknecht das heisst, wenn die Werte dann in der History sind, für jeden Tag, können dann in Grafana als Graphische Balken dargestellt werden?

                                CodierknechtC Offline
                                CodierknechtC Offline
                                Codierknecht
                                Developer Most Active
                                schrieb am zuletzt editiert von Codierknecht
                                #29

                                @stefu87_ch
                                Ja!
                                Frag mich aber bei Influx nicht, wie da die Abfrage aussehen müsste.
                                Ich bleibe berufsbedingt beim guten alten SQL.

                                "Any fool can write code that a computer can understand. Good programmers write code that humans can understand." (Martin Fowler, "Refactoring")

                                Proxmox 9.1.1 LXC|8 GB|Core i7-6700
                                HmIP|ZigBee|Tasmota|Unifi
                                Zabbix Certified Specialist
                                Konnte ich Dir helfen? Dann benutze bitte das Voting unten rechts im Beitrag

                                S 3 Antworten Letzte Antwort
                                0
                                • CodierknechtC Codierknecht

                                  @stefu87_ch
                                  Ja!
                                  Frag mich aber bei Influx nicht, wie da die Abfrage aussehen müsste.
                                  Ich bleibe berufsbedingt beim guten alten SQL.

                                  S Offline
                                  S Offline
                                  stefu87_CH
                                  schrieb am zuletzt editiert von
                                  #30

                                  @codierknecht ok. Ich schaue mal was in den nächsten tagen passiert

                                  8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                                  Gigabyte mit Proxmox
                                  LXC Container mit Iobroker

                                  1 Antwort Letzte Antwort
                                  0
                                  • CodierknechtC Codierknecht

                                    @stefu87_ch
                                    Ja!
                                    Frag mich aber bei Influx nicht, wie da die Abfrage aussehen müsste.
                                    Ich bleibe berufsbedingt beim guten alten SQL.

                                    S Offline
                                    S Offline
                                    stefu87_CH
                                    schrieb am zuletzt editiert von stefu87_CH
                                    #31

                                    @codierknecht Du bist echt ein Profi auf deinem Gebiet. Dank deiner Anpassung des Java Codes hat es geklappt.

                                    292de850-14bf-4ccf-9d28-1e70a9228ea4-grafik.png

                                    8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                                    Gigabyte mit Proxmox
                                    LXC Container mit Iobroker

                                    1 Antwort Letzte Antwort
                                    0
                                    • CodierknechtC Codierknecht

                                      @stefu87_ch
                                      Ja!
                                      Frag mich aber bei Influx nicht, wie da die Abfrage aussehen müsste.
                                      Ich bleibe berufsbedingt beim guten alten SQL.

                                      S Offline
                                      S Offline
                                      stefu87_CH
                                      schrieb am zuletzt editiert von stefu87_CH
                                      #32

                                      @codierknecht
                                      Wie müsste ich den Code anpassen, wenn ich es direkt als Grafana Code vorbereitet haben möchte, also so das eigentlich die idTable nicht noch zusätzlich geschrieben wird?

                                      // @ts-nocheck
                                      const idVerbrauch = '0_userdata.0.Waschmaschine.Waschgänge_pro_Woche';// ID zuweisen!
                                      const idGrafana = '0_userdata.0.Grafana.Waschdurchgäne';
                                      const idTable = '0_userdata.0.Wohnungsverbrauch.Tagesverbrauch'; // ID anpassen!
                                      
                                       schedule('59 23 * * *', function() {
                                          var arr = [];
                                       
                                          if (getState(idTable).val) arr = JSON.parse(getState(idTable).val);
                                       
                                          const obj = {
                                              Durchgang: getState(idVerbrauch).val.toFixed(3)
                                          }
                                       
                                          arr.push(obj);
                                       
                                          if(arr.length > 5) arr.shift(); // max. 5 Zeilen
                                       
                                          setState(idTable, JSON.stringify(arr), true);
                                          
                                          let values = {};
                                          for (const item of arr) {
                                            values[item.Datum] = parseFloat(item.Verbrauch);
                                          }
                                          setState(idGrafana, JSON.stringify(values), true);
                                          
                                      });
                                      

                                      Möchte es gerne noch weiter treiben mit Daten in Grafana erfassen auf einfache Weise und nicht mit 2 unterschiedlichen Tabellen Varianten.

                                      Oder hast du einen einfachen Code den ich dafür verwenden kann?

                                      8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                                      Gigabyte mit Proxmox
                                      LXC Container mit Iobroker

                                      CodierknechtC 1 Antwort Letzte Antwort
                                      0
                                      • S stefu87_CH

                                        @codierknecht
                                        Wie müsste ich den Code anpassen, wenn ich es direkt als Grafana Code vorbereitet haben möchte, also so das eigentlich die idTable nicht noch zusätzlich geschrieben wird?

                                        // @ts-nocheck
                                        const idVerbrauch = '0_userdata.0.Waschmaschine.Waschgänge_pro_Woche';// ID zuweisen!
                                        const idGrafana = '0_userdata.0.Grafana.Waschdurchgäne';
                                        const idTable = '0_userdata.0.Wohnungsverbrauch.Tagesverbrauch'; // ID anpassen!
                                        
                                         schedule('59 23 * * *', function() {
                                            var arr = [];
                                         
                                            if (getState(idTable).val) arr = JSON.parse(getState(idTable).val);
                                         
                                            const obj = {
                                                Durchgang: getState(idVerbrauch).val.toFixed(3)
                                            }
                                         
                                            arr.push(obj);
                                         
                                            if(arr.length > 5) arr.shift(); // max. 5 Zeilen
                                         
                                            setState(idTable, JSON.stringify(arr), true);
                                            
                                            let values = {};
                                            for (const item of arr) {
                                              values[item.Datum] = parseFloat(item.Verbrauch);
                                            }
                                            setState(idGrafana, JSON.stringify(values), true);
                                            
                                        });
                                        

                                        Möchte es gerne noch weiter treiben mit Daten in Grafana erfassen auf einfache Weise und nicht mit 2 unterschiedlichen Tabellen Varianten.

                                        Oder hast du einen einfachen Code den ich dafür verwenden kann?

                                        CodierknechtC Offline
                                        CodierknechtC Offline
                                        Codierknecht
                                        Developer Most Active
                                        schrieb am zuletzt editiert von
                                        #33

                                        @stefu87_ch sagte in JSON in Grafana einbinden:

                                        Möchte es gerne noch weiter treiben mit Daten in Grafana erfassen auf einfache Weise

                                        Ich würde da unbedingt einen der SQL-Adapter empfehlen.
                                        Das ist am einfachsten anzubinden und kann dann nach Lust und Laune ausgewertet werden.
                                        Wenn Du das alles separat per Script machen willst, programmierst Du Dir 'nen Wolf.
                                        Eine Datenbank abzufragen ist da wesentlich flexibler.

                                        "Any fool can write code that a computer can understand. Good programmers write code that humans can understand." (Martin Fowler, "Refactoring")

                                        Proxmox 9.1.1 LXC|8 GB|Core i7-6700
                                        HmIP|ZigBee|Tasmota|Unifi
                                        Zabbix Certified Specialist
                                        Konnte ich Dir helfen? Dann benutze bitte das Voting unten rechts im Beitrag

                                        S 1 Antwort Letzte Antwort
                                        0
                                        • CodierknechtC Codierknecht

                                          @stefu87_ch sagte in JSON in Grafana einbinden:

                                          Möchte es gerne noch weiter treiben mit Daten in Grafana erfassen auf einfache Weise

                                          Ich würde da unbedingt einen der SQL-Adapter empfehlen.
                                          Das ist am einfachsten anzubinden und kann dann nach Lust und Laune ausgewertet werden.
                                          Wenn Du das alles separat per Script machen willst, programmierst Du Dir 'nen Wolf.
                                          Eine Datenbank abzufragen ist da wesentlich flexibler.

                                          S Offline
                                          S Offline
                                          stefu87_CH
                                          schrieb am zuletzt editiert von
                                          #34

                                          @codierknecht
                                          Dann würde ich deine Empfehlung gerne annehmen.
                                          Welchen SQL Adapter würdest du empfehlen der einfach zu verstehen ist, und auch eben mit verschiedenen Zeiten die Werte aufzeichnet, und dann einfach in Grafana einbinden lässt?

                                          8 x Intel(R) Core(TM) i5-8250U CPU @ 1.60GHz
                                          Gigabyte mit Proxmox
                                          LXC Container mit Iobroker

                                          CodierknechtC 1 Antwort Letzte Antwort
                                          0
                                          Antworten
                                          • In einem neuen Thema antworten
                                          Anmelden zum Antworten
                                          • Älteste zuerst
                                          • Neuste zuerst
                                          • Meiste Stimmen


                                          Support us

                                          ioBroker
                                          Community Adapters
                                          Donate

                                          873

                                          Online

                                          32.5k

                                          Benutzer

                                          81.6k

                                          Themen

                                          1.3m

                                          Beiträge
                                          Community
                                          Impressum | Datenschutz-Bestimmungen | Nutzungsbedingungen | Einwilligungseinstellungen
                                          ioBroker Community 2014-2025
                                          logo
                                          • Anmelden

                                          • Du hast noch kein Konto? Registrieren

                                          • Anmelden oder registrieren, um zu suchen
                                          • Erster Beitrag
                                            Letzter Beitrag
                                          0
                                          • Home
                                          • Aktuell
                                          • Tags
                                          • Ungelesen 0
                                          • Kategorien
                                          • Unreplied
                                          • Beliebt
                                          • GitHub
                                          • Docu
                                          • Hilfe