BAFU Hydro       _{Switzerland — ~300 stations, FOEN}

🌍	Region	Switzerland — ~300 stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Switzerland — ~300 stations, FOEN

_{📍 keyed by {station_id}   ·   📦 events Station, WaterLevelObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ hydrodaten.admin.ch}

 Canada ECCC Water Office       _{Canada — ~2,100 hydrometric stations, ECCC/WSC}

🌍	Region	Canada — ~2
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	stations/{station_number}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Canada — ~2,100 hydrometric stations, ECCC/WSC

_{📍 keyed by stations/{station_number}   ·   📦 events Station, Observation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ wateroffice.ec.gc.ca}

 CDEC Reservoirs       _{California — ~2,600 stations, DWR}

🌍	Region	California — ~2
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}/{sensor_num}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

California — ~2,600 stations, DWR

_{📍 keyed by {station_id}/{sensor_num}   ·   📦 events ReservoirReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ cdec.water.ca.gov}

 CHMI Hydro       _{Czech Republic — CHMU}

🌍	Region	Czech Republic — CHMU
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Czech Republic — CHMU

_{📍 keyed by {station_id}   ·   📦 events Station, WaterLevelObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ chmi.cz}

 German Waters       _{Germany — 12 state portals, ~2,724 stations}

🌍	Region	Germany — 12 state portals
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Germany — 12 state portals, ~2,724 stations

_{📍 keyed by {station_id}   ·   📦 events Station, WaterLevelObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ hvz.lubw.baden-wuerttemberg.de}

 Hub'Eau Hydrometrie       _{France — ~6,300 stations}

🌍	Region	France — ~6
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{code_station}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

France — ~6,300 stations

_{📍 keyed by {code_station}   ·   📦 events Station, Observation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ hubeau.eaufrance.fr}

 IMGW Hydro       _{Poland — IMGW-PIB}

🌍	Region	Poland — IMGW-PIB
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Poland — IMGW-PIB

_{📍 keyed by {station_id}   ·   📦 events Station, WaterLevelObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ imgw.pl}

 Ireland OPW Water Level       _{Ireland — ~500 OPW hydrometric stations}

🌍	Region	Ireland — ~500 OPW hydrometric stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_ref}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Ireland — ~500 OPW hydrometric stations

_{📍 keyed by {station_ref}   ·   📦 events Station, WaterLevelReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ waterlevel.ie}

 King County Marine       _{Washington State / Puget Sound — buoy and mooring telemetry}

🌍	Region	Washington State / Puget Sound — buoy and mooring telemetry
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Washington State / Puget Sound — buoy and mooring telemetry

_{📍 keyed by {station_id}   ·   📦 events Station, WaterQualityReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ green2.kingcounty.gov}

 Nepal BIPAD Hydrology       _{Nepal — Himalayan river basins, BIPAD}

🌍	Region	Nepal — Himalayan river basins
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Nepal — Himalayan river basins, BIPAD

_{📍 keyed by {station_id}   ·   📦 events RiverStation, WaterLevelReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ bipadportal.gov.np}

 NOAA NDBC       _{United States — buoy observations}

🌍	Region	United States — buoy observations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	9 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — buoy observations

_{📍 keyed by {station_id}   ·   📦 events BuoyObservation, BuoyStation, BuoySolarRadiationObservation, BuoyOceanographicObservation, BuoyDartMeasurement, BuoyContinuousWindObservation, BuoySupplementalMeasurement, BuoyDetailedWaveSummary, BuoyHourlyRainMeasurement}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ ndbc.noaa.gov}

 NOAA Tides & Currents       _{United States — ~3,000 stations}

🌍	Region	United States — ~3
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	13 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — ~3,000 stations

_{📍 keyed by {station_id}   ·   📦 events WaterLevel, Predictions, AirPressure, AirTemperature, WaterTemperature, Wind, Humidity, Conductivity, Salinity, Station, Visibility, Currents, CurrentPredictions}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ tidesandcurrents.noaa.gov}

 NVE Hydro       _{Norway — NVE (requires free API key)}

🌍	Region	Norway — NVE (requires free API key)
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Norway — NVE (requires free API key)

_{📍 keyed by {station_id}   ·   📦 events Station, WaterLevelObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ nve.no}

 Pegelonline       _{Germany — federal waterways, ~3,000 stations}

🌍	Region	Germany — federal waterways
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Germany — federal waterways, ~3,000 stations

