Object Daten in Influx db speichern

Marc Berg

@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!!

CrazyChickenBln

@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:

Schon einmal vielen Dank :-)

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

CrazyChickenBln

@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 :disappointed_relieved:

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.

mickym

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

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}]

CrazyChickenBln

Vielen Dank für die Hilfe, das hat wunderbar geklappt! :slightly_smiling_face:
Ihr seid eine tolle Community :+1:

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:

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

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

Das wars auch schon.

Ach und ggf. noch auf ms umstellen:

icebear

@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

@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.

Community Forum

NEWS

Object Daten in Influx db speichern

Support us

837

32.5k

81.6k

1.3m