Upload app.py

app.py

@@ -0,0 +1,75 @@
+import streamlit as st
+import os
+import platform
+import zipfile
+
+# --- 1. WINDOWS HATA ENGELLEYİCİ (EN ÜSTTE OLMALI) ---
+if platform.system() == "Windows":
+    os.environ['PYSPARK_PYTHON'] = "python"
+    os.environ['PYSPARK_DRIVER_PYTHON'] = "python"
+
+from pyspark.sql import SparkSession
+from pyspark.ml.feature import VectorAssembler
+from pyspark.ml.classification import LogisticRegressionModel
+
+# --- 2. ZIP VE DOSYA YOLLARI ---
+current_dir = os.path.dirname(os.path.abspath(__file__))
+model_path = os.path.join(current_dir, "heart_model")
+zip_path = os.path.join(current_dir, "heart_model.zip")
+
+# Klasör yoksa ama zip varsa klasöre çıkart
+if not os.path.exists(model_path) and os.path.exists(zip_path):
+    try:
+        with zipfile.ZipFile(zip_path, 'r') as zip_ref:
+            zip_ref.extractall(current_dir) # DİKKAT: zip'in içindeki klasör yapısı önemli
+    except Exception as e:
+        st.error(f"Zip dosyası açılırken hata: {e}")
+
+# --- 3. KRİTİK SPARK OTURUMU (HATA BYPASS EDİCİ) ---
+@st.cache_resource
+def get_spark():
+    builder = SparkSession.builder.appName("HeartApp")
+    
+    if platform.system() == "Windows":
+        # Windows'ta dosya erişim hatasını (NativeIO) susturan ayarlar
+        return builder.master("local[1]") \
+            .config("spark.driver.host", "127.0.0.1") \
+            .config("spark.hadoop.fs.file.impl", "org.apache.hadoop.fs.RawLocalFileSystem") \
+            .config("spark.hadoop.fs.permission.check", "false") \
+            .getOrCreate()
+    else:
+        # Hugging Face (Linux) ayarları
+        return builder.master("local[*]").getOrCreate()
+
+spark = get_spark()
+
+# --- 4. MODEL YÜKLEME ---
+@st.cache_resource
+def load_heart_model():
+    # Model yolu kontrolü
+    if os.path.exists(model_path):
+        try:
+            return LogisticRegressionModel.load(model_path)
+        except Exception as e:
+            # Buradaki hata hala geliyorsa Spark dosyayı bulamıyor demektir
+            st.error(f"Spark Hatası: {e}")
+            return None
+    return None
+
+model = load_heart_model()
+
+# --- 5. ARAYÜZ ---
+st.set_page_config(page_title="Kalp Analizi", layout="wide")
+st.title("🫀 Kalp Hastalığı Risk Analizi")
+
+if model is None:
+    st.error("❌ Model hala yüklenemedi!")
+    st.info("⚠️ Lütfen şu adımı kontrol et: VS Code sol tarafta 'heart_model' klasörünün içine bak. "
+            "Eğer içinde direkt 'data' ve 'metadata' klasörlerini görmüyorsan Spark yükleme yapamaz.")
+    st.code(f"Şu yolu kontrol et: {model_path}")
+else:
+    # Form ve tahmin kısmı buraya gelecek
+    st.success("✅ Model başarıyla bağlandı!")
+    with st.form("input_form"):
+        # (Önceki form kodlarını buraya ekleyebilirsin)
+        submit = st.form_submit_button("Tahmin Et")