han-byeol commited on
Commit
f17abc5
โ€ข
1 Parent(s): dc09600

Delete app.py

Browse files
Files changed (1) hide show
  1. app.py +0 -186
app.py DELETED
@@ -1,186 +0,0 @@
1
- import streamlit as st
2
- from dotenv import load_dotenv
3
- from PyPDF2 import PdfReader
4
- from langchain.text_splitter import CharacterTextSplitter, RecursiveCharacterTextSplitter
5
- from langchain.embeddings import OpenAIEmbeddings, HuggingFaceInstructEmbeddings
6
- from langchain.vectorstores import FAISS, Chroma
7
- from langchain.embeddings import HuggingFaceEmbeddings # General embeddings from HuggingFace models.
8
- from langchain.chat_models import ChatOpenAI
9
- from langchain.memory import ConversationBufferMemory
10
- 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
- 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
- # txt ๋ฌธ์„œ๋กœ๋ถ€ํ„ฐ ํ…์ŠคํŠธ๋ฅผ ์ถ”์ถœํ•˜๋Š” ํ•จ์ˆ˜
31
- def get_text_file(text_docs):
32
- temp_dir = tempfile.TemporaryDirectory()
33
- temp_filepath = os.path.join(temp_dir.name, text_docs.name)
34
- with open(temp_filepath, "wb") as f:
35
- f.write(text_docs.getvalue())
36
- text_loader = TextLoader(temp_filepath)
37
- text_doc = text_loader.load()
38
- return text_doc
39
-
40
-
41
-
42
- # csv ๋ฌธ์„œ๋กœ๋ถ€ํ„ฐ ํ…์ŠคํŠธ๋ฅผ ์ถ”์ถœํ•˜๋Š” ํ•จ์ˆ˜
43
- def get_csv_file(csv_docs):
44
- temp_dir = tempfile.TemporaryDirectory()
45
- temp_filepath = os.path.join(temp_dir.name, csv_docs.name)
46
- with open(temp_filepath, "wb") as f:
47
- f.write(csv_docs.getvalue())
48
- csv_loader = CSVLoader(temp_filepath)
49
- csv_doc = csv_loader.load()
50
- return csv_doc
51
-
52
-
53
- # json ๋ฌธ์„œ๋กœ๋ถ€ํ„ฐ ํ…์ŠคํŠธ๋ฅผ ์ถ”์ถœํ•˜๋Š” ํ•จ์ˆ˜
54
- class JSONLoader:
55
- def __init__(self, file_path, jq_schema):
56
- self.file_path = file_path
57
- self.jq_schema = jq_schema
58
-
59
- def load(self):
60
- with open(self.file_path, 'r') as json_file:
61
- data = json.load(json_file)
62
- users_text = [user.get('text', '') for user in data.get('users', [])]
63
- return users_text
64
-
65
- def get_json_file(json_docs):
66
- temp_dir = tempfile.TemporaryDirectory()
67
- temp_filepath = os.path.join(temp_dir.name, json_docs.name)
68
- with open(temp_filepath, "wb") as f:
69
- f.write(json_docs.getvalue())
70
- json_loader = JSONLoader(temp_filepath, jq_schema={})
71
- users_text = json_loader.load()
72
- return users_text
73
-
74
-
75
-
76
- # ๋ฌธ์„œ๋“ค์„ ์ฒ˜๋ฆฌํ•˜์—ฌ ํ…์ŠคํŠธ ์ฒญํฌ๋กœ ๋‚˜๋ˆ„๋Š” ํ•จ์ˆ˜์ž…๋‹ˆ๋‹ค.
77
- def get_text_chunks(documents):
78
- text_splitter = RecursiveCharacterTextSplitter(
79
- chunk_size=1000, # ์ฒญํฌ์˜ ํฌ๊ธฐ๋ฅผ ์ง€์ •ํ•ฉ๋‹ˆ๋‹ค.
80
- chunk_overlap=200, # ์ฒญํฌ ์‚ฌ์ด์˜ ์ค‘๋ณต์„ ์ง€์ •ํ•ฉ๋‹ˆ๋‹ค.
81
- length_function=len # ํ…์ŠคํŠธ์˜ ๊ธธ์ด๋ฅผ ์ธก์ •ํ•˜๋Š” ํ•จ์ˆ˜๋ฅผ ์ง€์ •ํ•ฉ๋‹ˆ๋‹ค.
82
- )
83
-
84
- documents = text_splitter.split_documents(documents) # ๋ฌธ์„œ๋“ค์„ ์ฒญํฌ๋กœ ๋‚˜๋ˆ•๋‹ˆ๋‹ค
85
- return documents # ๋‚˜๋ˆˆ ์ฒญํฌ๋ฅผ ๋ฐ˜ํ™˜ํ•ฉ๋‹ˆ๋‹ค.
86
-
87
-
88
-
89
- # ํ…์ŠคํŠธ ์ฒญํฌ๋“ค๋กœ๋ถ€ํ„ฐ ๋ฒกํ„ฐ ์Šคํ† ์–ด๋ฅผ ์ƒ์„ฑํ•˜๋Š” ํ•จ์ˆ˜์ž…๋‹ˆ๋‹ค.
90
- def get_vectorstore(text_chunks):
91
- # OpenAI ์ž„๋ฒ ๋”ฉ ๋ชจ๋ธ์„ ๋กœ๋“œํ•ฉ๋‹ˆ๋‹ค. (Embedding models - Ada v2)
92
-
93
- embeddings = OpenAIEmbeddings()
94
- vectorstore = FAISS.from_documents(text_chunks, embeddings) # FAISS ๋ฒกํ„ฐ ์Šคํ† ์–ด๋ฅผ ์ƒ์„ฑํ•ฉ๋‹ˆ๋‹ค.
95
-
96
- return vectorstore # ์ƒ์„ฑ๋œ ๋ฒกํ„ฐ ์Šคํ† ์–ด๋ฅผ ๋ฐ˜ํ™˜ํ•ฉ๋‹ˆ๋‹ค.
97
-
98
-
99
- def get_conversation_chain(vectorstore):
100
- gpt_model_name = 'gpt-3.5-turbo'
101
- llm = ChatOpenAI(model_name = gpt_model_name) #gpt-3.5 ๋ชจ๋ธ ๋กœ๋“œ
102
-
103
- # ๋Œ€ํ™” ๊ธฐ๋ก์„ ์ €์žฅํ•˜๊ธฐ ์œ„ํ•œ ๋ฉ”๋ชจ๋ฆฌ๋ฅผ ์ƒ์„ฑํ•ฉ๋‹ˆ๋‹ค.
104
- memory = ConversationBufferMemory(
105
- memory_key='chat_history', return_messages=True)
106
- # ๋Œ€ํ™” ๊ฒ€์ƒ‰ ์ฒด์ธ์„ ์ƒ์„ฑํ•ฉ๋‹ˆ๋‹ค.
107
- conversation_chain = ConversationalRetrievalChain.from_llm(
108
- llm=llm,
109
- retriever=vectorstore.as_retriever(),
110
- memory=memory
111
- )
112
- return conversation_chain
113
-
114
- # ์‚ฌ์šฉ์ž ์ž…๋ ฅ์„ ์ฒ˜๋ฆฌํ•˜๋Š” ํ•จ์ˆ˜์ž…๋‹ˆ๋‹ค.
115
- def handle_userinput(user_question):
116
- # ๋Œ€ํ™” ์ฒด์ธ์„ ์‚ฌ์šฉํ•˜์—ฌ ์‚ฌ์šฉ์ž ์งˆ๋ฌธ์— ๋Œ€ํ•œ ์‘๋‹ต์„ ์ƒ์„ฑํ•ฉ๋‹ˆ๋‹ค.
117
- response = st.session_state.conversation({'question': user_question})
118
- # ๋Œ€ํ™” ๊ธฐ๋ก์„ ์ €์žฅํ•ฉ๋‹ˆ๋‹ค.
119
- st.session_state.chat_history = response['chat_history']
120
-
121
- for i, message in enumerate(st.session_state.chat_history):
122
- if i % 2 == 0:
123
- st.write(user_template.replace(
124
- "{{MSG}}", message.content), unsafe_allow_html=True)
125
- else:
126
- st.write(bot_template.replace(
127
- "{{MSG}}", message.content), unsafe_allow_html=True)
128
-
129
-
130
- def main():
131
- load_dotenv()
132
- st.set_page_config(page_title="Chat with multiple Files",
133
- page_icon=":books:")
134
- st.write(css, unsafe_allow_html=True)
135
-
136
- if "conversation" not in st.session_state:
137
- st.session_state.conversation = None
138
- if "chat_history" not in st.session_state:
139
- st.session_state.chat_history = None
140
-
141
- st.header("Chat with multiple Files :")
142
- user_question = st.text_input("Ask a question about your documents:")
143
- if user_question:
144
- handle_userinput(user_question)
145
-
146
- with st.sidebar:
147
- openai_key = st.text_input("Paste your OpenAI API key (sk-...)")
148
- if openai_key:
149
- os.environ["OPENAI_API_KEY"] = openai_key
150
-
151
- st.subheader("Your documents")
152
- docs = st.file_uploader(
153
- "Upload your PDFs here and click on 'Process'", accept_multiple_files=True)
154
- if st.button("Process"):
155
- with st.spinner("Processing"):
156
- # get pdf text
157
- doc_list = []
158
-
159
- for file in docs:
160
- print('file - type : ', file.type)
161
- if file.type == 'text/plain':
162
- # file is .txt
163
- doc_list.extend(get_text_file(file))
164
- elif file.type in ['application/octet-stream', 'application/pdf']:
165
- # file is .pdf
166
- doc_list.extend(get_pdf_text(file))
167
- elif file.type == 'text/csv':
168
- # file is .csv
169
- doc_list.extend(get_csv_file(file))
170
- elif file.type == 'application/json':
171
- # file is .json
172
- doc_list.extend(get_json_file(file))
173
-
174
- # get the text chunks
175
- text_chunks = get_text_chunks(doc_list)
176
-
177
- # create vector store
178
- vectorstore = get_vectorstore(text_chunks)
179
-
180
- # create conversation chain
181
- st.session_state.conversation = get_conversation_chain(
182
- vectorstore)
183
-
184
-
185
- if __name__ == '__main__':
186
- main()