Klagarge/MSE-PI-E2EEDA-Plein-de-eeeeeeeeeee
1
0
Fork 0
Code Issues Pull Requests Releases 1 Activity

fix(db): filter random value

Browse Source 
Signed-off-by: Klagarge <remi@heredero.ch>
This commit is contained in:
Rémi Heredero
2026-05-27 15:23:13 +02:00
parent 9776695228
commit c78f1e1509
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
db/src/main.go
View File

@@ -146,13 +146,19 @@ func main() {
} }
} }
// If CO2PPM value is present and over 1000000000 delete the field // If CO2PPM value is present and over 1,000,000,000 delete the field, it's calibration value
values := dp.GetValues() values := dp.GetValues()
if values.CO2PPM > 1000000000 { if values.CO2PPM > 1000000000 {
log.Printf("[Main] Warning: CO2PPM value %d is over threshold, setting to 0\n", values.CO2PPM) log.Printf("[Main] Warning: CO2PPM value %d is calibrating, setting to 0\n", values.CO2PPM)
values.CO2PPM = 0 values.CO2PPM = 0
} }
// Still too high value, something wrong, dropping datapoint
if values.CO2PPM > 10000 {
log.Printf("[Main] Error: CO2PPM value %d is over threshold, dropping Datapoint\n", values.CO2PPM)
return
}
translatedDp := provenceMeasurement.CreateDataPoint(influxTags, values, dp.Timestamp()) translatedDp := provenceMeasurement.CreateDataPoint(influxTags, values, dp.Timestamp())
if err := influxGateway.AddDatapoint(&translatedDp); err != nil { if err := influxGateway.AddDatapoint(&translatedDp); err != nil {