Jahresrückblick 2025 – unser neuer Blogbeitrag ist online! ✨

[Hotze]

Hallo Zusammen,

als ich heute morgen im Stau stand habe ich mich natürlich wieder geärgert!
Ich habe einige Adapter mit verschiedenen API-Keys getestet und manche laufen dann aus und geht wieder nichts mehr.
Dann habe ich mich selber daran gemacht ein Script zu entwickeln. Einen Adapter schreiben kann ich nicht, Respekt an alle die das können.
Aber ich kann mein Script zur Verfügung stellen!
Dabei nehme ich die von uns allen bezahlten und bereitgestellten Daten und vergleiche die Koordinaten der Verkehrsmeldungen mit einem angegeben Bereich.

Wenn Jemand daraus einen Adapter machen kann wäre das natürlich super!
Auch eine Erweiterung auf mehrere Bereiche ist leicht umzusetzen

Hier die Anleitung der Autobahn App API

In meinem Script müsst Ihr unter der Konfiguration:

• Eure Autobahn angeben (Im Beispiel A45)

• Eure Telegram instanz angeben (Im Beispiel telegram.0)

• Eure ChatID angeben (Platzhalter im Script 123456789)

• Ein Koordinatenrechteck als zu überwachten Bereich erstellen:
  ** minLat: 50.6181514, // unten
  ** maxLat: 51.3742993, // oben (bis Lüdenscheid)
  ** minLon: 7.2582769, // links (bis Hagen/Dortmund)
  ** maxLon: 8.3822071 // rechts

• Im Aktuellen noch die Zeitfenster definieren

Wenn es geht nutzt bitte die aktuelle Version!

Spoiler

ALTE VERSION!

// =========================
// Konfiguration
// =========================

const roadId = "A45";  

// Bereichsdefinition (Rechteck zwischen zwei Punkten)
// minLat = südlichster Punkt (untere Grenze Breitengrad)
// maxLat = nördlichster Punkt (obere Grenze Breitengrad)
// minLon = westlichster Punkt (linke Grenze Längengrad)
// maxLon = östlichster Punkt (rechte Grenze Längengrad)
const coordsArea = {
   minLat: 50.6181514,   // unten
   maxLat: 51.3742993,   // oben (bis Lüdenscheid)
   minLon: 7.2582769,    // links (bis Hagen/Dortmund)
   maxLon: 8.3822071     // rechts
};

// Telegram-Konfiguration
const telegramInstance = "telegram.0";   // deine Telegram-Adapter-Instanz
const telegramChatId   = 123456789;      // deine Chat-ID

// API-URL
const url = `https://verkehr.autobahn.de/o/autobahn/${roadId}/services/warning`;

// =========================
// Hilfsfunktionen
// =========================

function isInArea(lat, lon, area) {
   return (
       lat >= area.minLat &&
       lat <= area.maxLat &&
       lon >= area.minLon &&
       lon <= area.maxLon
   );
}

function warningHitsArea(warning, area) {
   // Einzelpunkt-Feld "coordinate"
   if (warning.coordinate && typeof warning.coordinate.lat === "number" && typeof warning.coordinate.long === "number") {
       if (isInArea(warning.coordinate.lat, warning.coordinate.long, area)) {
           return true;
       }
   }
   // GeoJSON-Feld "geometry.coordinates" (LineString: Array von [lon, lat])
   if (warning.geometry && Array.isArray(warning.geometry.coordinates)) {
       for (const coord of warning.geometry.coordinates) {
           if (Array.isArray(coord) && coord.length >= 2) {
               const lon = coord[0];
               const lat = coord[1];
               if (isInArea(lat, lon, area)) return true;
           }
       }
   }
   return false;
}

function buildDescriptionText(descriptionField) {
   if (Array.isArray(descriptionField)) {
       return descriptionField
           .filter(d => d && String(d).trim() !== "")
           .join("\n");
   }
   return String(descriptionField || "").trim();
}

// =========================
// Hauptlogik mit Debug-Log
// =========================

