Add app

app.py

@@ -0,0 +1,103 @@
+import os
+import hopsworks
+import pandas as pd
+import streamlit as st
+import seaborn as sns
+import matplotlib.pyplot as plt
+
+#from dotenv import load_dotenv
+#load_dotenv()
+
+@st.experimental_memo
+def load_data():
+    project = hopsworks.login()
+    fs = project.get_feature_store()
+
+    #if not os.path.isfile("./cache/batch_data.pkl"):
+    #    if not os.path.isdir("./cache"):
+    #        os.mkdir("./cache")
+    posts_fg = fs.get_feature_group("reddit_posts", version=os.getenv("POSTS_FG_VERSION", default=1))
+    users_fg = fs.get_feature_group("reddit_users", version=os.getenv("USERS_FG_VERSION", default=1))
+    subreddits_fg = fs.get_feature_group("reddit_subreddits", version=os.getenv("SUBREDDITS_FG_VERSION", default=1))
+    full_join = posts_fg.select(features=["post_id", "snapshot_time", "num_likes", "upvote_ratio"]).join(
+                        users_fg.select(features=["user_id", "snapshot_time"]), on=["user_id", "snapshot_time"]).join(
+                            subreddits_fg.select(features=["subreddit_id", "snapshot_time"]), on=["subreddit_id", "snapshot_time"])
+    df = full_join.read()
+
+    #    df.to_pickle("./cache/batch_data.pkl")
+    #else:
+    #    df = pd.read_pickle("./cache/batch_data.pkl")
+
+    # Load model including the generated images and evaluation scores
+    mr = project.get_model_registry()
+    model_hsfs = mr.get_model("reddit_predict", version=16)
+    model_dir = model_hsfs.download()
+    print("Model directory: {}".format(model_dir))
+
+    metric_rows = {}
+    metrics_avail = [m.replace("_likes","") for m in model_hsfs.training_metrics if "_likes" in m]
+    for target in ["likes", "upvote_ratio"]:
+        metric_rows[target] = []
+        for metric in metrics_avail:
+            metric_rows[target].append(model_hsfs.training_metrics[f"{metric}_{target}"])
+    df_metrics = pd.DataFrame(metric_rows, index=metrics_avail)
+
+    img_predictions = plt.imread(f"{model_dir}/prediction_error.png")
+    img_predictions_logscale = plt.imread(f"{model_dir}/prediction_error_logscale.png")
+
+    return df, img_predictions, img_predictions_logscale, df_metrics
+
+
+df, img_predictions, img_predictions_logscale, df_metrics = load_data()
+
+# create a distribution plot of the number of likes using seaborn
+st.title("Like It or Not")
+st.markdown("This is the dashboard for the Like It Or Not model that predict the number of likes and the upvote ratio that a Reddit post is going to get.")
+
+# Data stats
+st.markdown("## Data Statistics")
+col1, col2, col3 = st.columns(3)
+col1.metric("Unqiue Posts", str(df["post_id"].nunique()))
+col2.metric("Unique Users", str(df["user_id"].nunique()))
+col3.metric("Unique Subreddits", str(df["subreddit_id"].nunique()))
+
+# Distribution of the target variables
+col1, col2 = st.columns(2)
+col1.markdown("### Distribution of Number of Likes")
+col2.markdown("### Distribution of Upvote Ratio")
+col1, col2 = st.columns(2)
+fig, ax = plt.subplots()
+sns.histplot(df["num_likes"], ax=ax)
+ax.set_ylabel("Number of posts")
+ax.set_xlabel("Number of likes (log scale)")
+ax.set_xscale("log")
+plt.tight_layout()
+col1.pyplot(fig)
+
+fig2, ax = plt.subplots()
+sns.distplot(df["upvote_ratio"], ax=ax)
+ax.set_ylabel("Number of posts")
+plt.tight_layout()
+col2.pyplot(fig2)
+
+# Performance metrics
+st.markdown("## Performance Metrics")
+st.markdown("The model achieved the below scores on the test set. Please keep the effect of the sample weights in mind as explained in the Github repository. These reduce for example the R2 score from 0.75 to roughly 0. However, despite these low scores, the model is more useful in practice as it provides a meaningful lower bound estimate of the likes to be received as opposed to overestimating every post by up to 1500")
+st.dataframe(df_metrics)
+
+# Prediction error plots
+st.markdown("## Prediction Error Plots")
+st.markdown("The green line indicates the perfect prediction while the blue lines show point densities. Every point represents a prediction. The model is optimized for the number of likes and provides an estimate for the minimum number of likes expected. The upvote ratio does not perform well and would profit from dedicated modeling with another objective function if it is important.")
+st.markdown("### Linear Scale")
+st.image(img_predictions)
+st.markdown("### Log Scale")
+st.image(img_predictions_logscale)
+
+# Confusion matrix
+#st.markdown("## Confusion Matrix")
+#st.markdown("The confusion matrix of the model is as follows:")
+#st.image("confusion_matrix.png")
+
+# display the evaluation scores table
+#st.title("Evaluation Scores")
+#st.dataframe(df[["metric1", "metric2", "metric3", "metric4"]])

requirements.txt

@@ -0,0 +1,22 @@
+bayesian_optimization==1.4.2
+great_expectations==0.14.12
+hopsworks==3.0.5
+hsml==3.0.3
+joblib==1.2.0
+matplotlib==3.5.3
+modal==0.4.1
+modal_client==0.44.679
+numpy==1.21.6
+pandas==1.3.5
+praw==7.6.1
+pytest==7.2.0
+python-dotenv==0.21.0
+scikit_learn==1.2.0
+scipy==1.7.3
+seaborn==0.12.2
+sentence_transformers==2.2.2
+shap==0.41.0
+streamlit==1.16.0
+tqdm==4.64.1
+transformers==4.25.1
+xgboost==1.6.2