Update app.py

app.py

@@ -13,44 +13,44 @@ from functions import decode_features
 #import functions
 
 def greet(total_pred_days):
-
+    str1 = ""
     
-    print("hi")
+#    print("hi")
     project = hopsworks.login()
     print("connected")
-    #api = project.get_dataset_api()
-    
-
-    # The latest available data timestamp
-    start_time = 1649196000000
-
-   # end_time = 1670972400000
-
-    #start_date = datetime.now() - timedelta(days=1)
-    #start_time = int(start_date.timestamp()) * 1000
-
-    print("Time Stamp Set. ")
-    
-    
-
-    print("latest_date")
-   
-    mr=project.get_model_registry()
-    model = mr.get_model("temp_model", version=2)
-    model_dir=model.download()
-    
-    model1 = mr.get_model("tempmax_model", version=2) 
-    model_dir1=model1.download()
-
-    model2 = mr.get_model("tempmin_model", version=2)
-    model_dir2=model2.download()
-    
-    model = joblib.load(model_dir + "/model_temp.pkl")
-    model1 = joblib.load(model_dir1 + "/model_tempmax.pkl")
-    model2 = joblib.load(model_dir2+ "/model_tempmin.pkl")
-
-    print("temp_model is now right")
-         
+#    #api = project.get_dataset_api()
+#    
+#
+#    # The latest available data timestamp
+    start_time = 20221201
+#
+#   # end_time = 1670972400000
+#
+#    #start_date = datetime.now() - timedelta(days=1)
+#    #start_time = int(start_date.timestamp()) * 1000
+#
+#    print("Time Stamp Set. ")
+#    
+#    
+#
+#    print("latest_date")
+#   
+#    mr=project.get_model_registry()
+#    model = mr.get_model("temp_model", version=2)
+#    model_dir=model.download()
+#    
+#    model1 = mr.get_model("tempmax_model", version=2) 
+#    model_dir1=model1.download()
+#
+#    model2 = mr.get_model("tempmin_model", version=2)
+#    model_dir2=model2.download()
+#    
+#    model = joblib.load(model_dir + "/model_temp.pkl")
+#    model1 = joblib.load(model_dir1 + "/model_tempmax.pkl")
+#    model2 = joblib.load(model_dir2+ "/model_tempmin.pkl")
+#
+#    print("temp_model is now right")
+#         
     fs = project.get_feature_store()
     print("get the store")
     feature_view = fs.get_feature_view(
@@ -59,38 +59,39 @@ def greet(total_pred_days):
     )
     print("get the fv")
     X = feature_view.get_batch_data(start_time=start_time)
-    print("Data batched")
-    latest_date_unix = str(X.datetime.values[0])[:10]
-    latest_date = time.ctime(int(latest_date_unix))
-    X = X.drop(columns=["datetime"]).fillna(0)
-    preds = model.predict(X)
-    preds1= model1.predict(X)
-    preds2= model2.predict(X)
-    
-    
-
-   # cities = [city_tuple[0] for city_tuple in cities_coords.keys()]
-
-    next_day_date = datetime.today() + timedelta(days=1)
-    next_day = next_day_date.strftime ('%d/%m/%Y')
-    str1 = ""
-    
-    if(total_pred_days == ""):
-        return "Empty input"
-    
-    count = int(total_pred_days)
-    if count > 20:
-        str1 += "Warning: 20 days at most. " + '\n'
-        count = 20
-    if count <0:
-        str1 = "Invalid input."
-        return str1
-    
-    for x in range(count):
-        if (x != 0):
-            str1 += (datetime.now() + timedelta(days=x)).strftime('%Y-%m-%d') + " predicted temperature:      " +str(int(preds[len(preds) - count + x]))+ " predicted max temperature:      " +str(int(preds1[len(preds1) - count + x]))+ " predicted min temperature:      " +str(int(preds2[len(preds2) - count + x]))+"\n"
-    
-    #print(str1)
+    print(X)
+#    print("Data batched")
+#    latest_date_unix = str(X.datetime.values[0])[:10]
+#    latest_date = time.ctime(int(latest_date_unix))
+#    X = X.drop(columns=["datetime"]).fillna(0)
+#    preds = model.predict(X)
+#    preds1= model1.predict(X)
+#    preds2= model2.predict(X)
+#    
+#    
+#
+#   # cities = [city_tuple[0] for city_tuple in cities_coords.keys()]
+#
+#    next_day_date = datetime.today() + timedelta(days=1)
+#    next_day = next_day_date.strftime ('%d/%m/%Y')
+#    str1 = ""
+#    
+#    if(total_pred_days == ""):
+#        return "Empty input"
+#    
+#    count = int(total_pred_days)
+#    if count > 20:
+#        str1 += "Warning: 20 days at most. " + '\n'
+#        count = 20
+#    if count <0:
+#        str1 = "Invalid input."
+#        return str1
+#    
+#    for x in range(count):
+#        if (x != 0):
+#            str1 += (datetime.now() + timedelta(days=x)).strftime('%Y-%m-%d') + " predicted temperature:      " +str(int(preds[len(preds) - count + x]))+ " predicted max temperature:      " +str(int(preds1[len(preds1) - count + x]))+ " predicted min temperature:      " +str(int(preds2[len(preds2) - count + x]))+"\n"
+#    
+#    #print(str1)
     return str1