merge: unify Milestone-5-fix and Milestone-6 histories for PR

monitoring/locust/README.md

@@ -0,0 +1,101 @@
+# Locust Load Testing - Skill Classification API
+
+Questa directory contiene gli script per il load testing della Skill Classification API utilizzando [Locust](https://locust.io/).
+
+## Prerequisiti
+
+Assicurati di avere Python installato e installa Locust:
+
+```bash
+pip install locust
+```
+
+## Avvio del Test
+
+### 1. Avvia Locust
+
+Dalla directory `monitoring/locust/`, esegui:
+
+```bash
+locust -f locustfile.py
+```
+
+### 2. Accedi alla Web UI
+
+Apri il browser e vai a: **http://localhost:8089**
+
+### 3. Configura il Test
+
+Nella Web UI, configura i seguenti parametri:
+
+| Parametro | Descrizione | Valore Consigliato |
+|-----------|-------------|-------------------|
+| **Host** | URL dell'API da testare | `http://localhost:8080` (Docker) o `http://localhost:8000` (locale) |
+| **Number of users** | Numero totale di utenti simulati | 10-100 |
+| **Spawn rate** | Utenti da creare al secondo | 1-10 |
+
+### 4. Avvia il Test
+
+Clicca su **"Start swarming"** per avviare il test di carico.
+
+## Task Implementati
+
+Lo script simula il comportamento di utenti reali con i seguenti task:
+
+| Task | Endpoint | Metodo | Peso | Descrizione |
+|------|----------|--------|------|-------------|
+| **Predizione Singola** | `/predict` | POST | 3 | Classifica un singolo issue text. Task principale, eseguito più frequentemente. |
+| **Predizione Batch** | `/predict/batch` | POST | 1 | Classifica multipli issue text in una singola richiesta. |
+| **Monitoraggio e Storia** | `/predictions`, `/health` | GET | 1 | Visualizza la cronologia delle predizioni e verifica lo stato del sistema. |
+
+### Distribuzione dei Pesi
+
+Con i pesi configurati (3:1:1), la distribuzione approssimativa delle richieste è:
+- **60%** - Predizione Singola
+- **20%** - Predizione Batch  
+- **20%** - Monitoraggio e Storia
+
+### Tempo di Attesa
+
+Ogni utente attende tra **1 e 5 secondi** tra un task e l'altro per simulare un comportamento realistico.
+
+## Metriche Monitorate
+
+Durante il test, Locust fornisce le seguenti metriche in tempo reale:
+
+- **RPS (Requests Per Second)**: Numero di richieste al secondo
+- **Response Time**: Tempo medio/mediano/percentili di risposta
+- **Failure Rate**: Percentuale di richieste fallite
+- **Active Users**: Numero di utenti attualmente attivi
+
+## Opzioni Avanzate
+
+### Esecuzione Headless (senza UI)
+
+```bash
+locust -f locustfile.py --headless -u 50 -r 5 -t 5m --host http://localhost:8000
+```
+
+| Opzione | Descrizione |
+|---------|-------------|
+| `--headless` | Esegui senza Web UI |
+| `-u 50` | 50 utenti simulati |
+| `-r 5` | 5 utenti creati al secondo |
+| `-t 5m` | Durata del test: 5 minuti |
+| `--host` | URL dell'API |
+
+### Esportazione Risultati
+
+```bash
+locust -f locustfile.py --headless -u 50 -r 5 -t 5m --host http://localhost:8000 --csv=results
+```
+
+Questo creerà file CSV con i risultati del test.
+
+## Struttura File
+
+```
+monitoring/locust/
+├── locustfile.py   # Script principale di load testing
+└── README.md       # Questa documentazione
+```

monitoring/locust/locustfile.py

@@ -0,0 +1,99 @@
+"""
+Locust Load Testing Script for Skill Classification API
+
+This script defines user behavior for load testing the prediction and monitoring
+endpoints of the Skill Classification API.
+"""
+
+from locust import HttpUser, task, between
+
+
+class SkillClassificationUser(HttpUser):
+    """
+    Simulated user for load testing the Skill Classification API.
+    
+    This user performs the following actions:
+    - Single predictions (most frequent)
+    - Batch predictions
+    - Monitoring and health checks
+    """
+    
+    # Default host for the API (can be overridden via --host flag or Web UI)
+    # Use http://localhost:8080 for Docker or http://localhost:8000 for local dev
+    host = "http://localhost:8080"
+    
+    # Wait between 1 and 5 seconds between tasks to simulate real user behavior
+    wait_time = between(1, 5)
+    
+    @task(3)
+    def predict_single(self):
+        """
+        Task 1: Single Prediction (Weight: 3)
+        
+        Performs a POST request to /predict with a single issue text.
+        This is the main task and executes more frequently due to higher weight.
+        """
+        payload = {
+            "issue_text": "Fix authentication bug in login module"
+        }
+        
+        with self.client.post(
+            "/predict",
+            json=payload,
+            catch_response=True
+        ) as response:
+            if response.status_code == 201:
+                response.success()
+            else:
+                response.failure(f"Prediction failed with status {response.status_code}")
+    
+    @task(1)
+    def predict_batch(self):
+        """
+        Task 2: Batch Prediction (Weight: 1)
+        
+        Performs a POST request to /predict/batch with multiple issue texts.
+        """
+        payload = {
+            "issues": [
+                {"issue_text": "Test 1"},
+                {"issue_text": "Test 2"}
+            ]
+        }
+        
+        with self.client.post(
+            "/predict/batch",
+            json=payload,
+            catch_response=True
+        ) as response:
+            if response.status_code == 200:
+                response.success()
+            else:
+                response.failure(f"Batch prediction failed with status {response.status_code}")
+    
+    @task(1)
+    def monitoring_and_history(self):
+        """
+        Task 3: Monitoring and History (Weight: 1)
+        
+        Performs GET requests to check prediction history and system health.
+        """
+        # Check prediction history
+        with self.client.get(
+            "/predictions",
+            catch_response=True
+        ) as response:
+            if 200 <= response.status_code < 300:
+                response.success()
+            else:
+                response.failure(f"Predictions history failed with status {response.status_code}")
+        
+        # Check system health
+        with self.client.get(
+            "/health",
+            catch_response=True
+        ) as response:
+            if 200 <= response.status_code < 300:
+                response.success()
+            else:
+                response.failure(f"Health check failed with status {response.status_code}")

requirements.txt

@@ -47,6 +47,8 @@ pytest-json-report>=1.5.0
 pytest-cov>=4.0.0
 pytest-xdist>=3.0.0
 
+# Load testing
+locust>=2.20.0
 # Data validation and quality
 great_expectations>=0.18.0
 deepchecks>=0.18.0