Update functions.py

functions.py

@@ -41,8 +41,57 @@ def decode_features(df, feature_view):
 def get_air_json(AIR_QUALITY_API_KEY):
     return requests.get(f'https://api.waqi.info/feed/Helsinki/?token={AIR_QUALITY_API_KEY}').json()['data']
 
+def get_weather_json_quick(date):
+    return requests.get(f'https://weather.visualcrossing.com/VisualCrossingWebServices/rest/services/timeline/helsinki/{date}?unitGroup=metric&include=days&key=J7TT2WGMUNNHD8JBEDXAJJXB2&contentType=json').json()
 
 
+def get_weather_data(json):
+
+    data = json['days'][0]
+    print("data parsed sccessfully")
+
+    return data
+
+
+def get_weather_df(data):
+    col_names = [
+        'name',
+        'datetime',
+        'tempmax',
+        'tempmin',
+        'temp',
+        'feelslikemax',
+        'feelslikemin',
+        'feelslike',
+        'dew',
+        'humidity',
+        'precip',
+        'precipprob',
+        'precipcover',
+        'snow',
+        'snowdepth',
+        'windgust',
+        'windspeed',
+        'winddir',
+        'sealevelpressure',
+        'cloudcover',
+        'visibility',
+        'solarradiation',
+        'solarenergy',
+        'uvindex',
+        'conditions'
+    ]
+
+    
+
+    new_data = pd.DataFrame(
+        data,
+        columns=col_names
+    )
+    new_data.datetime = new_data.datetime.apply(timestamp_2_time1)
+    #new_data.rename(columes={'pressure':'sealevelpressure'})
+    return new_data
+
 def get_air_quality_data1():
     
     AIR_QUALITY_API_KEY = os.getenv('AIR_QUALITY_API_KEY')