Change Analytics to HTTP API

app.py

@@ -1,6 +1,9 @@
 from PIL import Image
 import sys
 import os
+import requests
+import json
+import uuid
 
 import streamlit as st
 from streamlit_pills import pills
@@ -12,10 +15,14 @@ from datasets import load_dataset
 from vectara_agent.agent import AgentStatusType
 from agent import initialize_agent, get_agent_config
 
-from amplitude import Amplitude, BaseEvent
+# Setup for HTTP API Call to Amplitude Analytics
+device_id = str(uuid.uuid4())
+headers = {
+    'Content-Type': 'application/json',
+    'Accept': '*/*'
+}
 
 initial_prompt = "How can I help you today?"
-client = Amplitude(os.getenv('AMPLITUDE_TOKEN'))
 
 def toggle_logs():
     st.session_state.show_logs = not st.session_state.show_logs
@@ -100,15 +107,27 @@ def launch_bot():
     if prompt:
         st.session_state.messages.append({"role": "user", "content": prompt, "avatar": '🧑‍💻'})
         st.session_state.prompt = prompt  # Save the prompt in session state
-        client.track(
-            BaseEvent(
-                event_type="submitted_query",
-                event_properties={
+
+        # Send query to Amplitude Analytics
+        data = {
+            "api_key": "2a706490a2e8d62cdabf007d25408d34",
+            "events": [{
+                "device_id": device_id,
+                "event_type": "submitted_query",
+                "event_properties": {
                     "query": prompt
-                }
-            )
-        )
-        client.flush() # Send user query to Amplitude Analytics
+                    }
+            }]
+        }
+        
+        response = requests.post('https://api2.amplitude.com/2/httpapi',
+                        headers=headers, data=json.dumps(data))
+        
+        if response.status_code == 200:
+            print(f"DEBUG: Request successfully sent: {response.json()}")
+        else:
+            print(f"DEBUG: Request failed with status code {response.status_code}. Response Text: {response.text}")
+
         st.session_state.log_messages = []
         st.session_state.show_logs = False
         with st.chat_message("user", avatar='🧑‍💻'):

requirements.txt

@@ -4,5 +4,5 @@ python-dotenv==1.0.1
 streamlit==1.32.2
 streamlit_pills==0.3.0
 datasets==2.14.7
-amplitude-analytics==1.1.4
+uuid==1.30
 git+https://{GITHUB_TOKEN}@github.com/vectara/vectara-agent.git