#!/usr/bin/env python3
"""
Monterey County, California weather station map with actual temperatures.
"""
import requests
import json
from datetime import datetime
from concurrent.futures import ThreadPoolExecutor, as_completed
# API endpoints
ALL_STATIONS_URL = "https://www.weatherlink.com/map/data"
STATION_DETAIL_URL = "https://www.weatherlink.com/map/data/station/{id}"
HEADERS = {
'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36'
}
# Monterey County, California bounding box
MONTEREY_BOUNDS = {
'min_lat': 35.78,
'max_lat': 36.92,
'min_lng': -121.98,
'max_lng': -120.21
}
MAX_WORKERS = 5
def is_in_monterey(lat, lng):
return (MONTEREY_BOUNDS['min_lat'] <= lat <= MONTEREY_BOUNDS['max_lat'] and
MONTEREY_BOUNDS['min_lng'] <= lng <= MONTEREY_BOUNDS['max_lng'])
def get_temp_color(temp):
"""Get color for temperature value."""
try:
t = float(temp)
if t < 0: return '#29333b'
elif t < 10: return '#535f79'
elif t < 20: return '#2f6695'
elif t < 32: return '#1b7dbf'
elif t < 40: return '#27a5af'
elif t < 50: return '#00b58d'
elif t < 60: return '#009247'
elif t < 70: return '#fdd03b'
elif t < 80: return '#ed9922'
else: return '#dd5626'
except:
return '#888888'
def fetch_station_detail(station):
"""Fetch full details for a single station."""
station_id = station.get('id')
if not station_id:
return None
try:
url = STATION_DETAIL_URL.format(id=station_id)
resp = requests.get(url, headers=HEADERS, timeout=10)
resp.raise_for_status()
detail = resp.json()
return {
'lat': station.get('lat'),
'lng': station.get('lng'),
'name': detail.get('sStation', 'Unknown'),
'temp': detail.get('temperature', '--'),
'humidity': detail.get('humidity', '--'),
'wind': detail.get('windSpeed', '--'),
'wind_dir': detail.get('windDirection', '--'),
'barometer': detail.get('barometer', '--'),
'updated': detail.get('lastUpdatedAt', '--')
}
except:
return None
def main():
print("=" * 60)
print("Monterey County Weather Map Generator")
print(f"Started: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
print("=" * 60)
# Fetch all stations
print("\nFetching station list...")
resp = requests.get(ALL_STATIONS_URL, headers=HEADERS, timeout=30)
all_stations = resp.json()
print(f" Total worldwide: {len(all_stations):,}")
# Filter to Monterey County
monterey_stations = [s for s in all_stations
if is_in_monterey(s.get('lat', 0), s.get('lng', 0))]
print(f" Monterey County: {len(monterey_stations)}")
if not monterey_stations:
print("No stations found!")
return
# Poll stations in parallel
print(f"\nPolling {len(monterey_stations)} stations...")
stations = []
with ThreadPoolExecutor(max_workers=MAX_WORKERS) as executor:
futures = {executor.submit(fetch_station_detail, s): s for s in monterey_stations}
for future in as_completed(futures):
result = future.result()
if result:
stations.append(result)
print(f" Got data for {len(stations)} stations")
if not stations:
print("No station data retrieved!")
return
# Calculate stats
temps = []
for s in stations:
try:
temps.append(float(s['temp']))
except:
pass
if temps:
min_temp = min(temps)
max_temp = max(temps)
print(f" Temp range: {min_temp:.0f}°F to {max_temp:.0f}°F")
else:
min_temp = max_temp = 0
# Add colors to stations
for s in stations:
s['color'] = get_temp_color(s['temp'])
# Generate HTML map
html = f"""
Monterey County Weather
"""
# Save HTML
output_file = "monterey_county_weather.html"
with open(output_file, "w") as f:
f.write(html)
print(f"\n✓ Map saved to {output_file}")
# Save station data
with open("monterey_county_data.json", "w") as f:
json.dump(stations, f, indent=2)
print(f"✓ Data saved to monterey_county_data.json")
print("=" * 60)
if __name__ == "__main__":
main()