_{📍 keyed by {station_id}   ·   📦 events Station, CurrentMeasurement}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ pegelonline.wsv.de}

 RWS Waterwebservices       _{Netherlands — ~785 stations}

🌍	Region	Netherlands — ~785 stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_code}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Netherlands — ~785 stations

_{📍 keyed by {station_code}   ·   📦 events Station, WaterLevelObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ waterinfo.rws.nl}

 SMHI Hydro       _{Sweden — SMHI}

🌍	Region	Sweden — SMHI
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Sweden — SMHI

_{📍 keyed by {station_id}   ·   📦 events Station, DischargeObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ smhi.se}

 SNOTEL Snow       _{Western US & Alaska — ~900 snowpack stations, NRCS}

🌍	Region	Western US & Alaska — ~900 snowpack stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_triplet}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Western US & Alaska — ~900 snowpack stations, NRCS

_{📍 keyed by {station_triplet}   ·   📦 events Station, SnowObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ nrcs.usda.gov}

 SYKE Hydro       _{Finland — SYKE}

🌍	Region	Finland — SYKE
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Finland — SYKE

_{📍 keyed by {station_id}   ·   📦 events Station, WaterLevelObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ syke.fi}

 UK EA Flood Monitoring       _{England — ~4,000 stations}

🌍	Region	England — ~4
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_reference}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

England — ~4,000 stations

_{📍 keyed by {station_reference}   ·   📦 events Station, Reading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ environment.data.gov.uk}

 USGS Instantaneous Values       _{United States — ~1.5M stations}

🌍	Region	United States — ~1.5M stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{agency_cd}/{site_no}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — ~1.5M stations

_{📍 keyed by {agency_cd}/{site_no}   ·   📦 events Site}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ waterdata.usgs.gov}

 USGS NWIS Water Quality       _{United States — ~3,000 continuous WQ sites}

🌍	Region	United States — ~3
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{site_number}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — ~3,000 continuous WQ sites

_{📍 keyed by {site_number}   ·   📦 events MonitoringSite}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ waterdata.usgs.gov}

 Waterinfo VMM       _{Belgium / Flanders — ~1,785 stations}

🌍	Region	Belgium / Flanders — ~1
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_no}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Belgium / Flanders — ~1,785 stations

_{📍 keyed by {station_no}   ·   📦 events Station, WaterLevelReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ waterinfo.be}

 AviationWeather.gov       _{Global — METAR, SIGMET advisories}

🌍	Region	Global — METAR
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{icao_id}
📦	Events	3 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — METAR, SIGMET advisories

_{📍 keyed by {icao_id}   ·   📦 events Station, Metar, Sigmet}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ aviationweather.gov}

 Blitzortung       _{Global — community lightning strokes, seconds latency}

🌍	Region	Global — community lightning strokes
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{source_id}/{stroke_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — community lightning strokes, seconds latency

_{📍 keyed by {source_id}/{stroke_id}   ·   📦 events LightningStroke}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ blitzortung.org}

 BOM Australia       _{Australia — ~8 capital city airports, half-hourly obs}

🌍	Region	Australia — ~8 capital city airports
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_wmo}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Australia — ~8 capital city airports, half-hourly obs

_{📍 keyed by {station_wmo}   ·   📦 events Station, WeatherObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ bom.gov.au}

 DMI       _{Denmark — DMI observation triad (metObs + oceanObs + lightning)}

🌍	Region	Denmark — DMI observation triad (metObs + oceanObs + lightning)
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	n/a
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Denmark — DMI observation triad (metObs + oceanObs + lightning)

_{📍 keyed by n/a   ·   📦 events MetObsStation, MetObsObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ dmi.dk}

 DWD       _{Germany — ~1,450 stations, observations and CAP alerts}

🌍	Region	Germany — ~1
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	8 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Germany — ~1,450 stations, observations and CAP alerts

_{📍 keyed by {station_id}   ·   📦 events StationMetadata, AirTemperature10Min, Precipitation10Min, Wind10Min, Solar10Min, HourlyObservation, ExtremeWind10Min, ExtremeTemperature10Min}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ dwd.de}

 DWD Pollenflug       _{Germany — daily pollen forecasts, 27 regions}