async function checkTraffic() {
   try {
       console.log("Hole Daten von:", url);

       const axios = require("axios");
       const response = await axios.get(url);
       const data = response.data;

       if (!data || !Array.isArray(data.warning) || data.warning.length === 0) {
           console.log(`Keine Warnungen auf ${roadId}`);
           return;
       }

       // Debug: jede Warnung mit Koordinaten und Bereichsprüfung ausgeben
       data.warning.forEach(w => {
           const coord = w.coordinate ? `${w.coordinate.lat}, ${w.coordinate.long}` : "keine Koordinate";
           console.log(`Warnung: ${w.title} | Koordinate: ${coord} | HitsArea: ${warningHitsArea(w, coordsArea)}`);
       });

       // Nur nach Koordinatenbereich filtern
       const relevant = data.warning.filter(w => warningHitsArea(w, coordsArea));

       if (relevant.length === 0) {
           console.log(`Keine Warnungen im definierten Bereich auf ${roadId}`);
           return;
       }

       console.log(`${relevant.length} Warnung(en) im Bereich gefunden.`);

       for (const warning of relevant) {
           const descText = buildDescriptionText(warning.description);
           const msg = `⚠️ Störung auf ${roadId}:\n${warning.title}\n${descText}`;

           console.log("Sende Nachricht:", msg);
           sendTo(telegramInstance, "send", {
               chatId: telegramChatId,
               text: msg
           });
       }

   } catch (err) {
       console.error("Fehler beim Abruf:", err.message, err.stack);
       sendTo(telegramInstance, "send", {
           chatId: telegramChatId,
           text: `❌ Fehler beim Abruf der Verkehrsdaten: ${err.message}`
       });
   }
}

// alle 15 Minuten prüfen
schedule("*/15 * * * *", checkTraffic);

Ein erster Test ging gut, nun zerreißt mein Script in der Luft oder Verbessert es!

Viel Spaß und danke an alle die das Projekt "IOBroker" am Leben halten!

Tante Edit:
Code eingefügt
Beispiellink eingefügt:
https://verkehr.autobahn.de/o/autobahn/A45/services/warning

Hier ist die aktuelle Version!

[peterfido]

Auf den ersten Blick wird da nur eine Autobahn berücksichtigt und der Scheduler sind keine 15 Minuten.

Ich lasse mich immer von Google Navigieren, auch, wenn ich die Strecke kenne. Da fließen aktuellere Daten als vom Bund ein. Inkl. Empfehlung drauf bleiben, oder abfahren.

[Hotze]

Stimmt, der Timer stand noch zum testen auf einer Minute, ist korrigiert. Danke für den Hinwies!

Es wird nicht eine Autobahn überwacht! Es wird sogar nur ein Abschnitt überwacht, das ist noch weniger!

Es steht ja auch da, dass man es leicht erweitern kann, daher verstehe ich die Kritik nicht. Zumindest kommt diese bei mir nicht an.

Wenn ich für den weg zur Arbeit und nach hause gesamt eine Minute meine Route in Maps einstelle sind das über drei h pro Jahr. Und daran denken muss ich auch noch!
Praktischer ist es da schon wenn man einfach eine Nachricht bekommt.

Aber wenn ein Navi besser zu deiner Routine passt musst du das Script nicht nutzen.

[peterfido]

Es wird bestimmt der ein oder andere gebrauchen. Daher vielen Dank fürs teilen.
Mein Profil ist da anders: Android Auto ist mittlerweile soweit, dass er den Weg zur Arbeit / nach Hause vorschlägt, was dann mit einem Touch bestätigt wird.

[Rushmed]

Hallo,

vielen Dank für deine Mühe.

Habs zum Testen mal eingerichtet.

Als erstes fällt mir auf, dass ich lieber eine definierten DP mit den Infos beschreiben will.
Hintergrund ist bspw. dass ich mir morgens per Alexa Routine die Verkehrssituation ansagen lasse und dafür einen DP brauche.

[peterfido]

Dann ergänzen, welche Infos da rein sollen weiß ich nicht.

Grundsätzlich zum Triggern per Datenpunkt:

Spoiler

// Im Kopf vom Skript
const idDatenpunkt="0_userdata.0.AlexaRoutineVerkehr";

createState(idDatenpunkt, 0, false, { // Datenpunkt wird angelegt
  name: 'Verkehrsmeldung',
  desc: 'Alexa Morgenroutine',
  type: 'string',
  unit: '',
  role: 'value',
  def: "",
});
// Jetzt das Skript hier einfügen



