Skip to content

Implement In-Memory Weather Response Caching for /weather Endpoint #246

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
AYUSH-P-SINGH wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Implement In-Memory Weather Response Caching for /weather Endpoint #246

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
108 changes: 77 additions & 31 deletions backend/alertsystem.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import os
import sys
import requests

import time
from dotenv import load_dotenv

load_dotenv()
Expand Down Expand Up @@ -52,6 +52,13 @@ def fetch_gis_alert_data():

app = Flask(__name__)
CORS(app)
# =========================================================
# WEATHER CACHE
# =========================================================

weather_cache = {}

CACHE_DURATION = 600

BASE_DIR = os.path.dirname(
os.path.dirname(
Expand Down Expand Up @@ -170,7 +177,6 @@ def fetch_coords(params):

print("All geocoding attempts failed. Location not found.")
return None

# =========================================================
# GIS ALERT DATA (Issue #83: Exception Handling)
# =========================================================
Expand All @@ -180,6 +186,7 @@ def fetch_gis_alert_data():
Fetches external GIS climate data streams.
Implements try-except blocks to prevent backend crashes.
"""

GIS_API_URL = "https://external-gis-source.com"

try:
Expand All @@ -188,15 +195,21 @@ def fetch_gis_alert_data():
return response.json(), 200

except requests.exceptions.Timeout:
return {"error": "External GIS service timed out. Please try again."}, 504

except (requests.exceptions.RequestException, ValueError):
return {"error": "External GIS service is unavailable or returned an invalid response."}, 503
return {
"error": "External GIS service timed out. Please try again."
}, 504

except (
requests.exceptions.RequestException,
ValueError
):
return {
"error": "External GIS service is unavailable or returned an invalid response."
}, 503

# =========================================================
# WEATHER API
# =========================================================

@app.route("/weather", methods=["POST"])
def get_weather_insights():

Expand All @@ -208,6 +221,22 @@ def get_weather_insights():
state = payload.get("state", "").strip()
country = payload.get("country", "").strip()

cache_key = f"{city.lower()}:{state.lower()}:{country.lower()}"

current_time = time.time()

if cache_key in weather_cache:

cached = weather_cache[cache_key]

if current_time - cached["timestamp"] < CACHE_DURATION:

print(f"Cache HIT: {cache_key}")

return jsonify(cached["response"])

print(f"Cache MISS: {cache_key}")

if not city or not state or not country:

return jsonify({
Expand All @@ -218,17 +247,17 @@ def get_weather_insights():
api_key = os.environ.get("OPENWEATHER_API_KEY")

if not api_key:

print("OPENWEATHER_API_KEY missing")

return jsonify({
"success": False,
"message": "Weather service configuration error."
}), 500

# ----------------------------------------------------
# STEP 1: Convert city → coordinates
# ----------------------------------------------------

# ----------------------------------------------------
# STEP 1: Convert city → coordinates
# ----------------------------------------------------
geo_response = requests.get(
"https://api.openweathermap.org/geo/1.0/direct",
params={
Expand Down Expand Up @@ -486,7 +515,7 @@ def get_weather_insights():
}
})

return jsonify({
response_data = {

"success": True,

Expand All @@ -506,33 +535,50 @@ def get_weather_insights():
},

"risks": {
"flood_risk": round(flood_risk_metric, 3),
"flood_risk_confidence": round(flood_risk_metric * 100, 1),
"flood_risk_level": "HIGH" if flood_risk_metric >= 0.6 else "MEDIUM" if flood_risk_metric >= 0.3 else "LOW",
"heat_risk": round(heat_risk_metric, 3),
"heat_risk_confidence": round(heat_risk_metric * 100, 1),
"heat_risk_level": "HIGH" if heat_risk_metric >= 0.6 else "MEDIUM" if heat_risk_metric >= 0.3 else "LOW",
"wildfire_risk": round(wildfire_risk_metric, 3),
"wildfire_risk_confidence": round(wildfire_risk_metric * 100, 1),
"wildfire_risk_level": "HIGH" if wildfire_risk_metric >= 0.6 else "MEDIUM" if wildfire_risk_metric >= 0.3 else "LOW",
"cyclone_risk": round(cyclone_risk_metric, 3),
"cyclone_risk_confidence": round(cyclone_risk_metric * 100, 1),
"cyclone_risk_level": "HIGH" if cyclone_risk_metric >= 0.6 else "MEDIUM" if cyclone_risk_metric >= 0.3 else "LOW",
"drought_risk": round(drought_risk_metric, 3),
"drought_risk_confidence": round(drought_risk_metric * 100, 1),
"drought_risk_level": "HIGH" if drought_risk_metric >= 0.6 else "MEDIUM" if drought_risk_metric >= 0.3 else "LOW",
"flood_risk": round(flood_risk_metric, 3),
"flood_risk_confidence": round(flood_risk_metric * 100, 1),
"flood_risk_level": "HIGH" if flood_risk_metric >= 0.6 else "MEDIUM" if flood_risk_metric >= 0.3 else "LOW",

"heat_risk": round(heat_risk_metric, 3),
"heat_risk_confidence": round(heat_risk_metric * 100, 1),
"heat_risk_level": "HIGH" if heat_risk_metric >= 0.6 else "MEDIUM" if heat_risk_metric >= 0.3 else "LOW",

"wildfire_risk": round(wildfire_risk_metric, 3),
"wildfire_risk_confidence": round(wildfire_risk_metric * 100, 1),
"wildfire_risk_level": "HIGH" if wildfire_risk_metric >= 0.6 else "MEDIUM" if wildfire_risk_metric >= 0.3 else "LOW",

"cyclone_risk": round(cyclone_risk_metric, 3),
"cyclone_risk_confidence": round(cyclone_risk_metric * 100, 1),
"cyclone_risk_level": "HIGH" if cyclone_risk_metric >= 0.6 else "MEDIUM" if cyclone_risk_metric >= 0.3 else "LOW",

"drought_risk": round(drought_risk_metric, 3),
"drought_risk_confidence": round(drought_risk_metric * 100, 1),
"drought_risk_level": "HIGH" if drought_risk_metric >= 0.6 else "MEDIUM" if drought_risk_metric >= 0.3 else "LOW"
},

"forecast": forecast,

"alerts": calculated_alerts,
})
"alerts": calculated_alerts
}

weather_cache[cache_key] = {
"response": response_data,
"timestamp": current_time
}

print(f"Cached: {cache_key}")

return jsonify(response_data)

except Exception as general_err:
print("Weather Route Error:")
print(str(general_err))
return jsonify({"success": False, "message": "Internal server error."}), 500

return jsonify({
"success": False,
"message": "Internal server error."
}), 500


@app.route("/reverse-geocode", methods=["POST"])
def reverse_geocode():

Expand Down