documentQABot / app.py
KrishnaKumar23's picture
Handled session state bug on page refresh
46c9b40
raw
history blame
8.13 kB
import streamlit as st
from streamlit_lottie import st_lottie
import fitz # PyMuPDF
import requests
import os, shutil
import llm_model
SYSTEM_PROMPT = [
"""
You are not Mistral AI, but rather a Q&A bot trained by Krishna Kumar while building a cool side project based on RAG. Whenever asked, you need to answer as Q&A bot.
""",
"""You are a RAG based Document Q&A bot. Based on the input prompt and retrieved context from the vector database you will answer questions that are closer to the context.
If no context was found then, say "I don't know" instead of making up answer on your own. Follow above rules strictly.
"""
]
@st.cache_data(experimental_allow_widgets=True)
def index_document(_llm_object, uploaded_file):
if uploaded_file is not None:
# Specify the folder path where you want to store the uploaded file in the 'assets' folder
assets_folder = "assets/uploaded_files"
if not os.path.exists(assets_folder):
os.makedirs(assets_folder)
# Save the uploaded file to the specified folder
file_path = os.path.join(assets_folder, uploaded_file.name)
with open(file_path, "wb") as f:
f.write(uploaded_file.getvalue())
file_name = os.path.join(assets_folder, uploaded_file.name)
st.success(f"File '{file_name}' uploaded !")
with st.spinner("Indexing document... This is a free CPU version and may take a while ⏳"):
retriever = _llm_object.create_vector_db(file_name)
return file_name, retriever
else:
return None, None
def load_lottieurl(url: str):
r = requests.get(url)
if r.status_code != 200:
return None
return r.json()
def is_query_valid(query: str) -> bool:
if not query:
st.error("Please enter a question!")
return False
return True
def init_state() :
if "filename" not in st.session_state:
st.session_state.filename = None
if "messages" not in st.session_state:
st.session_state.messages = []
if "temp" not in st.session_state:
st.session_state.temp = 0.7
if "history" not in st.session_state:
st.session_state.history = [SYSTEM_PROMPT]
if "repetion_penalty" not in st.session_state:
st.session_state.repetion_penalty = 1
if "chat_bot" not in st.session_state:
st.session_state.chat_bot = "Mixtral-8x7B-Instruct-v0.1"
def faq():
st.markdown(
"""
# FAQ
## How does Document Q&A Bot work?
When you upload a document (in Pdf, word, csv or txt format), it will be divided into smaller chunks
and stored in a special type of database called a vector index
that allows for semantic search and retrieval.
When you ask a question, our Q&A bot will first look through the document chunks and find the
most relevant ones using the vector index. This acts as a context to our custom prompt which will be feed to the LLM model.
If the context was not found in the document then, LLM will reply 'I don't know'
## Is my data safe?
Yes, your data is safe. Our bot does not store your documents or
questions. All uploaded data is deleted after you close the browser tab.
## Why does it take so long to index my document?
Since, this is a sample QA bot project that uses open-source model
and doesn't have much resource capabilities like GPU, it may take time
to index your document based on the size of the document.
## Are the answers 100% accurate?
No, the answers are not 100% accurate.
But for most use cases, our QA bot is very accurate and can answer
most questions. Always check with the sources to make sure that the answers
are correct.
"""
)
def sidebar():
with st.sidebar:
st.markdown("## Document Q&A Bot")
st.write("LLM: Mixtral-8x7B-Instruct-v0.1")
#st.success('API key already provided!', icon='βœ…')
st.markdown("### Set Model Parameters")
# select LLM model
st.session_state.model_name = 'Mixtral-8x7B-Instruct-v0.1'
# set model temperature
st.session_state.temperature = st.slider(label="Temperature", min_value=0.0, max_value=1.0, step=0.1, value=0.7)
st.session_state.top_p = st.slider(label="Top Probablity", min_value=0.0, max_value=1.0, step=0.1, value=0.95)
st.session_state.repetition_penalty = st.slider(label="Repetition Penalty", min_value=0.0, max_value=1.0, step=0.1, value=1.0)
# load model parameters
st.session_state.llm_object = load_model()
st.markdown("---")
# Upload file through Streamlit
st.session_state.uploaded_file = st.file_uploader("Upload a file", type=["pdf", "doc", "docx", "txt"])
_, retriever = index_document(st.session_state.llm_object, st.session_state.uploaded_file)
st.markdown("---")
st.markdown("# About")
st.markdown(
"""QA bot πŸ€– allows you to ask questions about your
documents and get accurate answers with citations."""
)
st.markdown("Created with ❀️ by Krishna Kumar Yadav")
st.markdown(
"""
- [Email](mailto:[email protected])
- [LinkedIn](https://www.linkedin.com/in/krishna-kumar-yadav-726831105/)
- [Github](https://github.com/krish-yadav23)
- [LeetCode](https://leetcode.com/KrishnaKumar23/)
"""
)
faq()
return retriever
def chat_box() :
for message in st.session_state.messages:
with st.chat_message(message["role"]):
st.markdown(message["content"])
def generate_chat_stream(prompt, retriever) :
with st.spinner("Fetching relevant answers from source document..."):
response, sources = st.session_state.llm_object.mixtral_chat_inference(prompt, st.session_state.history, st.session_state.temperature,
st.session_state.top_p, st.session_state.repetition_penalty, retriever)
return response, sources
def stream_handler(chat_stream, placeholder) :
full_response = ''
for chunk in chat_stream :
if chunk.token.text!='</s>' :
full_response += chunk.token.text
placeholder.markdown(full_response + "β–Œ")
placeholder.markdown(full_response)
return full_response
def show_source(sources) :
with st.expander("Show source") :
for source in sources:
st.info(f"{source}")
# Function to load model parameters
@st.cache_resource()
def load_model():
# create llm object
return llm_model.LlmModel()
st.set_page_config(page_title="Document QA Bot")
#lottie_book = load_lottieurl("https://assets4.lottiefiles.com/temp/lf20_aKAfIn.json")
#st_lottie(lottie_book, speed=1, height=200, key="initial")
# Place the title below the Lottie animation
st.title("Document Q&A Bot πŸ€–")
# initialize session state for streamlit app
init_state()
# Left Sidebar
retriever = sidebar()
chat_box()
if prompt := st.chat_input("Ask a question about your document!"):
st.chat_message("user").markdown(prompt)
st.session_state.messages.append({"role": "user", "content": prompt})
try:
chat_stream, sources = generate_chat_stream(prompt, retriever)
with st.chat_message("assistant"):
placeholder = st.empty()
full_response = stream_handler(chat_stream, placeholder)
show_source(sources)
st.session_state.history.append([prompt, full_response])
st.session_state.messages.append({"role": "assistant", "content": full_response})
except Exception as e:
if not st.session_state.uploaded_file:
st.error("Kindly provide the document file by uploading it before posing any questions. Your cooperation is appreciated!")
else:
st.error(e)