Update app.py
Browse files
app.py
CHANGED
|
@@ -11,78 +11,64 @@ from langchain.chains import ConversationalRetrievalChain
|
|
| 11 |
from htmlTemplates import css, bot_template, user_template
|
| 12 |
from langchain.llms import HuggingFaceHub, LlamaCpp, CTransformers # For loading transformer models.
|
| 13 |
from langchain.document_loaders import PyPDFLoader, TextLoader, JSONLoader, CSVLoader
|
| 14 |
-
|
| 15 |
import os
|
| 16 |
|
| 17 |
|
|
|
|
| 18 |
def get_pdf_text(pdf_docs):
|
| 19 |
-
|
| 20 |
-
|
| 21 |
-
|
| 22 |
-
|
| 23 |
-
|
| 24 |
-
|
| 25 |
-
|
| 26 |
-
return pdf_doc
|
| 27 |
|
|
|
|
|
|
|
| 28 |
|
| 29 |
def get_text_file(docs):
|
| 30 |
-
|
| 31 |
-
temp_file.write(docs.getvalue())
|
| 32 |
-
temp_file.seek(0)
|
| 33 |
-
text_loader = TextLoader(temp_file.name)
|
| 34 |
-
text_doc = text_loader.load()
|
| 35 |
-
|
| 36 |
-
return text_doc
|
| 37 |
|
| 38 |
|
| 39 |
def get_csv_file(docs):
|
| 40 |
-
|
| 41 |
-
temp_file.write(docs.getvalue())
|
| 42 |
-
temp_file.seek(0)
|
| 43 |
-
text_loader = CSVLoader(temp_file.name)
|
| 44 |
-
text_doc = text_loader.load()
|
| 45 |
-
|
| 46 |
-
return text_doc
|
| 47 |
-
|
| 48 |
|
| 49 |
def get_json_file(docs):
|
| 50 |
-
|
| 51 |
-
temp_file.write(docs.getvalue())
|
| 52 |
-
temp_file.seek(0)
|
| 53 |
-
json_loader = JSONLoader(temp_file.name,
|
| 54 |
-
jq_schema='.scans[].relationships',
|
| 55 |
-
text_content=False)
|
| 56 |
-
json_doc = json_loader.load()
|
| 57 |
-
|
| 58 |
-
return json_doc
|
| 59 |
-
|
| 60 |
|
|
|
|
|
|
|
| 61 |
def get_text_chunks(documents):
|
| 62 |
text_splitter = RecursiveCharacterTextSplitter(
|
| 63 |
-
chunk_size=1000,
|
| 64 |
-
chunk_overlap=200,
|
| 65 |
-
length_function=len
|
| 66 |
)
|
| 67 |
|
| 68 |
-
documents = text_splitter.split_documents(documents)
|
| 69 |
-
return documents
|
| 70 |
|
| 71 |
|
|
|
|
| 72 |
def get_vectorstore(text_chunks):
|
| 73 |
-
#
|
| 74 |
|
| 75 |
embeddings = OpenAIEmbeddings()
|
| 76 |
-
vectorstore = FAISS.from_documents(text_chunks, embeddings)
|
| 77 |
|
| 78 |
-
return vectorstore
|
| 79 |
|
| 80 |
|
| 81 |
def get_conversation_chain(vectorstore):
|
| 82 |
gpt_model_name = 'gpt-3.5-turbo'
|
| 83 |
-
llm = ChatOpenAI(model_name = gpt_model_name)
|
|
|
|
|
|
|
| 84 |
memory = ConversationBufferMemory(
|
| 85 |
memory_key='chat_history', return_messages=True)
|
|
|
|
| 86 |
conversation_chain = ConversationalRetrievalChain.from_llm(
|
| 87 |
llm=llm,
|
| 88 |
retriever=vectorstore.as_retriever(),
|
|
@@ -90,9 +76,11 @@ def get_conversation_chain(vectorstore):
|
|
| 90 |
)
|
| 91 |
return conversation_chain
|
| 92 |
|
| 93 |
-
|
| 94 |
def handle_userinput(user_question):
|
|
|
|
| 95 |
response = st.session_state.conversation({'question': user_question})
|
|
|
|
| 96 |
st.session_state.chat_history = response['chat_history']
|
| 97 |
|
| 98 |
for i, message in enumerate(st.session_state.chat_history):
|
|
@@ -106,7 +94,7 @@ def handle_userinput(user_question):
|
|
| 106 |
|
| 107 |
def main():
|
| 108 |
load_dotenv()
|
| 109 |
-
st.set_page_config(page_title="Chat with multiple
|
| 110 |
page_icon=":books:")
|
| 111 |
st.write(css, unsafe_allow_html=True)
|
| 112 |
|
|
@@ -115,7 +103,7 @@ def main():
|
|
| 115 |
if "chat_history" not in st.session_state:
|
| 116 |
st.session_state.chat_history = None
|
| 117 |
|
| 118 |
-
st.header("Chat with multiple
|
| 119 |
user_question = st.text_input("Ask a question about your documents:")
|
| 120 |
if user_question:
|
| 121 |
handle_userinput(user_question)
|
|
|
|
| 11 |
from htmlTemplates import css, bot_template, user_template
|
| 12 |
from langchain.llms import HuggingFaceHub, LlamaCpp, CTransformers # For loading transformer models.
|
| 13 |
from langchain.document_loaders import PyPDFLoader, TextLoader, JSONLoader, CSVLoader
|
| 14 |
+
import tempfile # 임시 파일을 생성하기 위한 라이브러리입니다.
|
| 15 |
import os
|
| 16 |
|
| 17 |
|
| 18 |
+
# PDF 문서로부터 텍스트를 추출하는 함수입니다.
|
| 19 |
def get_pdf_text(pdf_docs):
|
| 20 |
+
temp_dir = tempfile.TemporaryDirectory() # 임시 디렉토리를 생성합니다.
|
| 21 |
+
temp_filepath = os.path.join(temp_dir.name, pdf_docs.name) # 임시 파일 경로를 생성합니다.
|
| 22 |
+
with open(temp_filepath, "wb") as f: # 임시 파일을 바이너리 쓰기 모드로 엽니다.
|
| 23 |
+
f.write(pdf_docs.getvalue()) # PDF 문서의 내용을 임시 파일에 씁니다.
|
| 24 |
+
pdf_loader = PyPDFLoader(temp_filepath) # PyPDFLoader를 사용해 PDF를 로드합니다.
|
| 25 |
+
pdf_doc = pdf_loader.load() # 텍스트를 추출합니다.
|
| 26 |
+
return pdf_doc # 추출한 텍스트를 반환합니다.
|
|
|
|
| 27 |
|
| 28 |
+
# 과제
|
| 29 |
+
# 아래 텍스트 추출 함수를 작성
|
| 30 |
|
| 31 |
def get_text_file(docs):
|
| 32 |
+
pass
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 33 |
|
| 34 |
|
| 35 |
def get_csv_file(docs):
|
| 36 |
+
pass
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 37 |
|
| 38 |
def get_json_file(docs):
|
| 39 |
+
pass
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 40 |
|
| 41 |
+
|
| 42 |
+
# 문서들을 처리하여 텍스트 청크로 나누는 함수입니다.
|
| 43 |
def get_text_chunks(documents):
|
| 44 |
text_splitter = RecursiveCharacterTextSplitter(
|
| 45 |
+
chunk_size=1000, # 청크의 크기를 지정합니다.
|
| 46 |
+
chunk_overlap=200, # 청크 사이의 중복을 지정합니다.
|
| 47 |
+
length_function=len # 텍스트의 길이를 측정하는 함수를 지정합니다.
|
| 48 |
)
|
| 49 |
|
| 50 |
+
documents = text_splitter.split_documents(documents) # 문서들을 청크로 나눕니다
|
| 51 |
+
return documents # 나눈 청크를 반환합니다.
|
| 52 |
|
| 53 |
|
| 54 |
+
# 텍스트 청크들로부터 벡터 스토어를 생성하는 함수입니다.
|
| 55 |
def get_vectorstore(text_chunks):
|
| 56 |
+
# OpenAI 임베딩 모델을 로드합니다. (Embedding models - Ada v2)
|
| 57 |
|
| 58 |
embeddings = OpenAIEmbeddings()
|
| 59 |
+
vectorstore = FAISS.from_documents(text_chunks, embeddings) # FAISS 벡터 스토어를 생성합니다.
|
| 60 |
|
| 61 |
+
return vectorstore # 생성된 벡터 스토어를 반환합니다.
|
| 62 |
|
| 63 |
|
| 64 |
def get_conversation_chain(vectorstore):
|
| 65 |
gpt_model_name = 'gpt-3.5-turbo'
|
| 66 |
+
llm = ChatOpenAI(model_name = gpt_model_name) #gpt-3.5 모델 로드
|
| 67 |
+
|
| 68 |
+
# 대화 기록을 저장하기 위한 메모리를 생성합니다.
|
| 69 |
memory = ConversationBufferMemory(
|
| 70 |
memory_key='chat_history', return_messages=True)
|
| 71 |
+
# 대화 검색 체인을 생성합니다.
|
| 72 |
conversation_chain = ConversationalRetrievalChain.from_llm(
|
| 73 |
llm=llm,
|
| 74 |
retriever=vectorstore.as_retriever(),
|
|
|
|
| 76 |
)
|
| 77 |
return conversation_chain
|
| 78 |
|
| 79 |
+
# 사용자 입력을 처리하는 함수입니다.
|
| 80 |
def handle_userinput(user_question):
|
| 81 |
+
# 대화 체인을 사용하여 사용자 질문에 대한 응답을 생성합니다.
|
| 82 |
response = st.session_state.conversation({'question': user_question})
|
| 83 |
+
# 대화 기록을 저장합니다.
|
| 84 |
st.session_state.chat_history = response['chat_history']
|
| 85 |
|
| 86 |
for i, message in enumerate(st.session_state.chat_history):
|
|
|
|
| 94 |
|
| 95 |
def main():
|
| 96 |
load_dotenv()
|
| 97 |
+
st.set_page_config(page_title="Chat with multiple Files",
|
| 98 |
page_icon=":books:")
|
| 99 |
st.write(css, unsafe_allow_html=True)
|
| 100 |
|
|
|
|
| 103 |
if "chat_history" not in st.session_state:
|
| 104 |
st.session_state.chat_history = None
|
| 105 |
|
| 106 |
+
st.header("Chat with multiple Files :")
|
| 107 |
user_question = st.text_input("Ask a question about your documents:")
|
| 108 |
if user_question:
|
| 109 |
handle_userinput(user_question)
|