Upload precipitation.py

stlib/precipitation.py

@@ -8,11 +8,11 @@ from streamlit_folium import st_folium
 from branca.element import Figure
 
 
-from precipitation_function import date_split,lat_long_process_precp
+from precipitation_function import date_split,lat_long_process_precp,load_data
 from precipitation_function import concat_func, drop_dup_funct,lat_long_type
 from precipitation_function import daily_precp_plot,start_end_date_ui,lat_long_ui,year_selection_ui
 from precipitation_function import monthly_mean_plot, annual_max_precip_plot,daily_precp_data,cumulative_plot
-from precipitation_function import annual_max_precip_plot,annual_min_precip_plot,annual_avg_plot,max_precip,min_precip,avg_precip,cumulative
+from precipitation_function import annual_max_precip_plot,annual_min_precip_plot,annual_avg_plot,max_precip,min_precip,avg_precip,cumulative,main_concat
 
 from temperature_functions import convert_df, map_creation, search_func
 
@@ -24,80 +24,50 @@ def run():
     start = pd.to_datetime('2001/01/01')
     end = pd.to_datetime('2019/12/31')
 
-    #precipitation data
-    # bucket_name = "timeseries_data_storage"
-    # file_path_1 = "precip_data/precip1.zip"
-    # file_path_2 = "precip_data/precip2.zip"
-    # file_path_3 = "precip_data/precip3.zip"
-    # file_path_4 = "precip_data/precip4.zip"
-    # file_path_5 = "precip_data/precip5.zip"
-    # file_path_6 = "precip_data/precip6.zip"
-    # file_path_7 = "precip_data/precip7.zip"
-    # file_path_8 = "precip_data/precip8.zip"
-    # file_path_9 = "precip_data/precip9.zip"
-    # file_path_10 = "precip_data/precip10.zip"
-    # file_path_11 = "precip_data/precip11.zip"
-    # file_path_12 = "precip_data/precip12.zip"
-    # file_path_13 = "precip_data/precip13.zip"
-    # file_path_14 = "precip_data/precip14.zip"
-    # file_path_15 = "precip_data/precip15.zip"
-    # file_path_16 = "precip_data/precip16.zip"
-
-
-
-    precipitation_1_og = pd.read_csv('historicalData/precip1.zip',compression = 'zip')
-    precipitation_2_og = pd.read_csv('historicalData/precip2.zip',compression = 'zip')
-    precipitation_3_og = pd.read_csv('historicalData/precip3.zip',compression = 'zip')
-    precipitation_4_og = pd.read_csv('historicalData/precip4.zip',compression = 'zip')
-    precipitation_5_og = pd.read_csv('historicalData/precip5.zip',compression = 'zip')
-    precipitation_6_og = pd.read_csv('historicalData/precip6.zip',compression = 'zip')
-    precipitation_7_og = pd.read_csv('historicalData/precip7.zip',compression = 'zip')
-    precipitation_8_og = pd.read_csv('historicalData/precip8.zip',compression = 'zip')
-    precipitation_9_og = pd.read_csv('historicalData/precip9.zip',compression = 'zip')
-    precipitation_10_og = pd.read_csv('historicalData/precip10.zip',compression = 'zip')
-    precipitation_11_og = pd.read_csv('historicalData/precip11.zip',compression = 'zip')
-    precipitation_12_og = pd.read_csv('historicalData/precip12.zip',compression = 'zip')
-    precipitation_13_og = pd.read_csv('historicalData/precip13.zip',compression = 'zip')
-    precipitation_14_og = pd.read_csv('historicalData/precip14.zip',compression = 'zip')
-    precipitation_15_og = pd.read_csv('historicalData/precip15.zip',compression = 'zip')
-    precipitation_16_og = pd.read_csv('historicalData/precip16.zip',compression = 'zip')
+    p1 = 'historicalData/precip1.zip'
+    p2 = 'historicalData/precip2.zip'
+    # p3 = 'historicalData/precip3.zip'
+    # p4 = 'historicalData/precip4.zip'
+    # p5 = 'historicalData/precip5.zip'
+    # p6 = 'historicalData/precip6.zip'
+    # p7 = 'historicalData/precip7.zip'
+    # p8 = 'historicalData/precip8.zip'
+
+    precipitation_1_og = load_data(p1)
+    precipitation_2_og = load_data(p2)
+    # precipitation_3_og = load_data(p3)
+    # precipitation_4_og = load_data(p4)
+    # precipitation_5_og = load_data(p5)
+    # precipitation_6_og = load_data(p6)
+    # precipitation_7_og = load_data(p7)
+    # precipitation_8_og = load_data(p8)
 
 
     lat_long_precipitation_1 = precipitation_1_og['lat_long']
     lat_long_precipitation_2 = precipitation_2_og['lat_long']