🌍	Region	Germany — daily pollen forecasts
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{region_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Germany — daily pollen forecasts, 27 regions

_{📍 keyed by {region_id}   ·   📦 events Region, PollenForecast}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ dwd.de}

 Environment Canada       _{Canada — ~963 SWOB stations, hourly obs}

🌍	Region	Canada — ~963 SWOB stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{msc_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Canada — ~963 SWOB stations, hourly obs

_{📍 keyed by {msc_id}   ·   📦 events Station, WeatherObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ weather.gc.ca}

 GeoSphere Austria       _{Austria — ~280 TAWES stations, 10-min obs}

🌍	Region	Austria — ~280 TAWES stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Austria — ~280 TAWES stations, 10-min obs

_{📍 keyed by {station_id}   ·   📦 events WeatherStation, WeatherObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ geosphere.at}

 HKO Hong Kong       _{Hong Kong — 27 temp stations, 18 rainfall districts}

🌍	Region	Hong Kong — 27 temp stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{place_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Hong Kong — 27 temp stations, 18 rainfall districts

_{📍 keyed by {place_id}   ·   📦 events Station, WeatherObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ hko.gov.hk}

 JMA Bosai AMeDAS       _{Japan — ~1,300 AMeDAS stations, 10-min observations via Bosai JSON API}

🌍	Region	Japan — ~1
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	jp.jma.amedas/{station_code}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Japan — ~1,300 AMeDAS stations, 10-min observations via Bosai JSON API

_{📍 keyed by jp.jma.amedas/{station_code}   ·   📦 events Station, Observation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ jma.go.jp}

 JMA Japan       _{Japan — weather bulletins, warnings, forecasts}

🌍	Region	Japan — weather bulletins
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{bulletin_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Japan — weather bulletins, warnings, forecasts

_{📍 keyed by {bulletin_id}   ·   📦 events WeatherBulletin}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ jma.go.jp}

 KMI Belgium       _{Belgium — ~14 AWS stations, 10-min observations}

🌍	Region	Belgium — ~14 AWS stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_code}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Belgium — ~14 AWS stations, 10-min observations

_{📍 keyed by {station_code}   ·   📦 events Station, WeatherObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ meteo.be}

 Meteoalarm       _{Europe — 37 countries, severe weather warnings}

🌍	Region	Europe — 37 countries
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{identifier}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Europe — 37 countries, severe weather warnings

_{📍 keyed by {identifier}   ·   📦 events WeatherWarning}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ meteoalarm.org}

 NOAA GOES / SWPC       _{Global — space weather, solar wind, K-index}

🌍	Region	Global — space weather
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{product_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — space weather, solar wind, K-index

_{📍 keyed by {product_id}   ·   📦 events SpaceWeatherAlert}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ swpc.noaa.gov}

 NOAA NWS       _{United States — weather alerts, CAP}

🌍	Region	United States — weather alerts
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{alert_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — weather alerts, CAP

_{📍 keyed by {alert_id}   ·   📦 events WeatherAlert}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ weather.gov}

 NOAA SWPC L1       _{Global — L1 propagated solar wind (DSCOVR/ACE), 1-min cadence, 30–60 min Earth-impact lead time}

🌍	Region	Global — L1 propagated solar wind (DSCOVR/ACE)
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{spacecraft}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — L1 propagated solar wind (DSCOVR/ACE), 1-min cadence, 30–60 min Earth-impact lead time

_{📍 keyed by {spacecraft}   ·   📦 events PropagatedSolarWind}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ swpc.noaa.gov}

 NWS CAP Alerts       _{United States — active alerts via api.weather.gov}

🌍	Region	United States — active alerts via api.weather.gov
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{alert_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — active alerts via api.weather.gov

_{📍 keyed by {alert_id}   ·   📦 events WeatherAlert}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ weather.gov}

 NWS Forecast Zones       _{United States — configurable land and marine forecast zones}

🌍	Region	United States — configurable land and marine forecast zones
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{zone_id}
📦	Events	3 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — configurable land and marine forecast zones

_{📍 keyed by {zone_id}   ·   📦 events ForecastZone, LandZoneForecast, MarineZoneForecast}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ weather.gov}

 Singapore NEA       _{Singapore — 62 weather stations + 5 air-quality regions}

🌍	Region	Singapore — 62 weather stations + 5 air-quality regions
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Singapore — 62 weather stations + 5 air-quality regions

_{📍 keyed by {station_id}   ·   📦 events Station, WeatherObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ nea.gov.sg}

 SMHI Weather       _{Sweden — ~232 stations, hourly obs}

