Strompreis und CO2 in ioBroker einbinden, ohne eigenen Adapter zu bauen

Wichtige Logik früh erklärt

Die Preislogik ist nicht „nur Forecast“. Sie arbeitet bewusst in zwei Schritten, damit echte Marktdaten bevorzugt werden.

Empfohlener Endpunkt

Für ioBroker gibt es einen eigenen Summary-Pfad. Er liefert die kompakten Felder, die für erste Automationen meist reichen, plus Meta-Felder für Limits und Key-Status.

Alternative für eigene Preislogik

Wenn du nicht mit der kompakten Summary arbeiten willst, gibt es zusätzlich einen zweiten ioBroker-Pfad nur für die Preisreihe. Der ist eher für fortgeschrittene Nutzer gedacht, die eigene Fensterlogik, Charts oder Preisregeln in JavaScript bauen wollen.

Was die API genau liefert

Der Endpunkt liefert eine allgemeine Automation-Summary. Für ioBroker ist das gut, weil du nicht auf einen festen Spezialadapter festgelegt bist und dieselben Daten auch in eigenen Skripten oder Visualisierungen weiterverwenden kannst.

Wenn du statt der Summary eine echte Preisreihe für eigene Berechnungen brauchst, nutze den separaten Pfad /api/v1/iobroker/prices. Die Summary bleibt bewusst beim kompakten Basispreis. Der Preisreihen-Pfad liefert standardmäßig ebenfalls Basispreise, kann jetzt aber optional auch annahmenbasierte Retail-/Gesamtpreise liefern.

Preisreihe für eigene Skripte: iobroker/prices

Der zusätzliche Preisreihen-Pfad liefert bewusst nur Preise, keine CO2-Felder und keine fertige Fensterlogik. Genau das ist der Sinn: Du kannst in ioBroker selbst entscheiden, wie du günstige Zeitfenster, Schwellwerte oder Visualisierungen bauen willst.

https://api.energypriceforecast.eu/api/v1/iobroker/prices?country=de&hours=48&mode=mixed&resolution=15m

https://api.energypriceforecast.eu/api/v1/iobroker/prices?country=de&hours=48&mode=mixed&resolution=15m&price_mode=retail&plz=10115

Wichtig: Im 15m-Modus werden Forecast-Werte nicht zwischen zwei Stunden geglättet. Die API erfindet also keine Zwischenpreise, sondern markiert sauber, dass diese Viertelstunden aus einem stündlichen Forecast-Block stammen.

Basispreis oder Gesamtpreis?

Die ioBroker-summary liefert weiterhin bewusst Basis- bzw. Marktpreise. Der Pfad prices liefert standardmäßig ebenfalls Basispreise, kann aber jetzt optional auch annahmenbasierte Retail-/Gesamtpreise ausgeben.

Zeitraum und Auflösung

Das Beispiel nutzt hours=48 und window_hours=4. Das ist ein sinnvoller Einstieg, aber nicht die einzige mögliche Einstellung.

Wichtig: source.price.day_ahead_entries und source.price.forecast_entries zählen Slots, nicht Stunden. Deshalb können Werte wie 97 Day-Ahead und 0 Forecast plausibel sein, wenn der angefragte Zeitraum gerade fast vollständig durch veröffentlichte Day-Ahead-Slots abgedeckt wird.

Schnellstart für Copy-Paste

1. Im ioBroker Admin den JavaScript-Adapter öffnen.
2. Ein neues JavaScript-Skript anlegen.
3. Den kompletten Block unten einfügen und speichern.
4. Einmal manuell starten oder kurz warten. Danach sollten neue States unter 0_userdata.0.energypriceforecast sichtbar sein.

Fertiges Skript für den JavaScript-Adapter

