datacipen commited on
Commit
54890d4
1 Parent(s): 672ccef

Update main.py

Browse files
Files changed (1) hide show
  1. main.py +23 -7
main.py CHANGED
@@ -1,4 +1,6 @@
1
  from langchain_community.llms import HuggingFaceEndpoint
 
 
2
  from langchain_core.prompts import PromptTemplate
3
  from langchain.prompts import ChatPromptTemplate, MessagesPlaceholder
4
  from langchain.memory import ChatMessageHistory, ConversationBufferMemory
@@ -6,13 +8,15 @@ from langchain.schema import StrOutputParser
6
  from langchain.schema.runnable import Runnable, RunnablePassthrough, RunnableLambda
7
  from langchain.schema.runnable.config import RunnableConfig
8
  from langchain.schema import StrOutputParser
 
 
9
  import os
10
  import pandas as pd
11
  import numpy as np
12
 
13
  from langchain.agents import AgentExecutor
14
  from langchain.agents.agent_types import AgentType
15
- from langchain_experimental.agents.agent_toolkits import create_csv_agent
16
 
17
  from deep_translator import GoogleTranslator
18
 
@@ -43,12 +47,24 @@ async def on_chat_start():
43
  llm = HuggingFaceEndpoint(
44
  repo_id=repo_id, temperature=1.0
45
  )
46
- agent = create_csv_agent(
47
- llm,
48
- "https://cipen.univ-gustave-eiffel.fr/typo3conf/ext/cipen_package/Resources/Public/Dataviz/datalab/crossfilterings/enquete-DClic-juin2022-dataviz-ord1.csv",
49
- verbose=True,
50
- agent_type=AgentType.ZERO_SHOT_REACT_DESCRIPTION
51
- )
 
 
 
 
 
 
 
 
 
 
 
 
52
  cl.user_session.set("runnable", agent)
53
 
54
  @cl.on_message
 
1
  from langchain_community.llms import HuggingFaceEndpoint
2
+ from langchain_community.utilities import SQLDatabase
3
+ from sqlalchemy import create_engine
4
  from langchain_core.prompts import PromptTemplate
5
  from langchain.prompts import ChatPromptTemplate, MessagesPlaceholder
6
  from langchain.memory import ChatMessageHistory, ConversationBufferMemory
 
8
  from langchain.schema.runnable import Runnable, RunnablePassthrough, RunnableLambda
9
  from langchain.schema.runnable.config import RunnableConfig
10
  from langchain.schema import StrOutputParser
11
+ from langchain_community.agent_toolkits import create_sql_agent
12
+
13
  import os
14
  import pandas as pd
15
  import numpy as np
16
 
17
  from langchain.agents import AgentExecutor
18
  from langchain.agents.agent_types import AgentType
19
+ #from langchain_experimental.agents.agent_toolkits import create_csv_agent
20
 
21
  from deep_translator import GoogleTranslator
22
 
 
47
  llm = HuggingFaceEndpoint(
48
  repo_id=repo_id, temperature=1.0
49
  )
50
+ if cl.user_session.get("createdb") == None:
51
+ df = pd.read_csv("https://cipen.univ-gustave-eiffel.fr/typo3conf/ext/cipen_package/Resources/Public/Dataviz/datalab/crossfilterings/enquete-DClic-juin2022-dataviz-ord1.csv")
52
+ engine = create_engine("sqlite:///epnum.db")
53
+ df.to_sql("epnum", engine, index=False)
54
+ db = SQLDatabase(engine=engine)
55
+ cl.user_session.set("createdb", "OK")
56
+ cl.user_session.set("db", db)
57
+ else:
58
+ db = cl.user_session.get("db")
59
+
60
+ agent = create_sql_agent(llm, db=db, agent_type="openai-tools", verbose=True)
61
+
62
+ #agent = create_csv_agent(
63
+ # llm,
64
+ # "https://cipen.univ-gustave-eiffel.fr/typo3conf/ext/cipen_package/Resources/Public/Dataviz/datalab/crossfilterings/enquete-DClic-juin2022-dataviz-ord1.csv",
65
+ # verbose=True,
66
+ # agent_type=AgentType.ZERO_SHOT_REACT_DESCRIPTION
67
+ #)
68
  cl.user_session.set("runnable", agent)
69
 
70
  @cl.on_message