-    lat_long_precipitation_3 = precipitation_3_og['lat_long']
-    lat_long_precipitation_4 = precipitation_4_og['lat_long']
-    lat_long_precipitation_5 = precipitation_5_og['lat_long']
-    lat_long_precipitation_6 = precipitation_6_og['lat_long']
-    lat_long_precipitation_7 = precipitation_7_og['lat_long']
-    lat_long_precipitation_8 = precipitation_8_og['lat_long']
-    lat_long_precipitation_9 = precipitation_9_og['lat_long']
-    lat_long_precipitation_10 = precipitation_10_og['lat_long']
-    lat_long_precipitation_11 = precipitation_11_og['lat_long']
-    lat_long_precipitation_12 = precipitation_12_og['lat_long']
-    lat_long_precipitation_13 = precipitation_13_og['lat_long']
-    lat_long_precipitation_14 = precipitation_14_og['lat_long']
-    lat_long_precipitation_15 = precipitation_15_og['lat_long']
-    lat_long_precipitation_16 = precipitation_16_og['lat_long']
-
-
-
-    lat_long_precipitation_list_1 = concat_func(lat_long_precipitation_1,lat_long_precipitation_2,lat_long_precipitation_3,lat_long_precipitation_4)
-    lat_long_precipitation_list_2 = concat_func(lat_long_precipitation_5,lat_long_precipitation_6,lat_long_precipitation_7,lat_long_precipitation_8)
-    lat_long_precipitation_list_3 = concat_func(lat_long_precipitation_9,lat_long_precipitation_10,lat_long_precipitation_11,lat_long_precipitation_12)
-    lat_long_precipitation_list_4 = concat_func(lat_long_precipitation_13,lat_long_precipitation_14,lat_long_precipitation_15,lat_long_precipitation_16)
-    lat_long_precipitation_list   = concat_func(lat_long_precipitation_list_1,lat_long_precipitation_list_2,lat_long_precipitation_list_3,lat_long_precipitation_list_4)
-
-
-    precipitation_conc_1 = concat_func(precipitation_1_og,precipitation_2_og,precipitation_3_og,precipitation_4_og)
-    precipitation_conc_2 = concat_func(precipitation_5_og,precipitation_6_og,precipitation_7_og,precipitation_8_og)
-    precipitation_conc_3 = concat_func(precipitation_9_og,precipitation_10_og,precipitation_11_og,precipitation_12_og)
-    precipitation_conc_4 = concat_func(precipitation_13_og,precipitation_14_og,precipitation_15_og,precipitation_16_og)
-    precipitation = concat_func(precipitation_conc_1,precipitation_conc_2,precipitation_conc_3,precipitation_conc_4)
+    # lat_long_precipitation_3 = precipitation_3_og['lat_long']
+    # lat_long_precipitation_4 = precipitation_4_og['lat_long']
+    # lat_long_precipitation_5 = precipitation_5_og['lat_long']
+    # lat_long_precipitation_6 = precipitation_6_og['lat_long']
+    # lat_long_precipitation_7 = precipitation_7_og['lat_long']
+    # lat_long_precipitation_8 = precipitation_8_og['lat_long']
+
+
+
+    # lat_long_precipitation_list_1 = concat_func(lat_long_precipitation_1,lat_long_precipitation_2,lat_long_precipitation_3,lat_long_precipitation_4)
+    lat_long_precipitation_list = concat_func(lat_long_precipitation_1,lat_long_precipitation_2)
+    # lat_long_precipitation_list_2 = concat_func(lat_long_precipitation_5,lat_long_precipitation_6,lat_long_precipitation_7,lat_long_precipitation_8)
+    # lat_long_precipitation_list   = main_concat(lat_long_precipitation_list_1,lat_long_precipitation_list_2)
+
+
+    # precipitation_conc_1 = concat_func(precipitation_1_og,precipitation_2_og,precipitation_3_og,precipitation_4_og)
+    precipitation = concat_func(precipitation_1_og,precipitation_2_og)
+
+    # precipitation_conc_2 = concat_func(precipitation_5_og,precipitation_6_og,precipitation_7_og,precipitation_8_og)
+    # precipitation = main_concat(precipitation_conc_1,precipitation_conc_2)
 
     # precipitation = precipitation.drop([Unnamed:0.2,Unnamed:0.1,Unnamed:0],axis =1)
     precipitation.drop(precipitation.filter(regex="Unnamed"),axis=1, inplace=True)
