Die Pipeline erfasst kontinuierlich Daten von:

    • OpenSky-Netzwerk für lebende Flugzeugzustände
    • Open-Meteo für globale Wetterschnappschüsse
    • USGS-Erdbebengefahrenprogramm für seismische Ereignisse in Echtzeit

    Alle 5 Minuten werden die Streams aggregiert und nach geografischen Gitterzellen zusammengefügt, um eine zu generieren zusammengesetzter Risikoscore bezogen auf:

    • Flugverkehrsdichte
    • Erdbebenstärke
    • Wetterbedingungen

    Ziel ist es, durch die Zusammenführung mehrerer unabhängiger Echtzeitquellen in einer Visualisierung eine globale Live-Ansicht der luftfahrtbezogenen Umweltrisiken bereitzustellen.

    Verwendete Werkzeuge: Python, Quix Streams, Redpanda, PostgreSQL/PostGIS, Supabase, Bruin, Streamlit, Terraform, Docker

    Datenquellen: OpenSky Network, Open-Meteo, USGS Earthquake Hazards Program, OpenFlights

    GitHub-Repo: https://github.com/aletbm/SkyPulse-Streaming-Pipeline

    Live-Dashboard: https://skypulse-streaming-pipeline.streamlit.app

    Notiz: Das Live-Dashboard ist derzeit offline/zeigt veraltete Daten an, da die Cloud-Dienste pausiert wurden, um laufende Infrastrukturkosten zu vermeiden, aber die vollständige Implementierung und Architektur sind im Repository verfügbar.

    Von AleTBM

    Share.

    1 Kommentar

    Leave A Reply