🌍	Region	Sweden — ~232 stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Sweden — ~232 stations, hourly obs

_{📍 keyed by {station_id}   ·   📦 events Station, WeatherObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ smhi.se}

 Canada AQHI       _{Canada — community AQHI observations and forecasts}

🌍	Region	Canada — community AQHI observations and forecasts
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{province}/{community_name}
📦	Events	3 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Canada — community AQHI observations and forecasts

_{📍 keyed by {province}/{community_name}   ·   📦 events Community, Observation, Forecast}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ weather.gc.ca}

 Defra AURN       _{United Kingdom — 300+ monitoring locations, hourly pollutants}

🌍	Region	United Kingdom — 300+ monitoring locations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United Kingdom — 300+ monitoring locations, hourly pollutants

_{📍 keyed by {station_id}   ·   📦 events Station}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ uk-air.defra.gov.uk}

 EPA UV Index       _{United States — city-scoped hourly and daily UV forecasts}

🌍	Region	United States — city-scoped hourly and daily UV forecasts
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{location_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — city-scoped hourly and daily UV forecasts

_{📍 keyed by {location_id}   ·   📦 events HourlyForecast, DailyForecast}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ epa.gov}

 FMI Finland       _{Finland — hourly air quality observations via FMI WFS}

🌍	Region	Finland — hourly air quality observations via FMI WFS
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{fmisid}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Finland — hourly air quality observations via FMI WFS

_{📍 keyed by {fmisid}   ·   📦 events Station, Observation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ en.ilmatieteenlaitos.fi}

 GIOÅš Poland       _{Poland — ~250 stations, hourly pollutants + AQI}

🌍	Region	Poland — ~250 stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	n/a
📦	Events	4 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Poland — ~250 stations, hourly pollutants + AQI

_{📍 keyed by n/a   ·   📦 events Station, Sensor, Measurement, AirQualityIndex}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ gios.gov.pl}

 Hong Kong EPD AQHI       _{Hong Kong — 18 AQHI stations, hourly health index}

🌍	Region	Hong Kong — 18 AQHI stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Hong Kong — 18 AQHI stations, hourly health index

_{📍 keyed by {station_id}   ·   📦 events Station, AQHIReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ aqhi.gov.hk}

 IRCELINE Belgium       _{Belgium — station, timeseries, and hourly observations}

🌍	Region	Belgium — station
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Belgium — station, timeseries, and hourly observations

_{📍 keyed by {station_id}   ·   📦 events Station}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ irceline.be}

 LAQN London       _{London, UK — site metadata, species, hourly measurements}

🌍	Region	London
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{site_code}
📦	Events	3 type(s)
✅	Build	passing
🗄️	KQL schema	yes

London, UK — site metadata, species, hourly measurements

_{📍 keyed by {site_code}   ·   📦 events Site, Measurement, DailyIndex}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ londonair.org.uk}

 Luchtmeetnet Netherlands       _{Netherlands — station measurements, components, LKI index}

🌍	Region	Netherlands — station measurements
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_number}
📦	Events	3 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Netherlands — station measurements, components, LKI index

_{📍 keyed by {station_number}   ·   📦 events Station, Measurement, LKI}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ luchtmeetnet.nl}

 Sensor.Community       _{Global — citizen air sensors, PM and climate readings}

🌍	Region	Global — citizen air sensors
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{sensor_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — citizen air sensors, PM and climate readings

_{📍 keyed by {sensor_id}   ·   📦 events SensorInfo, SensorReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ sensor.community}

 UBA AirData       _{Germany — stations, pollutant components, hourly measures}

🌍	Region	Germany — stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Germany — stations, pollutant components, hourly measures

_{📍 keyed by {station_id}   ·   📦 events Station, Measure}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ umweltbundesamt.de}

 Wallonia ISSeP       _{Belgium / Wallonia — low-cost air quality sensors}