-    # st.write(precipitation.head())
     precipitation_temp = precipitation.copy()
     precipitation_temp = precipitation_temp.groupby('lat_long')
 
@@ -110,10 +80,23 @@ def run():
     if data_type == "Cumulative Monthly Precipitation":
         col1,col2 = st.columns(2)
         with col1:
-            start_year,end_year = year_selection_ui(99,100)
+            # start_year,end_year = year_selection_ui(99,100)
+            st.markdown('**Select the Start Year**')
+            start_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 99)
+
+            st.markdown('**Select the End Year**')
+            end_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key =100)
         with col2:
             #calling the ui method to create a lat long input UI
-            latitude_input,longitude_input = lat_long_ui(300,400)
+            # latitude_input,longitude_input = lat_long_ui(300,400)
+            st.markdown('**Enter the latitude**')
+            latitude_input = st.text_input('','12.55',key = 1)
+            st.markdown('**Enter the longitude**')
+            longitude_input = st.text_input('','42.45',key = 2)
 
 
         latitude_input,longitude_input= float(latitude_input),float(longitude_input)
@@ -164,9 +147,22 @@ def run():
         col1,col2 = st.columns(2)
         with col1:
             #calling the ui method to create a start end date input UI
-            start,end = start_end_date_ui(start,end,11,22)
+            # start,end = start_end_date_ui(start,end,11,22)
+            st.markdown('**Enter Start Date**')
+            start = st.date_input("",value = start,key = 9000)
+            if start < pd.to_datetime('2001/01/01'):
+                st.write('Start date should not be less than 2001/01/01')
+
+            st.markdown('**Enter End Date**')
+            end = st.date_input("",value = end, key = 900)
+            if end > pd.to_datetime('2019/12/31'):
+                st.write('End date should not be greater than 2019/12/31')
         with col2:
-            latitude_input,longitude_input = lat_long_ui(1,2)
+            # latitude_input,longitude_input = lat_long_ui(1,2)
+            st.markdown('**Enter the latitude**')
+            latitude_input = st.text_input('','12.55',key = 132)
+            st.markdown('**Enter the longitude**')
+            longitude_input = st.text_input('','42.45',key = 223)
 
 
         latitude_input,longitude_input= float(latitude_input),float(longitude_input)
@@ -220,10 +216,23 @@ def run():
     elif data_type == 'Monthly Average Precipitation':
         col1,col2 = st.columns(2)
         with col1:
-            start_year,end_year = year_selection_ui(9,10)
+            # start_year,end_year = year_selection_ui(9,10)
+            st.markdown('**Select the Start Year**')
+            start_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 9)
+
+            st.markdown('**Select the End Year**')
+            end_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 10)
         with col2:
             #calling the ui method to create a lat long input UI
-            latitude_input,longitude_input = lat_long_ui(3,4)
+            # latitude_input,longitude_input = lat_long_ui(3,4)
+            st.markdown('**Enter the latitude**')
+            latitude_input = st.text_input('','12.55',key = 134)
+            st.markdown('**Enter the longitude**')
+            longitude_input = st.text_input('','42.45',key = 256)
 
         latitude_input,longitude_input= float(latitude_input),float(longitude_input)
         nearest_lat_long = search_func(latitude_input,longitude_input,lat_long_precipitation_list,precipitation)
@@ -278,10 +287,23 @@ def run():
     elif data_type == 'Annual Maximum Precipitation':
         col1,col2 = st.columns(2)
         with col1:
