Update pages/Hail.py

pages/Hail.py

@@ -1,4 +1,107 @@
 
+
+# -*- coding: utf-8 -*-
+"""
+Created on Tue Dec  6 09:56:29 2022
+
+@author: mritchey
+"""
+#streamlit run "C:\Users\mritchey\.spyder-py3\Python Scripts\streamlit projects\mrms\mrms_hail2 buffer.py"
+
+import plotly.express as px
+import os
+from PIL import Image
+from joblib import Parallel, delayed
+import pandas as pd
+import streamlit as st
+from geopy.extra.rate_limiter import RateLimiter
+from geopy.geocoders import Nominatim
+import folium
+from streamlit_folium import st_folium
+import math
+import geopandas as gpd
+from skimage.io import imread
+from streamlit_plotly_events import plotly_events
+import requests
+from requests.packages.urllib3.exceptions import InsecureRequestWarning
+import rasterio
+import rioxarray
+import numpy as np
+import io
+# from urllib import request
+# import certifi
+# import ssl
+# context = ssl.create_default_context(cafile=certifi.where())
+# https_handler = request.HTTPSHandler(context=context)
+# opener = request.build_opener(https_handler)
+# request.install_opener(opener)
+
+@st.cache(allow_output_mutation=True)
+def geocode(address, buffer_size):
+    try:
+        address2 = address.replace(' ', '+').replace(',', '%2C')
+        df = pd.read_json(
+            f'https://geocoding.geo.census.gov/geocoder/locations/onelineaddress?address={address2}&benchmark=2020&format=json')
+        results = df.iloc[:1, 0][0][0]['coordinates']
+        lat, lon = results['y'], results['x']
+    except:
+        geolocator = Nominatim(user_agent="GTA Lookup")
+        geocode = RateLimiter(geolocator.geocode, min_delay_seconds=1)
+        location = geolocator.geocode(address)
+        lat, lon = location.latitude, location.longitude
+
+    df = pd.DataFrame({'Lat': [lat], 'Lon': [lon]})
+    gdf = gpd.GeoDataFrame(
+        df, geometry=gpd.points_from_xy(df.Lon, df.Lat, crs=4326))
+    gdf['buffer'] = gdf['geometry'].to_crs(
+        3857).buffer(buffer_size/2*2580).to_crs(4326)
+    return gdf
+
+
+@st.cache(allow_output_mutation=True)
+def get_pngs(date):
+    year, month, day = date[:4], date[4:6], date[6:]
+    url = f'https://mrms.nssl.noaa.gov/qvs/product_viewer/local/render_multi_domain_product_layer.php?mode=run&cpp_exec_dir=/home/metop/web/specific/opv/&web_resources_dir=/var/www/html/qvs/product_viewer/resources/&prod_root={prod_root}&qperate_pal_option=0&qpe_pal_option=0&year={year}&month={month}&day={day}&hour={hour}&minute={minute}&clon={lon}&clat={lat}&zoom={zoom}&width=920&height=630'
+    # data = imread(url,verify=False)[:, :, :3]
+    response = requests.get(url,verify=False)
+    image_data = io.BytesIO(response.content)
+    data = imread(image_data)[:, :, :3]
+    
+    data2 = data.reshape(630*920, 3)
+    data2_df = pd.DataFrame(data2, columns=['R', 'G', 'B'])
+    data2_df2 = pd.merge(data2_df, lut[['R', 'G', 'B', 'Hail Scale', 'Hail Scale In']], on=['R', 'G', 'B'],
+                         how='left')[['Hail Scale', 'Hail Scale In']]
+    data2_df2['Date'] = date
+    return data2_df2.reset_index()
+
+
+@st.cache(allow_output_mutation=True)
+def get_pngs_parallel(dates):
+    results1 = Parallel(n_jobs=32, prefer="threads")(
+        delayed(get_pngs)(i) for i in dates)
+    return results1
+
+
+@st.cache(allow_output_mutation=True)
+def png_data(date):
+    year, month, day = date[:4], date[4:6], date[6:]
+    url = f'https://mrms.nssl.noaa.gov/qvs/product_viewer/local/render_multi_domain_product_layer.php?mode=run&cpp_exec_dir=/home/metop/web/specific/opv/&web_resources_dir=/var/www/html/qvs/product_viewer/resources/&prod_root={prod_root}&qperate_pal_option=0&qpe_pal_option=0&year={year}&month={month}&day={day}&hour={hour}&minute={minute}&clon={lon}&clat={lat}&zoom={zoom}&width=920&height=630'
+    response = requests.get(url,verify=False)
+    image_data = io.BytesIO(response.content)
+    data = imread(image_data)
+
+    # data = imread(url,verify=False)
+    return data
+
+
+@st.cache(allow_output_mutation=True)
+def map_folium(data, gdf):
+    m = folium.Map(location=[lat, lon],  zoom_start=zoom, height=300)
+    folium.Marker(
+        location=[lat, lon],
+        popup=address).add_to(m)
+
+    folium.GeoJson(gdf['buffer']).add_to(m)
     folium.raster_layers.ImageOverlay(
         data, opacity=0.8, bounds=bounds).add_to(m)
     return m
@@ -212,4 +315,7 @@ except:
 st.markdown(""" <style>
 #MainMenu {visibility: hidden;}
 footer {visibility: hidden;}
-</style> """, unsafe_allow_html=True)
+</style> """, unsafe_allow_html=True)
+
+
+