Spaces:
Runtime error
Runtime error
| from logging import getLogger | |
| from pathlib import Path | |
| import pandas as pd | |
| import plotly.express as px | |
| import streamlit as st | |
| from st_aggrid import AgGrid, ColumnsAutoSizeMode, GridOptionsBuilder | |
| from utilities import initialization | |
| initialization() | |
| # @st.cache(show_spinner=False) | |
| # def initialize_state(): | |
| # with st.spinner("Loading app..."): | |
| # if 'model' not in st.session_state: | |
| # model = Top2Vec.load('models/model.pkl') | |
| # model._check_model_status() | |
| # model.hierarchical_topic_reduction(num_topics=20) | |
| # | |
| # st.session_state.model = model | |
| # st.session_state.umap_model = joblib.load(proj_dir / 'models' / 'umap.sav') | |
| # logger.info("loading data...") | |
| # | |
| # if 'data' not in st.session_state: | |
| # logger.info("loading data...") | |
| # data = pd.read_csv(proj_dir / 'data' / 'data.csv') | |
| # data['topic_id'] = data['topic_id'].apply(lambda x: f'{x:02d}') | |
| # st.session_state.data = data | |
| # st.session_state.selected_data = data | |
| # st.session_state.all_topics = list(data.topic_id.unique()) | |
| # | |
| # if 'topics' not in st.session_state: | |
| # logger.info("loading topics...") | |
| # topics = pd.read_csv(proj_dir / 'data' / 'topics.csv') | |
| # topics['topic_id'] = topics['topic_id'].apply(lambda x: f'{x:02d}') | |
| # st.session_state.topics = topics | |
| # | |
| # st.session_state.selected_points = [] | |
| def main(): | |
| max_docs = st.sidebar.slider("# docs", 10, 100, value=50) | |
| to_search = st.text_input("Write your query here", "") or "" | |
| with st.spinner('Embedding Query...'): | |
| vector = st.session_state.model.embed([to_search]) | |
| with st.spinner('Dimension Reduction...'): | |
| point = st.session_state.umap_model.transform(vector.reshape(1, -1)) | |
| documents, document_scores, document_ids = st.session_state.model.search_documents_by_vector(vector.flatten(), | |
| num_docs=max_docs) | |
| st.session_state.search_raw_df = pd.DataFrame({'document_ids': document_ids, 'document_scores': document_scores}) | |
| st.session_state.data_to_model = st.session_state.data.merge(st.session_state.search_raw_df, left_on='id', | |
| right_on='document_ids').drop(['document_ids'], axis=1) | |
| st.session_state.data_to_model = st.session_state.data_to_model.sort_values(by='document_scores', | |
| ascending=False) # to make legend sorted https://bioinformatics.stackexchange.com/a/18847 | |
| st.session_state.data_to_model.loc[len(st.session_state.data_to_model.index)] = ['Point', *point[0].tolist(), | |
| to_search, 'Query', 0] | |
| st.session_state.data_to_model_with_point = st.session_state.data_to_model | |
| st.session_state.data_to_model_without_point = st.session_state.data_to_model.iloc[:-1] | |
| def get_topics_counts() -> pd.DataFrame: | |
| topic_counts = st.session_state.data_to_model_without_point["topic_id"].value_counts().to_frame() | |
| merged = topic_counts.merge(st.session_state.topics, left_index=True, right_on='topic_id') | |
| cleaned = merged.drop(['topic_id_y'], axis=1).rename({'topic_id_x': 'topic_count'}, axis=1) | |
| cols = ['topic_id'] + [col for col in cleaned.columns if col != 'topic_id'] | |
| return cleaned[cols] | |
| st.write(""" | |
| # Semantic Search | |
| This shows a 2d representation of documents embeded in a semantic space. Each dot is a document | |
| and the dots close represent documents that are close in meaning. | |
| Note that the distance metrics were computed at a higher dimension so take the representation with | |
| a grain of salt. | |
| The Query is shown with the documents in yellow. | |
| """ | |
| ) | |
| df = st.session_state.data_to_model_with_point.sort_values(by='topic_id', ascending=True) | |
| fig = px.scatter(df.iloc[:-1], x='x', y='y', color='topic_id', template='plotly_dark', | |
| hover_data=['id', 'topic_id', 'x', 'y']) | |
| fig.add_traces(px.scatter(df.tail(1), x="x", y="y").update_traces(marker_size=10, marker_color="yellow").data) | |
| st.plotly_chart(fig, use_container_width=True) | |
| tab1, tab2 = st.tabs(["Docs", "Topics"]) | |
| with tab1: | |
| cols = ['id', 'document_scores', 'topic_id', 'documents'] | |
| data = st.session_state.data_to_model_without_point.loc[:, cols] | |
| data['topic_word'] = data.topic_id.replace(st.session_state.topic_str_to_word) | |
| ordered_cols = ['id', 'document_scores', 'topic_id', 'topic_word', 'documents'] | |
| builder = GridOptionsBuilder.from_dataframe(data[ordered_cols]) | |
| builder.configure_pagination() | |
| builder.configure_column('document_scores', type=["numericColumn", "numberColumnFilter", "customNumericFormat"], | |
| precision=2) | |
| go = builder.build() | |
| AgGrid(data[ordered_cols], theme='streamlit', gridOptions=go, | |
| columns_auto_size_mode=ColumnsAutoSizeMode.FIT_CONTENTS) | |
| with tab2: | |
| cols = ['topic_id', 'topic_count', 'topic_0'] | |
| topic_counts = get_topics_counts() | |
| builder = GridOptionsBuilder.from_dataframe(topic_counts[cols]) | |
| builder.configure_pagination() | |
| builder.configure_column('topic_0', header_name='Topic Word', wrap_text=True) | |
| go = builder.build() | |
| AgGrid(topic_counts.loc[:, cols], theme='streamlit', gridOptions=go, | |
| columns_auto_size_mode=ColumnsAutoSizeMode.FIT_ALL_COLUMNS_TO_VIEW) | |
| if __name__ == "__main__": | |
| # Setting up Logger and proj_dir | |
| logger = getLogger(__name__) | |
| proj_dir = Path(__file__).parents[2] | |
| # For max width tables | |
| pd.set_option('display.max_colwidth', 0) | |
| # Streamlit settings | |
| # st.set_page_config(layout="wide") | |
| md_title = "# Semantic Search 🔍" | |
| st.markdown(md_title) | |
| st.sidebar.markdown(md_title) | |
| # initialize_state() | |
| main() | |