🌍	Region	Belgium / Wallonia — low-cost air quality sensors
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{configuration_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Belgium / Wallonia — low-cost air quality sensors

_{📍 keyed by {configuration_id}   ·   📦 events SensorConfiguration, Observation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ issep.be}

 Australian Wildfires       _{Australia — NSW, QLD, VIC bushfire incidents}

🌍	Region	Australia — NSW
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{state}/{incident_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Australia — NSW, QLD, VIC bushfire incidents

_{📍 keyed by {state}/{incident_id}   ·   📦 events FireIncident}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ rfs.nsw.gov.au}

 EAWS ALBINA Avalanche       _{European Alps — daily avalanche bulletins, CAAMLv6}

🌍	Region	European Alps — daily avalanche bulletins
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{region_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

European Alps — daily avalanche bulletins, CAAMLv6

_{📍 keyed by {region_id}   ·   📦 events AvalancheRegion, AvalancheBulletin}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ avalanche.report}

 FDSN Seismology       _{Global — federated earthquake detections, 7 FDSN nodes}

🌍	Region	Global — federated earthquake detections
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{contributor}/{event_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — federated earthquake detections, 7 FDSN nodes

_{📍 keyed by {contributor}/{event_id}   ·   📦 events Earthquake, Node}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ fdsn.org}

 GDACS       _{Global — earthquakes, floods, cyclones, volcanoes, droughts}

🌍	Region	Global — earthquakes
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{event_type}/{event_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — earthquakes, floods, cyclones, volcanoes, droughts

_{📍 keyed by {event_type}/{event_id}   ·   📦 events DisasterAlert}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ gdacs.org}

 INPE DETER Brazil       _{Brazil — Amazon & Cerrado deforestation alerts}

🌍	Region	Brazil — Amazon & Cerrado deforestation alerts
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{biome}/{alert_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Brazil — Amazon & Cerrado deforestation alerts

_{📍 keyed by {biome}/{alert_id}   ·   📦 events DeforestationAlert}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ terrabrasilis.dpi.inpe.br}

 JMA Bosai Quake       _{Japan — JMA earthquake bulletins (hypocenter, magnitude, JMA intensity)}

🌍	Region	Japan — JMA earthquake bulletins (hypocenter
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	jp.jma.quake/{event_id}/{serial}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Japan — JMA earthquake bulletins (hypocenter, magnitude, JMA intensity)

_{📍 keyed by jp.jma.quake/{event_id}/{serial}   ·   📦 events EarthquakeReport}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ jma.go.jp}

 JMA Bosai Volcano       _{Japan — 111 volcanoes, alert levels, eruption observations}

🌍	Region	Japan — 111 volcanoes
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	jp.jma.volcano/{volcano_code}
📦	Events	3 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Japan — 111 volcanoes, alert levels, eruption observations

_{📍 keyed by jp.jma.volcano/{volcano_code}   ·   📦 events Volcano, VolcanicWarning, VolcanicEruption}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ jma.go.jp}

 JMA Bosai Warning & Tsunami       _{Japan — per-prefecture weather warnings + tsunami alerts}

🌍	Region	Japan — per-prefecture weather warnings + tsunami alerts
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	jp.jma.warning/{office_code}/{area_code}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Japan — per-prefecture weather warnings + tsunami alerts

_{📍 keyed by jp.jma.warning/{office_code}/{area_code}   ·   📦 events Office, WeatherWarning}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ jma.go.jp}

 NASA FIRMS Active Fire       _{Global — active fire & thermal anomaly detections (VIIRS/MODIS), OSINT}

🌍	Region	Global — active fire & thermal anomaly detections (VIIRS/MODIS)
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{source}/{record_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — active fire & thermal anomaly detections (VIIRS/MODIS), OSINT

_{📍 keyed by {source}/{record_id}   ·   📦 events FireDetection, DataAvailability}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ firms.modaps.eosdis.nasa.gov}

 NIFC USA Wildfires       _{United States — active wildfire incidents, NIFC}

🌍	Region	United States — active wildfire incidents
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{irwin_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — active wildfire incidents, NIFC

_{📍 keyed by {irwin_id}   ·   📦 events WildfireIncident}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ nifc.gov}

 NINA/BBK       _{Germany — MOWAS, KATWARN, BIWAPP, DWD, LHP, Police}

🌍	Region	Germany — MOWAS
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{warning_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Germany — MOWAS, KATWARN, BIWAPP, DWD, LHP, Police

_{📍 keyed by {warning_id}   ·   📦 events CivilWarning}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ warnung.bund.de}

 PTWC Tsunami       _{Pacific and Atlantic — NOAA tsunami bulletins}

🌍	Region	Pacific and Atlantic — NOAA tsunami bulletins
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{bulletin_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Pacific and Atlantic — NOAA tsunami bulletins

_{📍 keyed by {bulletin_id}   ·   📦 events TsunamiBulletin}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ tsunami.gov}

 Seattle Fire 911       _{Seattle, WA — real-time fire dispatch incidents}