Das Skript holt die Daten sofort beim Start und danach standardmäßig alle 30 Minuten neu. Das ist ein sinnvoller Standard für viele Setups: Day-Ahead ändert sich nicht ständig, aber aktueller Slot, laufende Fenster und der Forecast-Kontext bewegen sich trotzdem weiter. Wenn du keinen API-Key hast, bleibt API_KEY einfach leer.

const axios = require("axios");

const COUNTRY = "de";
const API_KEY = "";
const API_URL = "https://api.energypriceforecast.eu/api/v1/iobroker/summary?country=" + COUNTRY + "&hours=48&window_hours=4";
const ROOT = "0_userdata.0.energypriceforecast";
const POLL_MS = 30 * 60 * 1000;

const STATE_DEFINITIONS = [
  [".current_price", 0, { name: "Aktueller Preis", type: "number", role: "value", unit: "EUR/kWh", read: true, write: false }],
  [".current_co2_g_kwh", 0, { name: "Aktuelle CO2-Intensität", type: "number", role: "value", unit: "gCO2/kWh", read: true, write: false }],
  [".cheapest_window_start", "", { name: "Günstigstes Fenster Start", type: "string", role: "text", read: true, write: false }],
  [".greenest_window_start", "", { name: "Grünstes Fenster Start", type: "string", role: "text", read: true, write: false }],
  [".is_cheapest_window_now", false, { name: "Bestes Preisfenster läuft jetzt", type: "boolean", role: "indicator", read: true, write: false }],
  [".cheapest_window_remaining_minutes", 0, { name: "Bestes Preisfenster Restlaufzeit", type: "number", role: "value.interval", unit: "min", read: true, write: false }],
  [".next_full_cheapest_window_start", "", { name: "Nächstes vollständiges Preisfenster", type: "string", role: "text", read: true, write: false }],
  [".is_greenest_window_now", false, { name: "Bestes CO2-Fenster läuft jetzt", type: "boolean", role: "indicator", read: true, write: false }],
  [".api_key_state", "missing", { name: "API-Key-Status", type: "string", role: "text", read: true, write: false }],
  [".allowed_horizon_hours", 0, { name: "Erlaubter Horizont", type: "number", role: "value", unit: "h", read: true, write: false }],
  [".used_horizon_hours", 0, { name: "Verwendeter Horizont", type: "number", role: "value", unit: "h", read: true, write: false }],
  [".rate_limit_daily", 0, { name: "Tageslimit", type: "number", role: "value", read: true, write: false }],
  [".used_calls_today", 0, { name: "Verbrauchte Calls heute", type: "number", role: "value", read: true, write: false }],
  [".last_update", "", { name: "Letztes Update", type: "string", role: "text", read: true, write: false }],
  [".last_error", "", { name: "Letzter Fehler", type: "string", role: "text", read: true, write: false }]
];

STATE_DEFINITIONS.forEach(([suffix, initialValue, definition]) => {
  createState(ROOT + suffix, initialValue, definition);
});

function setTextState(suffix, value) {
  setState(ROOT + suffix, value == null ? "" : String(value), true);
}

function setNumberState(suffix, value, digits) {
  if (!Number.isFinite(value)) {
    return;
  }

  const normalized = typeof digits === "number" ? Number(value.toFixed(digits)) : Number(value);
  setState(ROOT + suffix, normalized, true);
}

function setBooleanState(suffix, value) {
  if (typeof value !== "boolean") {
    return;
  }

  setState(ROOT + suffix, value, true);
}

