add pyairtable

app.py

@@ -8,6 +8,8 @@ from qdrant_client.models import Filter, FieldCondition, MatchValue
 import os
 from symspellpy.symspellpy import SymSpell, Verbosity
 from pythainlp.tokenize import word_tokenize
+from pyairtable import Table
+from pyairtable import Api
 
 
 qdrant_client = QdrantClient(
@@ -15,6 +17,12 @@ qdrant_client = QdrantClient(
     api_key=os.environ.get("Qdrant_api"),
 )
 
+AIRTABLE_API_KEY = os.environ.get("airtable_api")
+BASE_ID = os.environ.get("airtable_baseid")  
+TABLE_NAME = "Feedback_search"  
+api = Api(AIRTABLE_API_KEY)
+table = api.table(BASE_ID, TABLE_NAME)
+
 # โมเดลที่โหลดล่วงหน้า
 models = {
     "E5 (intfloat/multilingual-e5-small)": SentenceTransformer('intfloat/multilingual-e5-small'),
@@ -118,17 +126,18 @@ def search_product(query, model_name):
 
 # 📝 Logging feedback
 def log_feedback(feedback):
-    now = datetime.now().isoformat()
-    log_entry = {
-        "timestamp": now,
-        "model": latest_query_result["model"],
-        "query": latest_query_result["query"],
-        "result": latest_query_result["result"],
-        "feedback": feedback
-    }
-    df = pd.DataFrame([log_entry])
-    df.to_csv("feedback_log.csv", mode='a', header=not pd.io.common.file_exists("feedback_log.csv"), index=False)
-    return f"✅ Feedback saved: {feedback}"
+    try:
+        now = datetime.now().strftime("%Y-%m-%d") 
+        table.create({
+            "timestamp": now,
+            "model": latest_query_result["model"],
+            "query": latest_query_result["query"],
+            "result": latest_query_result["result"],
+            "feedback": feedback
+        })
+        return "✅ Feedback saved to Airtable!"
+    except Exception as e:
+        return f"❌ Failed to save feedback: {str(e)}"
 
 
 # 🎨 Gradio UI