//Nach ganz unten zu den Triggern, damit die zum besser Auffinden zusammen sind
on({id: idDatenpunkt, change:'any'}, function (dp) {
  console.log("Alexa Verkehrsroutine aufgerufen");
//  mach was mit den Daten?

  checkTraffic();
});

[peterfido]

Doppelpost und finde den Löschen-Button nicht

[Hotze]

Das ist eine gute Idee! Ich habe das mal versucht umzusetzen und noch Schalter eingebaut falls einer einen teil des Scripts nicht benötigt:

Spoiler

// =========================
// Konfiguration
// =========================

const roadId = "A45";  

// Bereichsdefinition
const coordsArea = {
   minLat: 50.6181514,
   maxLat: 51.3742993,
   minLon: 7.2582769,
   maxLon: 8.3822071
};

// Schalter
const telegramEnabled     = 1;   // 1 = Telegram senden, 0 = keine Nachrichten
const alexaEnabled        = 1;   // 1 = Alexa-Routine Trigger aktiv, 0 = ignorieren
const verkehrsstoerungDP  = 1;   // 1 = Datenpunkt "Verkehrsstörung" anlegen/befüllen, 0 = ignorieren

// Telegram-Konfiguration
const telegramInstance = "telegram.0";   // deine Telegram-Adapter-Instanz
const telegramChatId   = 123456789;      // deine Chat-ID

// Alexa-Routine Datenpunkt
const idDatenpunkt = "0_userdata.0.AlexaRoutineVerkehr";

// Datenpunkt nur anlegen, wenn Schalter aktiv ist
if (verkehrsstoerungDP === 1) {
   createState(idDatenpunkt, "", false, {
     name: 'Verkehrsmeldung',
     desc: 'Alexa Morgenroutine',
     type: 'string',
     unit: '',
     role: 'value',
     def: ""
   });
}

// API-URL
const url = `https://verkehr.autobahn.de/o/autobahn/${roadId}/services/warning`;

// =========================
// Hilfsfunktionen
// =========================

function isInArea(lat, lon, area) {
   return (
       lat >= area.minLat &&
       lat <= area.maxLat &&
       lon >= area.minLon &&
       lon <= area.maxLon
   );
}

function warningHitsArea(warning, area) {
   if (warning.coordinate && typeof warning.coordinate.lat === "number" && typeof warning.coordinate.long === "number") {
       if (isInArea(warning.coordinate.lat, warning.coordinate.long, area)) {
           return true;
       }
   }
   if (warning.geometry && Array.isArray(warning.geometry.coordinates)) {
       for (const coord of warning.geometry.coordinates) {
           if (Array.isArray(coord) && coord.length >= 2) {
               const lon = coord[0];
               const lat = coord[1];
               if (isInArea(lat, lon, area)) return true;
           }
       }
   }
   return false;
}

function buildDescriptionText(descriptionField) {
   if (Array.isArray(descriptionField)) {
       return descriptionField
           .filter(d => d && String(d).trim() !== "")
           .join("\n");
   }
   return String(descriptionField || "").trim();
}

// =========================
// Hauptlogik
// =========================

async function checkTraffic() {
   try {
       console.log("Hole Daten von:", url);

       const axios = require("axios");
       const response = await axios.get(url);
       const data = response.data;

       const warnings = data.warnings || data.warning;

       if (!warnings || !Array.isArray(warnings) || warnings.length === 0) {
           console.log(`Keine Warnungen auf ${roadId}`);
           if (verkehrsstoerungDP === 1) setState(idDatenpunkt, "Keine Warnungen auf " + roadId);
           return;
       }

       const relevant = warnings.filter(w => warningHitsArea(w, coordsArea));

       if (relevant.length === 0) {
           console.log(`Keine Warnungen im definierten Bereich auf ${roadId}`);
           if (verkehrsstoerungDP === 1) setState(idDatenpunkt, "Keine Warnungen im Bereich auf " + roadId);
           return;
       }

       console.log(`${relevant.length} Warnung(en) im Bereich gefunden.`);

       let summary = "";
       for (const warning of relevant) {
           const descText = buildDescriptionText(warning.description);
           const msg = `⚠️ Störung auf ${roadId}:\n${warning.title}\n${descText}`;
           summary += msg + "\n\n";

           if (telegramEnabled === 1) {
               console.log("Sende Nachricht:", msg);
               sendTo(telegramInstance, "send", {
                   chatId: telegramChatId,
                   text: msg
               });
           }
       }

       if (verkehrsstoerungDP === 1) {
           setState(idDatenpunkt, summary.trim());
       }

   } catch (err) {
       console.error("Fehler beim Abruf:", err.message, err.stack);
       if (telegramEnabled === 1) {
           sendTo(telegramInstance, "send", {
               chatId: telegramChatId,
               text: `❌ Fehler beim Abruf der Verkehrsdaten: ${err.message}`
           });
       }
       if (verkehrsstoerungDP === 1) {
           setState(idDatenpunkt, "Fehler beim Abruf der Verkehrsdaten");
       }
   }
}

