dav74 commited on
Commit
2df02c5
·
verified ·
1 Parent(s): 9aa35b1

Delete main.py

Browse files
Files changed (1) hide show
  1. main.py +0 -128
main.py DELETED
@@ -1,128 +0,0 @@
1
- from langchain_core.prompts import ChatPromptTemplate
2
- from langchain_google_genai import ChatGoogleGenerativeAI
3
- from langchain_community.document_loaders import DirectoryLoader
4
- from langchain_text_splitters import CharacterTextSplitter
5
- from langchain_community.document_loaders import PyPDFLoader
6
- from langchain_huggingface import HuggingFaceEmbeddings
7
- from typing import List
8
- from langchain_chroma import Chroma
9
- from typing_extensions import TypedDict
10
- from typing import Annotated
11
- from langgraph.graph.message import AnyMessage, add_messages
12
- from langchain_core.messages import HumanMessage, AIMessage
13
- from langgraph.graph import END, StateGraph, START
14
- from langgraph.checkpoint.memory import MemorySaver
15
- from fastapi import FastAPI, UploadFile, Form
16
- from fastapi.middleware.cors import CORSMiddleware
17
- from typing import Optional
18
- from PIL import Image
19
- import base64
20
- from io import BytesIO
21
- import os
22
- import logging
23
- import sys
24
-
25
- logger = logging.getLogger('uvicorn.error')
26
- logger.setLevel(logging.DEBUG)
27
-
28
- app = FastAPI()
29
-
30
- app.add_middleware(
31
- CORSMiddleware,
32
- allow_origins=["*"],
33
- allow_credentials=True,
34
- allow_methods=["*"],
35
- allow_headers=["*"],
36
- )
37
-
38
-
39
- llm = ChatGoogleGenerativeAI(model="gemini-2.0-flash", temperature=0.5)
40
-
41
- memory = MemorySaver()
42
-
43
- glob_pattern="./*.md"
44
- directory_path = "./documents"
45
- loader = DirectoryLoader(directory_path, glob=glob_pattern)
46
- documents = loader.load()
47
-
48
- file_path = "./documents/prog.pdf"
49
- loader = PyPDFLoader(file_path)
50
- prog = loader.load()
51
-
52
- system = """
53
- Tu es un assistant spécialisé dans l'enseignement de l'enseigement Sciences Numériques et Technologie (SNT) de la classe de seconde'
54
- Ton interlocuteur est un élève qui suit l'enseigement SNT en classe de seconde
55
- Ton unique thème de conservation doit être l'enseignement SNT. Tu ne dois pas aborder d'autres thèmes que l'enseignement SNT
56
- Tu ne dois pas faire d'erreur, répond à la question uniquement si tu es sûr de ta réponse
57
- si tu ne trouves pas la réponse à une question, tu réponds que tu ne connais pas la réponse et que l'élève doit s'adresser à son professeur pour obtenir cette réponse
58
- si l'élève n'arrive pas à trouver la réponse à un exercice, tu ne dois pas lui donner tout de suite la réponse, mais seulement lui donner des indications pour lui permettre de trouver la réponse par lui même
59
- Tu dois uniquement répondre en langue française
60
- Tu ne dois pas commencer tes interventions par "Assistant".
61
- Tu trouveras ci-dessous un résumé du cours de SNT , tu devras veiller à ce que tes réponses ne sortent pas du cadre du programme de SNT
62
- Si la question posée ne rentre pas dans le cadre du programme de SNT tu peux tout de même répondre en précisant bien que cette notion est hors programme
63
- si tu proposes un exercice, tu dois bien vérifier que toutes les notions nécessaires à la résolution de l'exercice sont explicitement au programme de SNT
64
- """
65
-
66
- prompt = ChatPromptTemplate.from_messages(
67
- [
68
- ("system", system),
69
- ("human", "Programme officiel de SNT: \n {prog} \n\n" "Résumé du cours de SNT : \n {documents} \n\n Historique conversation entre l'assistant et l'élève : \n {historical} \n\n Intervention de l'élève : {question}"),
70
- ]
71
- )
72
-
73
- def format_historical(hist):
74
- historical = []
75
- for i in range(0,len(hist)-2,2):
76
- historical.append("Utilisateur : "+hist[i].content[0]['text'])
77
- historical.append("Assistant : "+hist[i+1].content[0]['text'])
78
- return "\n".join(historical[-10:])
79
-
80
-
81
- class GraphState(TypedDict):
82
- messages: Annotated[list[AnyMessage], add_messages]
83
-
84
- def chatbot(state : GraphState):
85
- question = prompt.invoke({'historical': format_historical(state['messages']),'prog':prog, 'documents':documents , 'question' : state['messages'][-1].content[0]['text']})
86
- q = question.messages[0].content + question.messages[1].content
87
- if len(state['messages'][-1].content) > 1 :
88
- response = llm.invoke([HumanMessage(
89
- content=[
90
- {"type": "text", "text": q},
91
- state['messages'][-1].content[1]
92
- ])])
93
- else :
94
- response = llm.invoke([HumanMessage(
95
- content=[
96
- {"type": "text", "text": q}
97
- ])])
98
- return {"messages": [AIMessage(content=[{'type': 'text', 'text': response.content}])]}
99
-
100
- workflow = StateGraph(GraphState)
101
- workflow.add_node('chatbot', chatbot)
102
-
103
- workflow.add_edge(START, 'chatbot')
104
- workflow.add_edge('chatbot', END)
105
-
106
- app_chatbot = workflow.compile(checkpointer=memory)
107
-
108
- @app.post('/request')
109
- def request(id:Annotated[str, Form()], query:Annotated[str, Form()], image:Optional[UploadFile] = None):
110
- config = {"configurable": {"thread_id": id}}
111
- if image:
112
- try:
113
- img = Image.open(image.file)
114
- img_buffer = BytesIO()
115
- img.save(img_buffer, format='PNG')
116
- byte_data = img_buffer.getvalue()
117
- base64_img = base64.b64encode(byte_data).decode("utf-8")
118
- message = HumanMessage(
119
- content=[
120
- {'type': 'text', 'text': query},
121
- {'type': 'image_url', 'image_url': {"url": f"data:image/jpeg;base64,{base64_img}"}}
122
- ])
123
- except:
124
- return {"response":"Attention, vous m'avez fourni autre chose qu'une image. Renouvelez votre demande avec une image."}
125
- rep = app_chatbot.invoke({"messages": message},config, stream_mode="values")
126
- else :
127
- rep = app_chatbot.invoke({"messages": [HumanMessage(content=[{'type': 'text', 'text': query}])]},config, stream_mode="values")
128
- return {"response":rep['messages'][-1].content[0]['text']}