ApplicationScenarios openmeteo

Anwendungs-Szenario: Datenimport von openmeteo

Dieses Beispiel zeigt, wie Daten von der openmeteo API durch Nutzung des JSON-Parsers importiert werden können.

Einrichtung: Datenbank

In der Datenbank wird die Tabelle für die Speicherung angelegt. Die Namen der Tabellenspalten werden unten im JSON für die Importkonfiguration wieder verwendet.

CREATE TABLE openmeteo (
	id bigserial NOT NULL,
	pos public.geometry(point, 4326) NOT NULL
        ts timestamp NOT NULL,
        temperature_2m float NOT NULL,
        windspeed_10m NOT NULL
);

Einrichtung: Import der Vorhersagen

{
   "server":"http://epigraf01.ad.fh-bielefeld.de:8080",
   "smartdata":"SmartDataGewaesser",
   "storage":"smartmonitoring",
    "collection":"openmeteo",
   "parser":"JSONParser",
    "importer":"HTTPImporter",
   "url":"https://api.open-meteo.com/v1/forecast?latitude=52.2525&longitude=10.5393&hourly=temperature_2m,windspeed_10m",
   "json_mapping":[
     {
      "collection":"openmeteo",
      "mappingdata":[
        {
         "path":"/latitude",
         "dbcolumn":"lat"
        },
        {
         "path":"/longitude",
         "dbcolumn":"lon"
        },
        {
         "path":"/hourly/time",
         "dbcolumn":"ts"
        },
        {
         "path":"/hourly/temperature_2m",
         "dbcolumn":"temperature_2m"
        },
        {
         "path":"/hourly/windspeed_10m",
         "dbcolumn":"windspeed_10m"
        }
      ]
   }
   ],
    "geo.transform":true,
    "geo.latAttr":"lat",
    "geo.lonAttr":"lon",
    "geo.srid":"4326",
    "geo.dbattr":"pos"
}

Hinweis: geo.* Konfigurationen gehören zu den Basis-Konfigurationen. Siehe "[Konfiguration des Imports](anwendung/Importer/Konfiguration des Imports)" Der Import der Koordinate erfolgt hier nur in die Spalte "pos"

Nutzung: Einmaliger Import

Für einen einmaligen Import kann das obige JSON per HTTP-POST an den SmartDataPorter gesendet werden.

POST http://localhost:8080/SmartDataPorter/smartdataporter/import

Nutzung: Regelmäßiger Import

Für den regelmäßigen Import kann ServerSideJobs verwendet werden.