ESMATUGBA commited on
Commit
e6cf9a3
·
verified ·
1 Parent(s): dec4ce8

Update app.py

Browse files
Files changed (1) hide show
  1. app.py +77 -74
app.py CHANGED
@@ -5,99 +5,102 @@ from pyspark.ml.classification import LogisticRegressionModel
5
  from pyspark.ml.feature import VectorAssembler
6
 
7
  # --- 1. SAYFA AYARLARI (PAGE CONFIG) ---
8
- st.set_page_config(page_title="Heart Disease Predictor", page_icon="🫀", layout="wide")
9
-
10
- # Görsel stil ekleyelim (CSS)
11
- st.markdown("""
12
- <style>
13
- .main { background-color: #f5f7f9; }
14
- .stButton>button { width: 100%; border-radius: 10px; height: 3em; background-color: #e63946; color: white; font-weight: bold; }
15
- .stSuccess { background-color: #d8f3dc; }
16
- </style>
17
- """, unsafe_allow_html=True)
18
-
19
- # --- 2. SPARK VE MODEL BAŞLATMA ---
20
  @st.cache_resource
21
- def initialize_spark_and_model():
22
- # Spark Session
23
  spark = SparkSession.builder \
24
- .appName("HeartDiseaseApp") \
25
  .master("local[*]") \
26
  .config("spark.driver.bindAddress", "127.0.0.1") \
27
  .getOrCreate()
28
-
29
- # Model Loading
30
  model = LogisticRegressionModel.load("heart_model")
31
  return spark, model
32
 
33
  try:
34
- spark, model = initialize_spark_and_model()
35
  except Exception as e:
36
  st.error(f"Error / Hata: {e}")
37
  st.stop()
38
 
39
- # --- 3. ÜST BAŞLIK VE AÇIKLAMA ---
40
  st.title("🫀 Heart Disease Risk Prediction")
41
  st.subheader("Kalp Hastalığı Risk Tahmini")
42
- st.info("Fill in the patient data on the left and click 'Predict'. / Soldaki hasta verilerini doldurun ve 'Tahmin Et' butonuna basın.")
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
43
 
44
  # --- 4. GİRİŞ ALANLARI (SIDEBAR) ---
45
- st.sidebar.header("📋 Patient Data / Hasta Verileri")
46
-
47
- def get_user_inputs():
48
- # Sayısal girişler ve seçimler
49
- age = st.sidebar.slider("Age / Yaş", 1, 100, 50)
50
- sex = st.sidebar.radio("Sex / Cinsiyet", [1, 0], format_func=lambda x: "Male/Erkek" if x == 1 else "Female/Kadın")
51
- cp = st.sidebar.selectbox("Chest Pain Type / Göğüs Ağrısı Tipi (0-3)", [0, 1, 2, 3])
52
- trestbps = st.sidebar.number_input("Resting BP / Kan Basıncı (mm Hg)", 50, 250, 120)
53
- chol = st.sidebar.number_input("Cholesterol / Kolesterol (mg/dl)", 100, 600, 200)
54
- fbs = st.sidebar.radio("Fasting Blood Sugar > 120 / Şeker Yüksek mi?", [0, 1], format_func=lambda x: "Yes/Evet" if x == 1 else "No/Hayır")
55
- restecg = st.sidebar.selectbox("Resting ECG / EKG Sonucu (0-2)", [0, 1, 2])
56
- thalach = st.sidebar.slider("Max Heart Rate / Maks. Kalp Hızı", 50, 220, 150)
57
- exang = st.sidebar.radio("Exercise Induced Angina / Egzersiz Ağrısı?", [0, 1], format_func=lambda x: "Yes/Evet" if x == 1 else "No/Hayır")
58
- oldpeak = st.sidebar.number_input("Oldpeak (ST Depression)", 0.0, 10.0, 1.0, step=0.1)
59
- slope = st.sidebar.selectbox("Slope of ST Segment (0-2)", [0, 1, 2])
60
- ca = st.sidebar.selectbox("Major Vessels / Damar Sayısı (0-4)", [0, 1, 2, 3, 4])
61
- thal = st.sidebar.selectbox("Thalassemia / Thal (0-3)", [0, 1, 2, 3])
62
-
63
- data = {
 
64
  'age': age, 'sex': sex, 'cp': cp, 'trestbps': trestbps, 'chol': chol,
65
  'fbs': fbs, 'restecg': restecg, 'thalach': thalach, 'exang': exang,
66
  'oldpeak': oldpeak, 'slope': slope, 'ca': ca, 'thal': thal
67
- }
68
- return spark.createDataFrame([data])
69
-
70
- input_df = get_user_inputs()
71
-
72
- # --- 5. TAHMİN VE SONUÇ EKRANI ---
73
- col1, col2 = st.columns([1, 1])
74
-
75
- with col1:
76
- st.markdown("### User Profile / Kullanıcı Profili")
77
- st.write(input_df.toPandas().T.rename(columns={0: 'Values'}))
78
-
79
- with col2:
80
- st.markdown("### Prediction / Tahmin")
81
- if st.button("RUN ANALYSIS / ANALİZİ ÇALIŞTIR"):
82
- # Veriyi hazırla
83
- feature_cols = ['age', 'sex', 'cp', 'trestbps', 'chol', 'fbs', 'restecg', 'thalach', 'exang', 'oldpeak', 'slope', 'ca', 'thal']
84
- assembler = VectorAssembler(inputCols=feature_cols, outputCol="features")
85
- processed_data = assembler.transform(input_df)
86
-
87
- # Model tahmini
88
- prediction_output = model.transform(processed_data)
89
- result = prediction_output.select("prediction").collect()[0][0]
90
- prob = prediction_output.select("probability").collect()[0][0]
91
-
92
- # Sonuç Görselleştirme
93
- if result == 1.0:
94
- st.error(f"### ⚠️ HIGH RISK / YÜKSEK RİSK")
95
- st.metric("Risk Probability / Risk Olasılığı", f"%{round(prob[1]*100, 2)}")
96
- st.write("Please consult a doctor. / Lütfen bir doktora danışın.")
97
- else:
98
- st.success(f"### ✅ LOW RISK / DÜŞÜK RİSK")
99
- st.metric("Healthy Probability / Sağlıklı Olasılığı", f"%{round(prob[0]*100, 2)}")
100
- st.write("Results look stable. / Sonuçlar stabil görünüyor.")
101
 
