Navigation

    Logo
    • Register
    • Login
    • Search
    • Recent
    • Tags
    • Unread
    • Categories
    • Unreplied
    • Popular
    • GitHub
    • Docu
    • Hilfe
    1. Home
    2. Deutsch
    3. Skripten / Logik
    4. Node-Red
    5. Object Daten in Influx db speichern

    NEWS

    • ioBroker@Smart Living Forum Solingen, 14.06. - Agenda added

    • ioBroker goes Matter ... Matter Adapter in Stable

    • Monatsrückblick - April 2025

    Object Daten in Influx db speichern

    This topic has been deleted. Only users with topic management privileges can see it.
    • Marc Berg
      Marc Berg Most Active @mickym last edited by

      @mickym sagte in Object Daten in Influx db speichern:

      Ja dann halt die Klammer drum rum aber das ist ja easy:
      $zip(payload.unix_seconds,payload.price).[{"time":$[0],"value":$[1]}]

      Ja, perfekt! Danke!!

      1 Reply Last reply Reply Quote 0
      • C
        CrazyChickenBln @mickym last edited by

        @mickym

        Hallo!
        Ich bastle gerade an der gleichen Integration, die Du hier schon gelöst hast.
        Leider liefert die "Solarprognose.de" API bei mir irgendwie ein anderes Format als das bei @drdoener der Fall war.

        Somit funktioniert natürlich der Flow nicht richtig.
        Könntest Du Dir das bitte einmal ansehen? Ich stehe bei Programmierung ziemlich auf dem Schlauch.

        Hier mein API Payload:


        {"preferredNextApiRequestAt":{"secondOfHour":408,"epochTimeUtc":1713276408},"status":0,"iLastPredictionGenerationEpochTime":1713275949,"weather_source_text":"Kurzfristig (3 Tage): Powered by <a href="https://www.weatherapi.com/" title="Free Weather API">WeatherAPI.com</a> und Langfristig (10 Tage): Powered by <a href="https://www.visualcrossing.com/weather-data" target="_blank">Visual Crossing Weather</a>","datalinename":"Germany > Pichelsdorf","data":{"1713236400":[0,0],"1713240000":[0.003,0.003],"1713243600":[0.112,0.115],"1713247200":[0.269,0.384],"1713250800":[0.403,0.787],"1713254400":[0.621,1.408],"1713258000":[0.599,2.007],"1713261600":[0.697,2.704],"1713265200":[0.835,3.539],"1713268800":[0.679,4.218],"1713272400":[0.581,4.799],"1713276000":[0.496,5.295],"1713279600":[0.405,5.7],"1713283200":[0.272,5.972],"1713286800":[0.115,6.087],"1713290400":[0,6.087],"1713322800":[0,0],"1713326400":[0.019,0.019],"1713330000":[0.395,0.414],"1713333600":[0.775,1.189],"1713337200":[1.039,2.228],"1713340800":[0.858,3.086],"1713344400":[1.022,4.108],"1713348000":[0.623,4.731],"1713351600":[0.961,5.692],"1713355200":[0.644,6.336],"1713358800":[0.579,6.915],"1713362400":[0.656,7.571],"1713366000":[0.566,8.137],"1713369600":[0.298,8.435],"1713373200":[0.084,8.519],"1713376800":[0,8.519]}}

        Schon einmal vielen Dank 🙂

        mickym 1 Reply Last reply Reply Quote 0
        • mickym
          mickym Most Active @CrazyChickenBln last edited by mickym

          @crazychickenbln Wieso ist doch fast das Gleiche. Wie brauchst Du Dein Objekt?

          timestamp und dann fields mit Prognose_W und Prognose W_h als fields?

          Schau halt mal, ob das so für Dich passt - besser bekomme ich es erstmal nicht hin:
          https://try.jsonata.org/bTDLArmfO

          C 1 Reply Last reply Reply Quote 0
          • C
            CrazyChickenBln @mickym last edited by

            @mickym Erst einmal danke für die schnelle Antwort!

            Ich möchte die Prognosedaten genau wie oben bei @drdoener mit den entsprechenden Timestamps in eine Influx DB 2 schreiben, damit ich sie in Grafana visualisieren kann.
            Über den Thread Solarprognose hier im Forum habe ich es geschafft, die Daten zumindest schön im Broker zu implementieren. An der Übergabe der Zukunftswerte nach Grafana scheint es damit aber nicht möglich zu sein, jedenfalls hat es dort keiner geschafft. Dort wurde dann auf diesen Beitrag verwiesen.

            Da es mit Deinem Flow ja wohl bei Ihm funtioniert, würde ich also gerne mein Objekt (das brauche ich ja wohl für die Datenübergabe an Influx) genauso aufbauen wie bei Ihm.
            (Objekt mit den Flields Datum, Prognose_W, Prognose_Wh)

            Ich habe zumindest begriffen, dass ich irgend etwas in der zweiten Switch-Node ändern muss
            ($each($.payload, function($v, $k) {$v}).{
            "measurement":"Solarprognose1",
            "timestamp":$[0] ,
            "fields":{
            "Datum": ($moment($[0]*1000).locale("de").tz('Europe/Berlin').format('DD.MM.YYYY HH:mm:ss'))[0],
            "Prognose_W":$[1],
            "Prognose_Wh":$[2]
            }
            }

            weil bei meinem API-Output der zweite Timestamp ja nicht mehr existiert.
            Leider war es das aber auch schon mit meinem Wissen, mit meinen Kenntnissen in BASIC aus Schulzeiten komme ich hier nicht wirklich weiter 😥

            Diese JSONata Exerciser Seite habe ich mir angeschaut. Allerdings komme ich da auch nicht wirklich weiter, weil die Formel oben rechts

            $zip($keys(data),$zip(data.#$i[($i%2)=0],data.#$i[($i%2)=1])).[{"timestamp":$[0],"fields":{"Prognose_W":$[1],"Prognose_Wh":$[2]}}]

            ist ja nun wieder völlig anders, als die Node-Red Funktion weiter oben.

            1 Reply Last reply Reply Quote 0
            • mickym
              mickym Most Active last edited by

              Also ich bin auch nimmer so fit - mit der normalen Influx bekomme ich es nicht hin, sondern nur mit der Batch-Node.

              358b2243-ef46-45d8-94a4-2a904e4e45c7-image.png

              5a8871af-fd53-4be2-b29c-c86f6a0f06fd-image.png

              Hier der Flow:

              [{"id":"29339e62b7a1b9e3","type":"inject","z":"5ad55a7b0d4580eb","name":"","props":[{"p":"payload"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"{\"preferredNextApiRequestAt\":{\"secondOfHour\":408,\"epochTimeUtc\":1713276408},\"status\":0,\"iLastPredictionGenerationEpochTime\":1713275949,\"weather_source_text\":\"Kurzfristig (3 Tage): Powered by <a href='https: //www.weatherapi.com/title=\",\"datalinename\":\"Germany > Pichelsdorf\",\"data\":{\"1713236400\":[0,0],\"1713240000\":[0.003,0.003],\"1713243600\":[0.112,0.115],\"1713247200\":[0.269,0.384],\"1713250800\":[0.403,0.787],\"1713254400\":[0.621,1.408],\"1713258000\":[0.599,2.007],\"1713261600\":[0.697,2.704],\"1713265200\":[0.835,3.539],\"1713268800\":[0.679,4.218],\"1713272400\":[0.581,4.799],\"1713276000\":[0.496,5.295],\"1713279600\":[0.405,5.7],\"1713283200\":[0.272,5.972],\"1713286800\":[0.115,6.087],\"1713290400\":[0,6.087],\"1713322800\":[0,0],\"1713326400\":[0.019,0.019],\"1713330000\":[0.395,0.414],\"1713333600\":[0.775,1.189],\"1713337200\":[1.039,2.228],\"1713340800\":[0.858,3.086],\"1713344400\":[1.022,4.108],\"1713348000\":[0.623,4.731],\"1713351600\":[0.961,5.692],\"1713355200\":[0.644,6.336],\"1713358800\":[0.579,6.915],\"1713362400\":[0.656,7.571],\"1713366000\":[0.566,8.137],\"1713369600\":[0.298,8.435],\"1713373200\":[0.084,8.519],\"1713376800\":[0,8.519]}}","payloadType":"json","x":150,"y":2500,"wires":[["586029ecb69d46e0"]]},{"id":"586029ecb69d46e0","type":"change","z":"5ad55a7b0d4580eb","name":"","rules":[{"t":"set","p":"payload","pt":"msg","to":"$zip(\t   $keys(payload.data),\t   $zip(\t       payload.data.*#$i[($i%2)=0],\t       payload.data.*#$i[($i%2)=1]\t   )\t).\t   {\t       \"measurement\" : \"Solarprognose2\",\t       \"timestamp\":$number($[0])*1000,\t       \"fields\":{\t        \"Datum\": ($moment($[0],'X').format('DD.MM.YYYY HH:mm:ss'))[0],\t        \"Prognose_W\":$[1],\t        \"Prognose_Wh\":$[2]}\t   }\t","tot":"jsonata"}],"action":"","property":"","from":"","to":"","reg":false,"x":330,"y":2500,"wires":[["6ac97ec264377ff5","276d267403e20027"]]},{"id":"6ac97ec264377ff5","type":"debug","z":"5ad55a7b0d4580eb","name":"Daten","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":550,"y":2600,"wires":[]},{"id":"276d267403e20027","type":"influxdb batch","z":"5ad55a7b0d4580eb","influxdb":"492dfce8b90a8cc8","precision":"","retentionPolicy":"","name":"","database":"database","precisionV18FluxV20":"ms","retentionPolicyV18Flux":"","org":"mwdebian","bucket":"Node-Red Test","x":650,"y":2500,"wires":[]},{"id":"492dfce8b90a8cc8","type":"influxdb","hostname":"127.0.0.1","port":"8086","protocol":"http","database":"database","name":"","usetls":false,"tls":"","influxdbVersion":"2.0","url":"http://mwdebian.fritz.box:8086","rejectUnauthorized":false}]
              

              1 Reply Last reply Reply Quote 1
              • C
                CrazyChickenBln last edited by

                Vielen Dank für die Hilfe, das hat wunderbar geklappt! 🙂
                Ihr seid eine tolle Community 👍

                1 Reply Last reply Reply Quote 0
                • icebear
                  icebear last edited by icebear

                  Hallo ich kram das hier nochmal nach oben, weil leider bei mir das ganze nich funktioniert. Ich bekomme zwar in Node-Red die Daten, aber das senden an Influx funktioniert nicht , bei mir kommt immer diese Fehlermeldung:

                  node-red.png

                  Das json von Solarprognose sieht so aus:

                  [
                     {
                         "id": "7be48dbfd8733fdf",
                         "type": "tab",
                         "label": "solcastJSON",
                         "disabled": false,
                         "info": "",
                         "env": []
                     },
                     {
                         "id": "586029ecb69d46e0",
                         "type": "change",
                         "z": "7be48dbfd8733fdf",
                         "name": "",
                         "rules": [
                             {
                                 "t": "set",
                                 "p": "payload",
                                 "pt": "msg",
                                 "to": "$zip(\t $keys(payload.data),\t $zip(\t payload.data.*#$i[($i%2)=0],\t payload.data.*#$i[($i%2)=1]\t )\t).\t {\t \"measurement\" : \"Solarprognose2\",\t \"timestamp\":$number($[0])*1000,\t \"fields\":{\t \"Datum\": ($moment($[0],'X').format('DD.MM.YYYY HH:mm:ss'))[0],\t \"Prognose_W\":$[1],\t \"Prognose_Wh\":$[2]}\t }\t",
                                 "tot": "jsonata"
                             }
                         ],
                         "action": "",
                         "property": "",
                         "from": "",
                         "to": "",
                         "reg": false,
                         "x": 550,
                         "y": 240,
                         "wires": [
                             [
                                 "6ac97ec264377ff5",
                                 "868c451cb4e19d3f"
                             ]
                         ]
                     },
                     {
                         "id": "6ac97ec264377ff5",
                         "type": "debug",
                         "z": "7be48dbfd8733fdf",
                         "name": "Daten",
                         "active": true,
                         "tosidebar": true,
                         "console": false,
                         "tostatus": false,
                         "complete": "payload",
                         "targetType": "msg",
                         "statusVal": "",
                         "statusType": "auto",
                         "x": 690,
                         "y": 140,
                         "wires": []
                     },
                     {
                         "id": "66cc6cb89ddc729b",
                         "type": "http request",
                         "z": "7be48dbfd8733fdf",
                         "name": "",
                         "method": "GET",
                         "ret": "txt",
                         "paytoqs": "ignore",
                         "url": "https://www.solarprognose.de/web/solarprediction/api/v1?_format=json&access-token=<token>&item=location&id=3747&type=hourly",
                         "tls": "",
                         "persist": false,
                         "proxy": "",
                         "insecureHTTPParser": false,
                         "authType": "",
                         "senderr": false,
                         "headers": [],
                         "x": 250,
                         "y": 240,
                         "wires": [
                             [
                                 "4da0fe52d46153ed"
                             ]
                         ]
                     },
                     {
                         "id": "4da0fe52d46153ed",
                         "type": "json",
                         "z": "7be48dbfd8733fdf",
                         "name": "",
                         "property": "payload",
                         "action": "",
                         "pretty": false,
                         "x": 390,
                         "y": 240,
                         "wires": [
                             [
                                 "586029ecb69d46e0"
                             ]
                         ]
                     },
                     {
                         "id": "868c451cb4e19d3f",
                         "type": "influxdb out",
                         "z": "7be48dbfd8733fdf",
                         "influxdb": "2da91c195513de67",
                         "name": "",
                         "measurement": "Solarprognose",
                         "precision": "",
                         "retentionPolicy": "",
                         "database": "database",
                         "precisionV18FluxV20": "s",
                         "retentionPolicyV18Flux": "",
                         "org": "openHAB",
                         "bucket": "iobroker",
                         "x": 580,
                         "y": 340,
                         "wires": []
                     },
                     {
                         "id": "8d223fa469f881c3",
                         "type": "cronplus",
                         "z": "7be48dbfd8733fdf",
                         "name": "",
                         "outputField": "payload",
                         "timeZone": "",
                         "storeName": "",
                         "commandResponseMsgOutput": "output1",
                         "defaultLocation": "",
                         "defaultLocationType": "default",
                         "outputs": 1,
                         "options": [
                             {
                                 "name": "schedule1",
                                 "topic": "topic1",
                                 "payloadType": "default",
                                 "payload": "",
                                 "expressionType": "cron",
                                 "expression": "4 6,9,11,13,15 * * *",
                                 "location": "",
                                 "offset": "0",
                                 "solarType": "all",
                                 "solarEvents": "sunrise,sunset"
                             }
                         ],
                         "x": 100,
                         "y": 240,
                         "wires": [
                             [
                                 "66cc6cb89ddc729b"
                             ]
                         ]
                     },
                     {
                         "id": "2da91c195513de67",
                         "type": "influxdb",
                         "hostname": "127.0.0.1",
                         "port": "8086",
                         "protocol": "http",
                         "database": "database",
                         "name": "InfluxDB-IOB",
                         "usetls": false,
                         "tls": "",
                         "influxdbVersion": "2.0",
                         "url": "http://192.168.178.3:8086",
                         "rejectUnauthorized": true
                     }
                  ]
                  


                  was muß ich hier ändern?

                  mickym 1 Reply Last reply Reply Quote 0
                  • mickym
                    mickym Most Active @icebear last edited by mickym

                    @icebear Wenn Du Deine Daten so aufbereitest, darfst Du nicht die Influx-Out Node nehmen, sondern Du musst die Batch Node nehmen.

                    c6e1c87c-dae0-44e1-93b5-0735c7f4d2cd-image.png

                    e30ca16e-991c-49b4-bcc3-e3a3273027e4-image.png

                    Das wars auch schon.

                    552f0d3a-b4f7-4b58-8a9e-911c5a285d6a-image.png

                    Ach und ggf. noch auf ms umstellen:

                    94b1d6c0-ebfc-48d1-84b3-3feb85fe724f-image.png

                    icebear 1 Reply Last reply Reply Quote 0
                    • icebear
                      icebear @mickym last edited by

                      @mickym

                      Supi, vielen Dank für den Hinweis, ich habs grad mal ausprobiert und er schreibt jetzt die Werte in die DB.

                      Ich müsste da evtl. noch etwas an der Abfrage bzw. den Daten ändern, kann das aber im Moment nicht weiter testen, da ich beim Free-Account mit der letzten Abfrage das Limit erreicht habe.

                      Ich probier Morgen mal weiter und meld mich nochmal falls ich noch Hilfe brauche.

                      Also nochmal, vielen Dank für deine Hilfe.

                      mickym 1 Reply Last reply Reply Quote 0
                      • mickym
                        mickym Most Active @icebear last edited by mickym

                        @icebear Wenn Du die Influx-Out Nodes nimmst, dann hast Du keine Eigenschaften im Objekt, wie fields und measurement, sondern nur verschachtelte Arrays:

                        [
                            [
                                {
                                    "temperature": 24,
                                    "humidity": 52
                                },
                                {
                                    "room": "Wohnzimmer"
                                }
                            ],
                            [
                                {
                                    "temperature": 25,
                                    "humidity": 70
                                },
                                {
                                    "room": "Bad"
                                }
                            ]
                        ]
                        

                        Das äussere Array enthält die Datenpunkte, jeder Datenpunkt besteht wieder aus einem Array mit 2 Objekten. Im Ersten sind die "Fields" mit den Werten, im Zweiten die Tags.

                        Insofern ist die Batch-Verarbeitung etwas übersichtlicher und kannst so halt auch mit einer Node in verschiedene measurements schreiben.

                        1 Reply Last reply Reply Quote 0
                        • First post
                          Last post

                        Support us

                        ioBroker
                        Community Adapters
                        Donate

                        758
                        Online

                        31.7k
                        Users

                        79.7k
                        Topics

                        1.3m
                        Posts

                        5
                        50
                        3296
                        Loading More Posts
                        • Oldest to Newest
                        • Newest to Oldest
                        • Most Votes
                        Reply
                        • Reply as topic
                        Log in to reply
                        Community
                        Impressum | Datenschutz-Bestimmungen | Nutzungsbedingungen
                        The ioBroker Community 2014-2023
                        logo