async function updateEnergyPriceForecast() {
  const headers = {};

  if (API_KEY.trim()) {
    headers.Authorization = "Bearer " + API_KEY.trim();
  }

  try {
    const response = await axios.get(API_URL, {
      timeout: 10000,
      headers
    });

    const data = response.data || {};
    const flat = data.flat || {};
    const meta = data.meta || {};

    setNumberState(".current_price", flat.current_price, 4);
    setNumberState(".current_co2_g_kwh", flat.current_co2_g_kwh, 1);
    setTextState(".cheapest_window_start", flat.cheapest_window_start);
    setTextState(".greenest_window_start", flat.greenest_window_start);
    setBooleanState(".is_cheapest_window_now", flat.is_cheapest_window_now);
    setNumberState(".cheapest_window_remaining_minutes", flat.cheapest_window_remaining_minutes);
    setTextState(".next_full_cheapest_window_start", data.price && data.price.next_full_window ? data.price.next_full_window.start : null);
    setBooleanState(".is_greenest_window_now", flat.is_greenest_window_now);
    setTextState(".api_key_state", meta.api_key_state || (API_KEY.trim() ? "unknown" : "missing"));
    setNumberState(".allowed_horizon_hours", meta.allowed_horizon_hours);
    setNumberState(".used_horizon_hours", meta.used_horizon_hours);
    setNumberState(".rate_limit_daily", meta.rate_limit_daily);
    setNumberState(".used_calls_today", meta.used_calls_today);
    setTextState(".last_update", data.generated_at);
    setTextState(".last_error", "");
  } catch (error) {
    const statusCode = error && error.response ? error.response.status : null;
    const errorData = error && error.response ? error.response.data || {} : {};
    const errorMeta = errorData.meta || {};

    setTextState(".api_key_state", errorMeta.api_key_state || (API_KEY.trim() ? "error" : "missing"));

    if (statusCode === 401) {
      setTextState(".last_error", "401: API-Key fehlt, ist ungültig oder wurde deaktiviert.");
    } else if (statusCode === 403) {
      setTextState(".last_error", "403: Zugriff für Route, Markt oder Vertragszustand nicht erlaubt.");
    } else if (statusCode === 429) {
      setTextState(".last_error", "429: Tageslimit erreicht.");
    } else {
      setTextState(".last_error", "Abruf fehlgeschlagen.");
    }

    console.error("StrompreisVorhersage Fehler:", statusCode, error && error.message ? error.message : error);
  }
}

updateEnergyPriceForecast();
setInterval(updateEnergyPriceForecast, POLL_MS);

Wenn du lieber einen anderen Markt willst, ändere nur COUNTRY. Für Dänemark immer dk1 oder dk2 verwenden. Wenn du bewusst häufiger pollen willst, ändere POLL_MS selbst. Der Standardwert ist absichtlich zurückhaltend gewählt.

Wo der API-Key eingetragen wird

Der Key kommt direkt in die Variable API_KEY. Wenn du einen Test-Key bekommen hast, kannst du gleichzeitig den angefragten Horizont in der URL höher setzen, zum Beispiel auf 120 Stunden.

const API_KEY = "DEIN_TEST_KEY";
const API_URL = "https://api.energypriceforecast.eu/api/v1/iobroker/summary?country=de&hours=120&window_hours=4";

Wichtig: Maßgeblich ist am Ende nicht nur die URL, sondern meta.allowed_horizon_hours. Daran siehst du, was dein aktueller Zugriff serverseitig wirklich darf.

Für Automationen: jetzt laufen oder später planen

Ein häufiger Fehler ist, nur auf cheapest_window_start zu schauen. Das reicht für Anzeige, ist aber für echte Steuerung oft zu grob. Mit is_cheapest_window_now erkennst du direkt, ob das beste Preisfenster bereits aktiv ist. Mit next_full_cheapest_window_start planst du das nächste vollständige Zukunftsfenster.

on({ id: ROOT + ".is_cheapest_window_now", change: "any" }, obj => {
  if (obj.state.val === true) {
    log("Bestes Preisfenster läuft jetzt.");
    // Wallbox freigeben oder Auto-Laden starten
  }
});

Pragmatisch gedacht: Für Wallbox, Wärmepumpe oder Speicher ist ein Boolean für "jetzt" robuster als nur eine einzelne Startzeit in die Zukunft zu vergleichen.

Welche States das Skript anlegt

Fehlerfälle und Limits