102
  st.divider()
103
- st.caption("Disclaimer: This AI model is for educational purposes. / Bu yapay zeka modeli eğitim amaçlıdır.")
 
5
  from pyspark.ml.feature import VectorAssembler
6
 
7
  # --- 1. SAYFA AYARLARI (PAGE CONFIG) ---
8
+ st.set_page_config(page_title="Heart Predictor", page_icon="🫀", layout="wide")
9
+
10
+ # Spark ve Modeli Başlat
 
 
 
 
 
 
 
 
 
11
  @st.cache_resource
12
+ def initialize_app():
 
13
  spark = SparkSession.builder \
14
+ .appName("HeartApp") \
15
  .master("local[*]") \
16
  .config("spark.driver.bindAddress", "127.0.0.1") \
17
  .getOrCreate()
 
 
18
  model = LogisticRegressionModel.load("heart_model")
19
  return spark, model
20
 
21
  try:
22
+ spark, model = initialize_app()
23
  except Exception as e:
24
  st.error(f"Error / Hata: {e}")
25
  st.stop()
26
 
27
+ # --- 2. BAŞLIKLAR (HEADERS) ---
28
  st.title("🫀 Heart Disease Risk Prediction")
29
  st.subheader("Kalp Hastalığı Risk Tahmini")
30
+
31
+ st.markdown("---")
32
+
33
+ # --- 3. HIZLI TEST BUTONLARI (QUICK SCENARIOS) ---
34
+ st.markdown("### 🧪 Quick Test Scenarios / Hızlı Test Senaryoları")
35
+ st.write("Click a button to auto-fill the form / Formu otomatik doldurmak için bir butona basın:")
36
+
37
+ col_b1, col_b2 = st.columns(2)
38
+
39
+ # Session state ile değerleri kontrol edelim (Butonlara basınca form güncellenir)
40
+ if 'preset' not in st.session_state:
41
+ st.session_state.preset = "default"
42
+
43
+ if col_b1.button("🟢 Load Low Risk (Healthy) / Düşük Risk (Sağlıklı)"):
44
+ st.session_state.preset = "low"
45
+ if col_b2.button("🔴 Load High Risk (Patient) / Yüksek Risk (Hasta)"):
46
+ st.session_state.preset = "high"
47
+
48
+ # Senaryo değerlerini tanımlayalım
49
+ if st.session_state.preset == "low":
50
+ # Genç, sağlıklı değerler
51
+ d = [25, 0, 1, 110, 180, 0, 0, 180, 0, 0.0, 2, 0, 1]
52
+ elif st.session_state.preset == "high":
53
+ # Yaşlı, riskli değerler (Yüksek Tansiyon, Oldpeak ve Damar Sayısı)
54
+ d = [65, 1, 0, 160, 290, 1, 2, 105, 1, 3.2, 1, 3, 3]
55
+ else:
56
+ # Varsayılan değerler
57
+ d = [50, 1, 1, 120, 210, 0, 1, 145, 0, 1.0, 1, 0, 2]
58
+
59
+ st.markdown("---")
60
 
