How nicole10-19/airflow works
Sistema Airflow per monitorare serre controllate: genera misure simulate, le carica e pulisce, applica DBSCAN e Isolation Forest, salva risultati e metriche in PostgreSQL, quindi produce grafici comparativi. Il DAG coordina il flusso tramite task e XCom. I collegamenti seguono le chiamate e i trasferimenti esplicitamente visibili; le parti non campionate del DAG sono rappresentate solo dove confermate dal README.
Components 17
Orchestrazione
- Airflow runtime
- Greenhouse DAG
dags/greenhouse_pipeline.py
Acquisizione dati
- Generazione dati
dags/greenhouse_pipeline.py - Simulatore sensori
dags/sensor_simulator.py - CSV misure
data/sensori.csv - Caricamento CSV
dags/greenhouse_pipeline.py - Pulizia dati
dags/greenhouse_pipeline.py
Analisi anomalie
- Rilevazione anomalie
dags/greenhouse_pipeline.py - DBSCAN
dags/greenhouse_pipeline.py - Isolation Forest
dags/greenhouse_pipeline.py - Metriche confronto
dags/greenhouse_pipeline.py
Persistenza e report
- Salvataggio risultati
dags/greenhouse_pipeline.py - Schema database
init-db.sql - PostgreSQL
- Generazione report
dags/greenhouse_pipeline.py - Grafici analisi
reports
Other components
- Operatore
Connections 22
- Operatore → Airflow runtime: avvia
- Airflow runtime → Greenhouse DAG: esegue DAG
- Greenhouse DAG → Generazione dati: orchestra task
- Greenhouse DAG → Caricamento CSV: orchestra task
- Greenhouse DAG → Pulizia dati: orchestra task
- Greenhouse DAG → Rilevazione anomalie: orchestra task
- Greenhouse DAG → Salvataggio risultati: orchestra task
- Greenhouse DAG → Generazione report: orchestra task
- Generazione dati → Simulatore sensori: chiama simulatore
- Simulatore sensori → CSV misure: scrive CSV
- Caricamento CSV → CSV misure: legge CSV
- Caricamento CSV → Pulizia dati: passa dati
- Pulizia dati → Rilevazione anomalie: passa dati puliti
- Rilevazione anomalie → DBSCAN: esegue algoritmo
- Rilevazione anomalie → Isolation Forest: esegue algoritmo
- Rilevazione anomalie → Metriche confronto: calcola metriche
- Rilevazione anomalie → Salvataggio risultati: passa risultati
- Metriche confronto → Salvataggio risultati: passa metriche
- Schema database → PostgreSQL: crea tabelle
- Salvataggio risultati → PostgreSQL: scrive risultati
- Generazione report → PostgreSQL: legge misure
- Generazione report → Grafici analisi: scrive grafici