🌍	Region	Seattle
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{incident_number}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Seattle, WA — real-time fire dispatch incidents

_{📍 keyed by {incident_number}   ·   📦 events Incident}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ data.seattle.gov}

 USGS Earthquakes       _{Global — seismic events}

🌍	Region	Global — seismic events
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{net}/{code}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — seismic events

_{📍 keyed by {net}/{code}   ·   📦 events Event}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ earthquake.usgs.gov}

 BfS ODL       _{Germany — ~1,700 stations, hourly gamma dose rate}

🌍	Region	Germany — ~1
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Germany — ~1,700 stations, hourly gamma dose rate

_{📍 keyed by {station_id}   ·   📦 events Station, DoseRateMeasurement}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ odlinfo.bfs.de}

 EURDEP Radiation       _{Europe — ~5,500 stations, 39 countries, gamma dose}

🌍	Region	Europe — ~5
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Europe — ~5,500 stations, 39 countries, gamma dose

_{📍 keyed by {station_id}   ·   📦 events Station, DoseRateReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ remon.jrc.ec.europa.eu}

 USGS Geomagnetism       _{United States — 14 observatories, 1-min geomagnetic field}

🌍	Region	United States — 14 observatories
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{iaga_code}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

United States — 14 observatories, 1-min geomagnetic field

_{📍 keyed by {iaga_code}   ·   📦 events Observatory, MagneticFieldReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ usgs.gov}

 AISStream       _{Global — AIS via WebSocket, ~200 km from shore}

🌍	Region	Global — AIS via WebSocket
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{UserID}
📦	Events	23 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — AIS via WebSocket, ~200 km from shore

_{📍 keyed by {UserID}   ·   📦 events PositionReport, ShipStaticData, StandardClassBPositionReport, ExtendedClassBPositionReport, AidsToNavigationReport, StaticDataReport, BaseStationReport, SafetyBroadcastMessage, StandardSearchAndRescueAircraftReport, LongRangeAisBroadcastMessage, AddressedSafetyMessage, AddressedBinaryMessage, AssignedModeCommand, BinaryAcknowledge, BinaryBroadcastMessage, ChannelManagement, CoordinatedUTCInquiry, DataLinkManagementMessage, GnssBroadcastBinaryMessage, GroupAssignmentCommand, Interrogation, MultiSlotBinaryMessage, SingleSlotBinaryMessage}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ aisstream.io}

 Digitraffic Maritime       _{Finland / Baltic Sea — AIS via MQTT}

🌍	Region	Finland / Baltic Sea — AIS via MQTT
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{mmsi}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Finland / Baltic Sea — AIS via MQTT

_{📍 keyed by {mmsi}   ·   📦 events VesselLocation, VesselMetadata}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ digitraffic.fi}

 Kystverket AIS       _{Norway / Svalbard — raw TCP AIS, ~34 msg/s}

🌍	Region	Norway / Svalbard — raw TCP AIS
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{mmsi}
📦	Events	7 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Norway / Svalbard — raw TCP AIS, ~34 msg/s

_{📍 keyed by {mmsi}   ·   📦 events PositionReportClassA, StaticVoyageData, PositionReportClassB, StaticDataClassB, AidToNavigation, PositionReport, ShipStatic}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ kystverket.no}

 Mode-S       _{Local — ADS-B via dump1090 receivers}

🌍	Region	Local — ADS-B via dump1090 receivers
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{icao24}/{receiver_id}
📦	Events	6 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Local — ADS-B via dump1090 receivers

_{📍 keyed by {icao24}/{receiver_id}   ·   📦 events ADSB, AltitudeReply, IdentityReply, AcquisitionReply, CommBAltitude, CommBIdentity}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ opensky-network.org}

 VATSIM       _{Global — virtual aviation network, pilots & controllers}

🌍	Region	Global — virtual aviation network
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{callsign}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — virtual aviation network, pilots & controllers

_{📍 keyed by {callsign}   ·   📦 events PilotPosition}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ vatsim.net}

 Autobahn       _{Germany — roadworks, warnings, closures, webcams}

🌍	Region	Germany — roadworks
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{identifier}
📦	Events	30 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Germany — roadworks, warnings, closures, webcams