-            start_year,end_year = year_selection_ui(11,12)
+            # start_year,end_year = year_selection_ui(11,12)
+            st.markdown('**Select the Start Year**')
+            start_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 111)
+
+            st.markdown('**Select the End Year**')
+            end_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key =222)
         with col2:
             #calling the ui method to create a lat long input UI
-            latitude_input,longitude_input = lat_long_ui(5,6)
+            # latitude_input,longitude_input = lat_long_ui(5,6)
+            st.markdown('**Enter the latitude**')
+            latitude_input = st.text_input('','12.55',key = 145)
+            st.markdown('**Enter the longitude**')
+            longitude_input = st.text_input('','42.45',key = 267)
 
         latitude_input,longitude_input= float(latitude_input),float(longitude_input)
         nearest_lat_long = search_func(latitude_input,longitude_input,lat_long_precipitation_list,precipitation)
@@ -328,10 +350,23 @@ def run():
     elif data_type == 'Annual Minimum Precipitation':
         col1,col2 = st.columns(2)
         with col1:
-            start_year,end_year = year_selection_ui(13,14)
+            # start_year,end_year = year_selection_ui(13,14)
+            st.markdown('**Select the Start Year**')
+            start_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 13)
+
+            st.markdown('**Select the End Year**')
+            end_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 14)
         with col2:
             #calling the ui method to create a lat long input UI
-            latitude_input,longitude_input = lat_long_ui(7,8)
+            # latitude_input,longitude_input = lat_long_ui(7,8)
+            st.markdown('**Enter the latitude**')
+            latitude_input = st.text_input('','12.55',key = 109)
+            st.markdown('**Enter the longitude**')
+            longitude_input = st.text_input('','42.45',key = 209)
 
         latitude_input,longitude_input= float(latitude_input),float(longitude_input)
         nearest_lat_long = search_func(latitude_input,longitude_input,lat_long_precipitation_list,precipitation)
@@ -380,10 +415,23 @@ def run():
     elif data_type == 'Annual Average Precipitation':
         col1,col2 = st.columns(2)
         with col1:
-            start_year,end_year = year_selection_ui(15,16)
+            # start_year,end_year = year_selection_ui(15,16)
+            st.markdown('**Select the Start Year**')
+            start_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 15)
+
+            st.markdown('**Select the End Year**')
+            end_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 26)
         with col2:
             #calling the ui method to create a lat long input UI
-            latitude_input,longitude_input = lat_long_ui(9,10)
+            # latitude_input,longitude_input = lat_long_ui(9,10)
+            st.markdown('**Enter the latitude**')
+            latitude_input = st.text_input('','12.55',key = 198)
+            st.markdown('**Enter the longitude**')
+            longitude_input = st.text_input('','42.45',key =298)
 
         latitude_input,longitude_input= float(latitude_input),float(longitude_input)
         nearest_lat_long = search_func(latitude_input,longitude_input,lat_long_precipitation_list,precipitation)
@@ -428,10 +476,23 @@ def run():
     elif data_type == 'Annual Max, Min, & Average Precipitation':
         col1,col2 = st.columns(2)
         with col1:
-            start_year,end_year = year_selection_ui(17,18)
+            # start_year,end_year = year_selection_ui(17,18)
+            st.markdown('**Select the Start Year**')
+            start_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 1111)
+
+            st.markdown('**Select the End Year**')
+            end_year = st.selectbox('',
+                                      ('2001','2002','2003','2004','2005','2006','2007','2008','2009',
+                                      '2010','2011','2012','2013','2014','2015','2016','2017','2018','2019'),key = 2222)
 
         with col2:
-            latitude_input,longitude_input = lat_long_ui(11,12)
+            # latitude_input,longitude_input = lat_long_ui(11,12)
+            st.markdown('**Enter the latitude**')
+            latitude_input = st.text_input('','12.55',key = 186)
+            st.markdown('**Enter the longitude**')
+            longitude_input = st.text_input('','42.45',key = 2543)
 
         latitude_input,longitude_input= float(latitude_input),float(longitude_input)
         nearest_lat_long = search_func(latitude_input,longitude_input,lat_long_precipitation_list,precipitation)