// =========================
// Trigger
// =========================

// alle 15 Minuten prüfen
schedule("*/15 * * * *", checkTraffic);

// Trigger für Alexa-Routine nur wenn aktiviert
if (alexaEnabled === 1 && verkehrsstoerungDP === 1) {
   on({id: idDatenpunkt, change:'any'}, function (dp) {
     console.log("Alexa Verkehrsroutine aufgerufen");
     checkTraffic();
   });
}

Da ich keine Alexa habe kann ich es nicht testen! Somit muss das von jemand anderem verfeinert werden ;-)
Damit die Alexa direkt vorlesen kann ist es ein einfacher Text.
Hier ein Beispieltext Mit zwei Meldungen in einem Bereich:

Spoiler

⚠️ Störung auf A45:
A45 | Lüdenscheid - Lüdenscheid
Beginn: 16.12.25 um 10:27 Uhr
Im Stillstand
Durchschnittsgeschwindigkeit: 3 km/h

⚠️ Störung auf A45:
A45 | Schwerte-Ergste - Dortmund-Süd
Beginn: 16.12.25 um 09:45 Uhr
Langsamer Verkehr
Reisezeitverlust: 2 Minuten
Durchschnittsgeschwindigkeit: 40 km/h

[peterfido]

Ich habe noch nie ein if() vor ein on() gesetzt. Immer erst das on() und dann if(), wenn nötig. Den Datenpunkt legt man immer an, bzw. wird der einmalig angelegt, wenn es ihn noch nicht gibt. Ich sehe da noch mehr Optimierungsmöglichkeiten.

[Hotze]

Wenn es dir nichts aus macht dann poste den verbesserten Code einfach!
Für mich reicht ja die Warnung! Ich finde toll dass du dir das so genau anschaust!

Falls das Script, oder ein Teil davon, nur einem hilft haben wir alles richtig gemacht also:
Immer her mit den "Optimierungsmöglichkeiten"!

[peterfido]

Coden macht am kleinen Mäusekino keinen Spaß. Für meinen Auszug oben habe ich mir heute morgen schon fast einen abgebrochen. ;)

[peterfido]

Ich habe mal ChatGPT und Gemini gebeten, den Code zu optimieren. Die haben zwar hier und da was verbessert, die beiden if() an der falschen Stelle jedoch auch nicht korrigiert.

Somit warten, bis ich am größeren Rechner sitze, jemand anderes mir zuvorkommt, oder selbst noch mal kritisch drüberschauen und korrigieren.

[Hotze]

Der Gedanke ist:
Der Listener "on()" wird nur angelegt, wenn die Bedingung erfüllt ist.
Das heißt: wenn alexaEnabled oder verkehrsstoerungDP auf 0 stehen, existiert der Trigger gar nicht.
Also keine unnötigen Listener im System.
Falls jemand später die Schalter im laufenden Betrieb ändert, wird der Trigger nicht automatisch neu angelegt, weil das if nur beim Start des Skripts ausgewertet wird. Das macht doch kaum einer, oder?

Andere Variante:

on({id: idDatenpunkt, change:'any'}, function (dp) {
  if (alexaEnabled === 1 && verkehrsstoerungDP === 1) {
    console.log("Alexa Verkehrsroutine aufgerufen");
    checkTraffic();
  }
});

