My Reddit: an exploratory NLP project on reddit data

This website is a fully featured demonstrator of a Natural Language Processing (NLP) application: from data extraction to end user application, we've covered the whole lifecycle of a NLP application with a modern and open-source NLP data stack.

• The data is extracted from Reddit API, loaded into a https://cloud.google.com/bigquery DB.
• It is then locally transformed using https://www.getdbt.com/
• The texts are cleaned and preprocessed using https://github.com/chartbeat-labs/textacy
• Models are trained using https://spacy.io
• Models are served using https://fastapi.tiangolo.com/
• Models are monitored and new unknown data is annotated through https://www.rubrix.ml/
• Model performance and data are monitored through dashboard made with https://www.metabase.com/
• End user applications are demonstrated using https://streamlit.io

flowchart TD
    %% EL[T]
    reddit[[Reddit API]] --- ELT[\Extract Load - python/dagster/]
    ELT --> posts{{posts + comments}}
    %% [EL]T DBT processes
    posts --- pdbt[\Transform - DBT/]
    pdbt --> stats{{Statistics}}
    pdbt --> txt{{Texts}}
    %% Dashboards
    stats --- cube[\Aggregation/DataViz - Cube JS/] --> Dashboards
    %% Clean texts
    txt --- textacy[\Preprocessing - Textacy/] --> clean{{Clean Texts}}
    %% Subreddit prediction (trivial)
    txtcattr[\Train - Spacy/Transformers/] --> perfs{{Performances}}
    perfs --- cube
    clean --- txtcattr --> srmodel([Models])
    clean --- txtcatpr[\Batch Predictions/] --> prtxtcat{{Predictions}}
    srmodel --- txtcatpr
    %% APIs
    srmodel --> modelapi[[Prediction API - FastAPI]]
    %% Apps
    srmodel --> apps[Applications - Streamlit]
    clean --> apps

Loading

Legend:

flowchart TD
    legendapi[[API]]
    legendtr[\Transformation/]
    legenddb{{Data}}
    ledendweb[Web UI]

Loading

Architecture

Features

NLP Features

Implemented:

• Syntactic analysis with Spacy
• Topic Modeling with BERTopic
• Text classification with custom model

Coming Soon:

• Language detection
• Topic Modeling algorithm comparison

Product

• A dashboard app based on cubeJS
• A frontend which integrates all administration web UIs
• Data collection on demand & on schedules
• Cloud Database (BigQuery)
• On demand & scheduled model training
• APIs to serve models
• MLOps for NLP with explainability
• Interactive Apps