Strompreis und CO2 in Node-RED nutzen, ohne lange zu klicken

Empfohlener Endpunkt

Für Node-RED gibt es einen eigenen Summary-Pfad mit den wichtigsten Feldern für erste Automationen und mit Meta-Feldern für Limits und API-Key-Status.

Was die API genau liefert

Der Endpunkt liefert eine kompakte Automation-Summary. Für Node-RED ist das praktisch, weil du die Antwort einerseits direkt für einfache Flows nutzen kannst, andererseits aber genug Struktur für spätere Erweiterungen bekommst.

Zeitraum und Auflösung

Das Beispiel nutzt hours=48 und window_hours=4. Das ist ein Startpunkt, nicht die komplette Produktgrenze.

source.price.day_ahead_entries und source.price.forecast_entries zählen Slots, nicht Stunden. Deshalb können Zahlen wie 97 Day-Ahead und 0 Forecast plausibel sein, wenn der angefragte Zeitraum gerade schon fast vollständig mit veröffentlichten Day-Ahead-Werten abgedeckt ist.

Schnellstart für Copy-Paste

1. In Node-RED oben rechts auf Import klicken.
2. Den kompletten JSON-Block unten einfügen.
3. Importieren und danach auf Deploy klicken.
4. Die Debug-Seitenleiste öffnen und den Inject-Knopf einmal manuell auslösen.

Import-Flow für Node-RED

Den gesamten Block kopieren und in Node-RED importieren. Wenn du keinen API-Key hast, bleibt der String im Function-Node einfach leer.

[
  {
    "id": "epf_tab",
    "type": "tab",
    "label": "StrompreisVorhersage",
    "disabled": false,
    "info": ""
  },
  {
    "id": "epf_inject",
    "type": "inject",
    "z": "epf_tab",
    "name": "Jetzt laden",
    "props": [],
    "repeat": "900",
    "once": true,
    "onceDelay": "1",
    "topic": "",
    "x": 120,
    "y": 120,
    "wires": [["epf_auth"]]
  },
  {
    "id": "epf_auth",
    "type": "function",
    "z": "epf_tab",
    "name": "API-Key optional",
    "func": "const API_KEY = \"\";\\nmsg.headers = {};\\nif (API_KEY.trim()) {\\n    msg.headers.Authorization = \"Bearer \" + API_KEY.trim();\\n}\\nreturn msg;",
    "outputs": 1,
    "noerr": 0,
    "initialize": "",
    "finalize": "",
    "libs": [],
    "x": 340,
    "y": 120,
    "wires": [["epf_http"]]
  },
  {
    "id": "epf_http",
    "type": "http request",
    "z": "epf_tab",
    "name": "Summary abrufen",
    "method": "GET",
    "ret": "obj",
    "paytoqs": "ignore",
    "url": "https://api.energypriceforecast.eu/api/v1/node-red/summary?country=de&hours=48&window_hours=4",
    "persist": false,
    "x": 570,
    "y": 120,
    "wires": [["epf_extract"]]
  },
  {
    "id": "epf_extract",
    "type": "function",
    "z": "epf_tab",
    "name": "Wichtige Felder setzen",
    "func": "const data = msg.payload || {};\\nconst flat = data.flat || {};\\nconst meta = data.meta || {};\\nconst price = data.price || {};\\nconst co2 = data.co2 || {};\\n\\nmsg.current_price = flat.current_price;\\nmsg.current_co2_g_kwh = flat.current_co2_g_kwh;\\nmsg.cheapest_window_start = flat.cheapest_window_start || null;\\nmsg.greenest_window_start = flat.greenest_window_start || null;\\nmsg.is_cheapest_window_now = flat.is_cheapest_window_now === true;\\nmsg.cheapest_window_remaining_minutes = flat.cheapest_window_remaining_minutes ?? null;\\nmsg.next_full_cheapest_window_start = price.next_full_window ? price.next_full_window.start : null;\\nmsg.is_greenest_window_now = flat.is_greenest_window_now === true;\\nmsg.next_full_greenest_window_start = co2.next_full_window ? co2.next_full_window.start : null;\\nmsg.api_key_state = meta.api_key_state || 'missing';\\nmsg.allowed_horizon_hours = meta.allowed_horizon_hours;\\nmsg.used_horizon_hours = meta.used_horizon_hours;\\nmsg.rate_limit_daily = meta.rate_limit_daily;\\nmsg.used_calls_today = meta.used_calls_today;\\n\\nif (msg.statusCode === 401) {\\n    msg.error = '401: API-Key fehlt, ist ungültig oder wurde deaktiviert.';\\n} else if (msg.statusCode === 403) {\\n    msg.error = '403: Zugriff für Route, Markt oder Vertragszustand nicht erlaubt.';\\n} else if (msg.statusCode === 429) {\\n    msg.error = '429: Tageslimit erreicht.';\\n} else {\\n    msg.error = null;\\n}\\n\\nreturn msg;",
    "outputs": 1,
    "noerr": 0,
    "initialize": "",
    "finalize": "",
    "libs": [],
    "x": 830,
    "y": 120,
    "wires": [["epf_debug"]]
  },
  {
    "id": "epf_debug",
    "type": "debug",
    "z": "epf_tab",
    "name": "Werte anzeigen",
    "active": true,
    "tosidebar": true,
    "console": false,
    "tostatus": false,
    "complete": "true",
    "targetType": "full",
    "x": 1070,
    "y": 120,
    "wires": []
  }
]

Danach kannst du anstelle des Debug-Knotens später eigene Logik anschließen, zum Beispiel Dashboard, Benachrichtigungen oder Scheduler-Regeln.

Für Automationen: Anzeige und Laufentscheidung trennen

Für Dashboards reicht oft msg.cheapest_window_start. Für echte Steuerung ist aber meist wichtiger, ob das beste Fenster bereits läuft. Genau dafür setzt der Flow zusätzlich msg.is_cheapest_window_now und msg.cheapest_window_remaining_minutes.

if (msg.is_cheapest_window_now) {
  // Verbraucher jetzt freigeben
} else if (msg.next_full_cheapest_window_start) {
  // nächstes vollständiges Fenster für Planung verwenden
}

return msg;

Pragmatisch: Ein Boolean für "jetzt" ist für Automationen meist wertvoller als nur ein Zeitstempel in der Zukunft.

Welche Message-Felder du danach hast

Wichtige Hinweise