61
  # --- 4. GİRİŞ ALANLARI (SIDEBAR) ---
62
+ st.sidebar.header("📋 Input Data / Veri Girişi")
63
+
64
+ age = st.sidebar.slider("Age / Yaş", 1, 100, d[0])
65
+ sex = st.sidebar.radio("Sex / Cinsiyet", [1, 0], index=(0 if d[1]==1 else 1), format_func=lambda x: "Male/Erkek (1)" if x == 1 else "Female/Kadın (0)")
66
+ cp = st.sidebar.selectbox("Chest Pain / Göğüs Ağrısı (0-3)", [0, 1, 2, 3], index=d[2])
67
+ trestbps = st.sidebar.number_input("Blood Pressure / Tansiyon", 50, 250, d[3])
68
+ chol = st.sidebar.number_input("Cholesterol / Kolesterol", 100, 600, d[4])
69
+ fbs = st.sidebar.selectbox("Fasting Sugar / Şeker > 120", [0, 1], index=d[5], format_func=lambda x: "Yes/Evet (1)" if x == 1 else "No/Hayır (0)")
70
+ restecg = st.sidebar.selectbox("Resting ECG / EKG (0-2)", [0, 1, 2], index=d[6])
71
+ thalach = st.sidebar.slider("Max Heart Rate / Maks. Kalp Hızı", 50, 220, d[7])
72
+ exang = st.sidebar.radio("Exercise Angina / Egzersiz Ağrısı", [0, 1], index=d[8], format_func=lambda x: "Yes/Evet (1)" if x == 1 else "No/Hayır (0)")
73
+ oldpeak = st.sidebar.number_input("Oldpeak (ST Depression)", 0.0, 10.0, d[9], step=0.1)
74
+ slope = st.sidebar.selectbox("Slope (0-2)", [0, 1, 2], index=d[10])
75
+ ca = st.sidebar.selectbox("Major Vessels / Damar Sayısı (0-4)", [0, 1, 2, 3, 4], index=d[11])
76
+ thal = st.sidebar.selectbox("Thalassemia / Thal (0-3)", [0, 1, 2, 3], index=d[12])
77
+
78
+ # --- 5. TAHMİN BÖLÜMÜ (PREDICTION) ---
79
+ if st.button("🚀 RUN ANALYSIS / ANALİZİ ÇALIŞTIR"):
80
+ # Spark için veri hazırla
81
+ input_data = spark.createDataFrame([{
82
  'age': age, 'sex': sex, 'cp': cp, 'trestbps': trestbps, 'chol': chol,
83
  'fbs': fbs, 'restecg': restecg, 'thalach': thalach, 'exang': exang,
84
  'oldpeak': oldpeak, 'slope': slope, 'ca': ca, 'thal': thal
85
+ }])
86
+
87
+ # Özellikleri vektöre çevir
88
+ feature_cols = ['age', 'sex', 'cp', 'trestbps', 'chol', 'fbs', 'restecg', 'thalach', 'exang', 'oldpeak', 'slope', 'ca', 'thal']
89
+ assembler = VectorAssembler(inputCols=feature_cols, outputCol="features")
90
+ final_df = assembler.transform(input_data)
91
+
92
+ # Tahmin yap
93
+ prediction = model.transform(final_df)
94
+ res = prediction.select("prediction").collect()[0][0]
95
+ prob = prediction.select("probability").collect()[0][0]
96
+
97
+ st.markdown("### 📊 Result / Sonuç:")
98
+ if res == 1.0:
99
+ st.error(f"🚨 **HIGH RISK / YÜKSEK RİSK** (Prob: %{round(prob[1]*100, 2)})")
100
+ st.write("According to the model, heart disease risk is high. / Modele göre kalp hastalığı riski yüksek.")
101
+ else:
102
+ st.success(f"💚 **LOW RISK / DÜŞÜK RİSK** (Prob: %{round(prob[0]*100, 2)})")
103
+ st.write("According to the model, heart disease risk is low. / Modele göre risk düşük görünmektedir.")
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
104
 
105
  st.divider()
106
+ st.caption("Disclaimer: For educational purposes only. / Tıbbi tavsiye niteliği taşımaz.")