Yearly variant

app.py

@@ -1,8 +1,10 @@
 import os
+import utm
 import ee
 import json
 import geojson
 import geemap
+import numpy as np
 import geemap.foliumap as gee_folium
 import leafmap.foliumap as leaf_folium
 import streamlit as st
@@ -36,11 +38,15 @@ def calculate_ndvi(image, nir_band, red_band):
     ndvi = (nir.subtract(red)).divide(nir.add(red)).rename("NDVI")
     return image.addBands(ndvi)
 
-def process_date(start_date, end_date, satellite):
+def process_date(date, satellite):
     try:
         attrs = satellites[satellite]
         collection = attrs["collection"]
         collection = collection.filterBounds(ee_geometry)
+        str_start_date = date+"-01"
+        start_date = pd.to_datetime(str_start_date)
+        end_date = start_date + pd.DateOffset(months=1)
+        write_info(f"Processing {satellite} - {start_date} to {end_date}")
         collection = collection.filterDate(start_date, end_date)
         mosaic = collection.qualityMosaic("NDVI")
         fc = geemap.zonal_stats(
@@ -169,12 +175,11 @@ st.markdown(
 
 # Input: Date and Cloud Cover
 col = st.columns(4)
-start_year = col[0].selectbox("Start Year", list(range(2014, 2027)), index=8)
-start_month = col[1].selectbox("Start Month", list(range(1, 13)), index=0)
-end_year = col[2].selectbox("End Year", list(range(2014, 2027)), index=8)
-end_month = col[3].selectbox("End Month", list(range(1, 13)), index=2)
-start_date = f"{start_year}-{start_month:02d}"
-end_date = f"{end_year}-{end_month:02d}"
+month_of_interest = col[0].selectbox("Month of Interest", list(range(1, 13)), index=11)
+start_year = col[1].selectbox("Start Year", list(range(2014, 2027)), index=6)
+end_year = col[2].selectbox("End Year", list(range(2014, 2027)), index=9) + 1
+start_date = f"{start_year}-{month_of_interest:02d}"
+end_date = f"{end_year}-{month_of_interest:02d}"
 
 # Input: GeoJSON/KML file
 uploaded_file = st.file_uploader("Upload KML/GeoJSON file", type=["geojson", "kml"])
@@ -185,8 +190,8 @@ gdf = preprocess_gdf(gpd.read_file(uploaded_file))
 
 # Input: Geometry
 selected_geometry = st.selectbox("Select the geometry", gdf.Name.values)
-
-selected_geometry = gdf[gdf.Name == selected_geometry].iloc[0].geometry
+selected_geometry_gdf = gdf[gdf.Name == selected_geometry]
+selected_geometry = selected_geometry_gdf.iloc[0].geometry
 if selected_geometry.type != "Polygon":
     st.error(
         f"Selected geometry is of type {selected_geometry.type}. Please provide a polygon geometry."
@@ -196,8 +201,25 @@ if selected_geometry.type != "Polygon":
 # Derived Inputs
 selected_geometry = selected_geometry.__geo_interface__
 ee_geometry = ee.Geometry(selected_geometry)
+_, lonlat = ee_geometry.centroid().getInfo().values()
+lon, lat = lonlat
 ee_feature_collection = ee.FeatureCollection(ee_geometry)
 feature_collection = geojson.FeatureCollection([{"type": "Feature", "geometry": selected_geometry, "properties": {"name": "Selected Geometry"}}])
+x, y, zone, _ = utm.from_latlon(lat, lon)
+epsg = f"EPSG:326{zone}"
+selected_geometry_gdf = selected_geometry_gdf.to_crs(epsg)
+area = selected_geometry_gdf.area.values[0]
+perimeter = selected_geometry_gdf.length.values[0]
+
+stats_df = pd.DataFrame(
+    {
+        "Area (m^2)": [area],
+        "Perimeter (m)": [perimeter],
+        "Centroid (lat, lon)": [f"{lat}, {lon}"],
+        "Points": np.array(selected_geometry['coordinates']).tolist(),
+    }
+)
+        
 
 # visualize the geometry
 m = leaf_folium.Map()
@@ -208,6 +230,11 @@ m.add_geojson(feature_collection)
 write_info(f"Visual Esri Wayback Basemap - {latest_date}")
 m.to_streamlit()
 
+st.write(stats_df)
+# download option
+stats_csv = stats_df.to_csv()
+st.download_button("Download Geometry Stats", stats_csv, "geometry_stats.csv", "text/csv")
+
 
 # Input: Satellite Sources
 st.write("Select the satellite sources:")
@@ -223,7 +250,10 @@ if submit:
         st.stop()
 
     # Create month range
-    dates = pd.date_range(start_date, end_date, freq="MS").strftime("%Y-%m").tolist()
+    # print(start_date, end_date)
+    dates = pd.date_range(start_date, end_date, freq="Y").strftime("%Y-%m").tolist()
+    # print(dates)
+    # asjasndjasndj
     write_info(
         f"Start Date (inclusive): {start_date}, End Date (exclusive): {end_date}"
     )
@@ -234,14 +264,14 @@ if submit:
 
         with st.spinner(f"Processing {satellite} ..."):
             progress_bar = st.progress(0)
-            for i, (start, end) in enumerate(zip(dates[:-1], dates[1:])):
-                mosaic, mean_ndvi, cloud_proba = process_date(start, end, satellite)
-                result[satellite][start] = {
+            for i, date in enumerate(dates):
+                mosaic, mean_ndvi, cloud_proba = process_date(date, satellite)
+                result[satellite][date] = {
                     "mosaic": mosaic,
                     "mean_ndvi": mean_ndvi,
                     "cloud_mask_probability": cloud_proba,
                 }
-                progress_bar.progress((i + 1) / (len(dates) - 1))
+                progress_bar.progress((i + 1) / len(dates))
 
     st.session_state.result = result
 
@@ -279,14 +309,15 @@ if "result" in st.session_state:
 
     df_numeric = df.select_dtypes(include=["float64"])
     st.write(df_numeric)
+    # give streamlit option to download the data
+    csv = df_numeric.to_csv()
+    st.download_button("Download Time Series", csv, "data.csv", "text/csv")
     
-    fig = px.line(df, y=df_numeric.columns, title="Mean NDVI", markers=True)
+    fig = px.line(df, y=df_numeric.columns[0:1], title="Mean NDVI", markers=True)
     fig.update_yaxes(range=[-0.2, 1])
     st.plotly_chart(fig)
 
     st.subheader("Visual Inspection")
-    _, lonlat = ee_geometry.centroid().getInfo().values()
-    lon, lat = lonlat
     write_info(f"Centroid of the selected geometry (lat, lon): ({lat}, {lon})")
     cols = st.columns(2)
     df_dates = df.index.strftime("%Y-%m").tolist()

sandbox.ipynb

@@ -140,7 +140,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 24,
+   "execution_count": 26,
    "metadata": {},
    "outputs": [
     {
@@ -180,16 +180,16 @@
     {
      "data": {
       "text/plain": [
-       "2.75e-05"
+       "7272.727272727272"
       ]
      },
-     "execution_count": 24,
+     "execution_count": 26,
      "metadata": {},
      "output_type": "execute_result"
     }
    ],
    "source": [
-    "2.75e-05"
+    "1/2.75e-05 * 0.2"
    ]
   },
   {
@@ -2631,6 +2631,76 @@
     "layers = [\"Esri.WorldTopoMap\", \"OpenTopoMap\"]\n",
     "leafmap.linked_maps(rows=1, cols=2, height=\"400px\", layers=layers)"
    ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 1,
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "application/vnd.jupyter.widget-view+json": {
+       "model_id": "1ce50feee5594597a06e1de0b80600b1",
+       "version_major": 2,
+       "version_minor": 0
+      },
+      "text/plain": [
+       "Map(center=[45.8107, 8.6288], controls=(ZoomControl(options=['position', 'zoom_in_text', 'zoom_in_title', 'zoo…"
+      ]
+     },
+     "metadata": {},
+     "output_type": "display_data"
+    }
+   ],
+   "source": [
+    "from ipyleaflet import Map, TileLayer, WidgetControl\n",
+    "from ipywidgets import SelectionSlider\n",
+    "\n",
+    "# Prepare a slider widget to navigate the version history of the basemap\n",
+    "# There doesn't seem to be any pattern between timeId and basemap date, so just a few couples manually extracted from\n",
+    "# https://wayback.maptiles.arcgis.com/arcgis/rest/services/world_imagery/mapserver/wmts/1.0.0/wmtscapabilities.xml\n",
+    "date_timeId_mapping = [('2016-01-13', 3515),\n",
+    "                       ('2017-01-11', 577),\n",
+    "                       ('2018-01-08', 13161),\n",
+    "                       ('2019-01-09', 6036),\n",
+    "                       ('2020-01-08', 23001),\n",
+    "                       ('2021-01-13', 1049),\n",
+    "                       ('2022-01-12', 42663),\n",
+    "                       ('2023-01-11', 11475)]\n",
+    "\n",
+    "# Date slider widget\n",
+    "wayback_slider = SelectionSlider(\n",
+    "    options=date_timeId_mapping,\n",
+    "    value=3515,\n",
+    "    description='Date',\n",
+    "    disabled=False,\n",
+    "    continuous_update=True,\n",
+    "    orientation='horizontal',\n",
+    "    readout=True\n",
+    ")\n",
+    "time_control = WidgetControl(widget=wayback_slider, position='topright')\n",
+    "\n",
+    "# Connect tile layer (wayback, not yet defined) with slider value\n",
+    "def on_date_change(*args):\n",
+    "    wayback.url = 'https://wayback.maptiles.arcgis.com/arcgis/rest/services/world_imagery/wmts/1.0.0/default028mm/mapserver/tile/%d/{z}/{y}/{x}' % wayback_slider.value\n",
+    "    wayback.redraw()\n",
+    "    \n",
+    "wayback_slider.observe(on_date_change, 'value')\n",
+    "\n",
+    "# Prepare map, tilelayer and draw it\n",
+    "m = Map(center=(45.8107, 8.6288), zoom=16, scroll_wheel_zoom=True)\n",
+    "wayback = TileLayer(url='https://wayback.maptiles.arcgis.com/arcgis/rest/services/world_imagery/wmts/1.0.0/default028mm/mapserver/tile/3515/{z}/{y}/{x}')\n",
+    "m.add_layer(wayback)\n",
+    "m.add_control(time_control)\n",
+    "m"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": []
   }
  ],
  "metadata": {