04/08/2023

app.py

@@ -11,11 +11,45 @@ from langchain.text_splitter import RecursiveCharacterTextSplitter
 from langchain.embeddings.openai import OpenAIEmbeddings
 from openai.embeddings_utils import get_embedding
 from openai.embeddings_utils import cosine_similarity
-
+import gspread # See: https://docs.gspread.org/en/v5.10.0/user-guide.html
+from oauth2client.service_account import ServiceAccountCredentials
+from datetime import datetime
 
 # API de OpenAI
 openai.api_key = os.getenv("OPENAI_API_KEY")
 
+# Establece las credenciales y la API
+type_s = os.getenv("type_s")
+project_id = os.getenv("project_id")
+private_key_id = os.getenv("private_key_id")
+private_key = os.getenv("private_key")
+client_email = os.getenv("client_email")
+client_id = os.getenv("client_id")
+auth_uri = os.getenv("auth_uri")
+token_uri = os.getenv("token_uri")
+auth_provider_x509_cert_url = os.getenv("auth_provider_x509_cert_url")
+client_x509_cert_url = os.getenv("client_x509_cert_url")
+universe_domain = os.getenv("universe_domain")
+
+credentials = {
+  "type": type_s,
+  "project_id": project_id,
+  "private_key_id": private_key_id,
+  "private_key": private_key,
+  "client_email": client_email,
+  "client_id": client_id,
+  "auth_uri": auth_uri,
+  "token_uri": token_uri,
+  "auth_provider_x509_cert_url": auth_provider_x509_cert_url,
+  "client_x509_cert_url": client_x509_cert_url,
+  "universe_domain": universe_domain
+}
+
+gc = gspread.service_account_from_dict(credentials)
+
+Google_URL = os.getenv("Google_URL")
+sht = gc.open_by_url(Google_URL)
+
 # Cargar el archivo 
 #df_Normas_Embeddings = pd.read_csv( 'datos/CLEAN_EMBEDDINGS/Textos_Normas.csv' )
 df_Normas_Embeddings = pd.read_csv( 'https://raw.githubusercontent.com/benjov/Data_Fiscal/main/Textos_Normas.csv' )
@@ -126,6 +160,18 @@ def get_respuesta( user_message, informacion ):
     #
 
     #
+
+#
+def update_records( user_message ):
+    #
+    sht.sheet1.get_all_records()
+    #
+    sht.sheet1.update_cell( len( sht.sheet1.get_all_records()[:] ) + 2 , 
+                            1 , datetime.now().strftime("%m/%d/%Y, %H:%M:%S") )
+    #
+    sht.sheet1.update_cell( len( sht.sheet1.get_all_records()[:] ) + 1 , 
+                            2 , user_message )
+#
 def Chat( user_message_1 ):
     #
     norma_y_tema_response_1 = get_topic( user_message_1 )
@@ -144,6 +190,9 @@ def Chat( user_message_1 ):
     #
     Textos = df_final[ 'Final_Text' ].tolist()
     #
+    # Save Question and date time
+    update_records( user_message_1 )
+    #
     return get_respuesta( user_message_1, Textos ), '\n'.join(Textos)