_{📍 keyed by {identifier}   ·   📦 events RoadworkAppeared, RoadworkUpdated, RoadworkResolved, ShortTermRoadworkAppeared, ShortTermRoadworkUpdated, ShortTermRoadworkResolved, WarningAppeared, WarningUpdated, WarningResolved, ClosureAppeared, ClosureUpdated, ClosureResolved, EntryExitClosureAppeared, EntryExitClosureUpdated, EntryExitClosureResolved, WeightLimit35RestrictionAppeared, WeightLimit35RestrictionUpdated, WeightLimit35RestrictionResolved, ParkingLorryAppeared, ParkingLorryUpdated, ParkingLorryResolved, ElectricChargingStationAppeared, ElectricChargingStationUpdated, ElectricChargingStationResolved, StrongElectricChargingStationAppeared, StrongElectricChargingStationUpdated, StrongElectricChargingStationResolved, WebcamAppeared, WebcamUpdated, WebcamResolved}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ autobahn.de}

 Digitraffic Road       _{Finland — TMS sensors, road weather, traffic messages}

🌍	Region	Finland — TMS sensors
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{station_id}/{sensor_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Finland — TMS sensors, road weather, traffic messages

_{📍 keyed by {station_id}/{sensor_id}   ·   📦 events TmsSensorData, WeatherSensorData}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ digitraffic.fi}

 French Road Traffic       _{France — national road network, DATEX II}

🌍	Region	France — national road network
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{site_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

France — national road network, DATEX II

_{📍 keyed by {site_id}   ·   📦 events TrafficFlowMeasurement}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ bison-fute.gouv.fr}

 GTFS Realtime       _{Global — 1,000+ transit agencies, vehicles, trips, alerts}

🌍	Region	Global — 1
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{agencyid}
📦	Events	3 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Global — 1,000+ transit agencies, vehicles, trips, alerts

_{📍 keyed by {agencyid}   ·   📦 events VehiclePosition, TripUpdate, Alert}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ gtfs.org}

 Madrid Traffic       _{Madrid, Spain — ~4,000 sensors, Informo}

🌍	Region	Madrid
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{sensor_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Madrid, Spain — ~4,000 sensors, Informo

_{📍 keyed by {sensor_id}   ·   📦 events MeasurementPoint, TrafficReading}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ datos.madrid.es}

 NDW Road Traffic       _{Netherlands — national road traffic, DATEX II XML}

🌍	Region	Netherlands — national road traffic
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	measurement-sites/{measurement_site_id}
📦	Events	4 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Netherlands — national road traffic, DATEX II XML

_{📍 keyed by measurement-sites/{measurement_site_id}   ·   📦 events PointMeasurementSite, RouteMeasurementSite, TrafficObservation, TravelTimeObservation}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ ndw.nu}

 Nextbus       _{North America — public transit arrivals}

🌍	Region	North America — public transit arrivals
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	n/a
📦	Events	4 type(s)
✅	Build	passing
🗄️	KQL schema	yes

North America — public transit arrivals

_{📍 keyed by n/a   ·   📦 events VehiclePosition, RouteConfig, Schedule, Message}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ umoiq.com}

 Paris Bicycle Counters       _{Paris — ~141 counting stations, hourly counts}

🌍	Region	Paris — ~141 counting stations
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{counter_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Paris — ~141 counting stations, hourly counts

_{📍 keyed by {counter_id}   ·   📦 events Counter, BicycleCount}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ opendata.paris.fr}

 Seattle Street Closures       _{Seattle, WA — permit-driven street closure windows}

🌍	Region	Seattle
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	{closure_id}
📦	Events	1 type(s)
✅	Build	passing
🗄️	KQL schema	yes

Seattle, WA — permit-driven street closure windows

_{📍 keyed by {closure_id}   ·   📦 events StreetClosure}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ data.seattle.gov}

 TfL Road Traffic       _{London, UK — road corridor status and disruptions}

🌍	Region	London
🔌	Transports	Kafka · MQTT · AMQP
📍	Kafka key	roads/{road_id}
📦	Events	2 type(s)
✅	Build	passing
🗄️	KQL schema	yes

London, UK — road corridor status and disruptions

_{📍 keyed by roads/{road_id}   ·   📦 events RoadCorridor, RoadStatus}

_DEPLOY

_{📘 README  ·  📑 EVENTS  ·  🐳 CONTAINER  ·  ↗ tfl.gov.uk}