Spaces:
Runtime error
Runtime error
import os | |
from langchain.chains import RetrievalQA | |
from langchain.llms import AzureOpenAI | |
from langchain.document_loaders import TextLoader | |
from langchain.document_loaders import PyPDFLoader | |
from langchain.indexes import VectorstoreIndexCreator | |
from langchain.text_splitter import CharacterTextSplitter | |
from langchain.embeddings import OpenAIEmbeddings | |
from langchain.vectorstores import Chroma | |
from langchain.chains.question_answering import load_qa_chain | |
from langchain.llms import AzureOpenAI | |
from langchain.chains.question_answering import load_qa_chain | |
import streamlit as st | |
from PIL import Image | |
import time | |
image = Image.open('Wipro logo.png') | |
st.image(image) | |
st.title("Wipro Impact | CSRD | Advisor") | |
st.header("Enable clients to prepare for CSRD.. ") | |
genre = st.radio( | |
"Choose a CSRD focus area for AI question answering", | |
('E1-Climate Change', 'E4-Biodiversity and ecosystem', 'S1-Own Workforce'), index=0) | |
url = "https://www.efrag.org/Assets/Download?assetUrl=%2Fsites%2Fwebpublishing%2FSiteAssets%2F13%2520Draft%2520ESRS%2520S1%2520Own%2520workforce%2520November%25202022.pdf" | |
if genre == 'E1-Climate Change': | |
url = "https://www.efrag.org/Assets/Download?assetUrl=%2Fsites%2Fwebpublishing%2FSiteAssets%2F08%2520Draft%2520ESRS%2520E1%2520Climate%2520Change%2520November%25202022.pdf" | |
samplequestions = ["What are the climate related indicators?", "List all the disclosure requirments listed in page 3?", "Policies related to climate change mitigation and adaptation?", | |
"What should the company disclose regarding Actions and resources in relation to climate change policies?" , "How should the GHG emission reduction targets be reported?" , | |
"Total energy consumption from non-renewable sources for high climate impact sectors should be disaggregated as ?", | |
"Total energy consumption from renewable sources should be disaggregated as ?" , | |
"What should be disclosed on GHG removals and GHG mitigation projects financed through carbon credits ?" , | |
"Is it wise to invest on carbon credits? ", | |
"What is Climate change adaptation? ", "What are Decarbonisation levers?" ] | |
if genre == 'E4-Biodiversity and ecosystem': | |
url = "https://www.efrag.org/Assets/Download?assetUrl=%2Fsites%2Fwebpublishing%2FSiteAssets%2F11%2520Draft%2520ESRS%2520E4%2520Biodiversity%2520and%2520ecosystems%2520November%25202022.pdf" | |
samplequestions = ["What are the Biodiversity related indicators?", "List all the disclosure requirments listed in page 3?"] | |
if genre == 'S1-Own Workforce': | |
url = "https://www.efrag.org/Assets/Download?assetUrl=%2Fsites%2Fwebpublishing%2FSiteAssets%2F13%2520Draft%2520ESRS%2520S1%2520Own%2520workforce%2520November%25202022.pdf" | |
samplequestions = ["What are the social related indicators?", "List all the disclosure requirments listed in page 3?"] | |
sampleselectedquestion = st.selectbox( | |
'Just ask your question or start with a one of these example questions...', samplequestions ) | |
st.write(" :green[ Ask any thing on your mind...just type your question here...]") | |
yourquestion = st.text_input('Your question', sampleselectedquestion) | |
st.write('Your typed .. ', yourquestion) | |
os.environ['OPENAI_API_TYPE'] = 'azure' | |
os.environ['OPENAI_API_VERSION'] = '2023-03-15-preview' | |
llmgpt3 = AzureOpenAI( deployment_name="testdavanci", model_name="text-davinci-003" ) | |
chain = load_qa_chain(llm=llmgpt3, chain_type="map_reduce") | |
aimethod = st.radio( | |
"Choose a AI brain or document comprehension method", | |
('2 minutes AI method map_reduce', '4 minutes AI method refine' ), index=0) | |
mychain_type = "map_reduce" | |
if aimethod == '2 minutes AI method map_reduce': | |
mychain_type = "map_reduce" | |
if aimethod == '4 minutes AI method refine': | |
mychain_type = "refine" | |
chain = load_qa_chain(llm=llmgpt3, chain_type=mychain_type) | |
loader1 = PyPDFLoader(url) | |
def history(): | |
mycount = 0 | |
if 'count' not in st.session_state: | |
st.session_state['count'] = 0 | |
else: | |
mycount = st.session_state['count'] | |
if True: | |
st.write(mycount) | |
mycount = mycount + 1 | |
st.session_state['count'] = mycount | |
for i in range(mycount): | |
mystatekeyindex = "element" + str(i) | |
mystatekeyanswerindex = "elementANS" + str(i) | |
if mystatekeyindex not in st.session_state: | |
st.session_state[mystatekeyindex] = yourquestion | |
st.session_state[mystatekeyanswerindex] = answer | |
if mystatekeyindex in st.session_state: | |
with st.expander(st.session_state[mystatekeyindex]): | |
st.write( st.session_state[mystatekeyanswerindex] ) | |
def colorizedtext(acolor, astring): | |
formattedcolor = ":" + acolor + "[" + astring + "]" | |
return formattedcolor | |
if st.button("Ask QA "): | |
documents = loader1.load() | |
answer = "" | |
with st.spinner(" Finding answer for your question .... AI will get you answer in 2 more minutes... " ): | |
with st.expander( "Employing your choice of AI method ... " + aimethod + "..."): | |
st.write(str(chain)[:700]) | |
st.write("AI is reading this [link](%s)" % url) | |
prgpgress = st.progress(0) | |
st.subheader(colorizedtext("red", yourquestion)) | |
for i in range(100): | |
time.sleep(0.9) | |
prgpgress.progress(i+1) | |
answer = chain.run(input_documents=documents, question=yourquestion) | |
st.subheader(colorizedtext("blue", answer)) | |
history() | |