Hier wird der Listener immer angelegt, aber er macht nur etwas, wenn die Schalter aktiv sind.
flexibler, weil man die Schalter auch zur Laufzeit ändern kann.
Aber es hängt immer ein Listener am Datenpunkt, auch wenn du ihn eigentlich gar nicht brauchst.

Meintest du das?

[peterfido]

Ja, genau. Und createState gehört nicht in ein if() Konstrukt.

[Hotze]

Wenn der Datenpunkt nicht benötigt wird (const verkehrsstoerungDP = 0), wird er nicht angelegt. Ansonsten läge ein toter Datenpunkt herum.
Mir war nicht bewusst was es für Regeln gibt! Bisher war ich der Auffassung: Wer trifft hat recht!
Aber wie gesagt: einfach ändern und posten, dann kann jeder das für sich passende raus suchen und man hat eine Versionierung nach Datum.
Frei nach dem Motto: "Teste mal das script aus Antwort #8!"

[peterfido]

OK, verstehe. Du meinst, wenn ein Anwender ohne Datenpunkte arbeiten will, soll es Ressourcen sparen. Ob ein Eventlistener hinter einem if() läuft, habe ich nie probiert. Vielleicht können die Profis hier was dazu sagen.

[Rushmed]

@peterfido @hotze

Vielen Dank für die Ergänzugen.
Das mit Alexa war nur ein Besispiel. Der Datenpunkt und die Kommentare im Script sollen keinen Alexa Bezug haben. Ein selbst wählbarer DP der als Wert die Staumeldungen für meinen definierten Bereich enthält reich völlig. Damit kann ich dann umgehen und würde auch die Telegram Integration im JS Adapter erledigen.

Ich weiß nicht welche infos in den DP sollen. Seit Testbeginn hatte ich wohl noch keine Störung auf der gewählten AB im gewählten Bereich.
Logmeldungen erscheinen schonmal:

javascript.0
2025-12-18 21:00:00.174	info	script.js.aaa_Staumelder: Keine Warnungen im definierten Bereich auf A4

javascript.0
2025-12-18 21:00:00.174	info	script.js.aaa_Staumelder: Warnung: A4 | Görlitz - Görlitz | Koordinate: 51.19872170096459, 14.960901000619456 | HitsArea: false

javascript.0
2025-12-18 21:00:00.174	info	script.js.aaa_Staumelder: Warnung: A4 | Kodersdorf - Ludwigsdorf | Koordinate: 51.19872170096459, 14.960901000619456 | HitsArea: false

javascript.0
2025-12-18 21:00:00.173	info	script.js.aaa_Staumelder: Warnung: A4 | Königshainer Berge - Königshainer Berge | Koordinate: 51.203233847771706, 14.759957057504197 | HitsArea: false

javascript.0
2025-12-18 21:00:00.173	info	script.js.aaa_Staumelder: Warnung: A4 | Nieder Seifersdorf - Königshainer Berge | Koordinate: 51.2032281716645, 14.760124784338583 | HitsArea: false

javascript.0
2025-12-18 21:00:00.172	info	script.js.aaa_Staumelder: Warnung: A4 | Willrodaer Forst - Erfurt-Vieselbach | Koordinate: 50.925375315043865, 11.136412592086435 | HitsArea: false

javascript.0
2025-12-18 21:00:00.170	info	script.js.aaa_Staumelder: Warnung: A4 | Bad Hersfeld - Friedewald | Koordinate: 50.85349478866353, 9.722682387354707 | HitsArea: false

javascript.0
2025-12-18 21:00:00.028	info	script.js.aaa_Staumelder: Hole Daten von:

Sieht plausiebel aus.

Sind die Logdaten alle die verfügbar sind? Interessant wäre die Verzögerung durch das jeweilige Ereignis und evtl. dass man die Richtung differenzieren kann. Hierfür wäre ein Zweiter DP oder generell die Ausgbe als JSON vorstellbar.

[matze55]

Interesserhalber...zeig mal nen video..oder bilder (wenn verfügbar).....obwohl ich keine Rennbahn habe.
Was mit dem Iobroker möglich ist...staune

[Rushmed]

Bin ich gemeint?

[bahnuhr]

@Hotze sagte in #Stauerkennung #DieAutobahn:

In meinem Script

Wo ist das Script ?

Oder sehe ich es nur nicht. ;-)