diff --git a/db/src/main.go b/db/src/main.go
index 19a3813..0d3fc93 100644
--- a/db/src/main.go
+++ b/db/src/main.go
@@ -143,7 +143,15 @@ func main() {
 			{Subject: "room", Content: room},
 			{Subject: "node", Content: nodeID},
 		}
-		translatedDp := provenceMeasurement.CreateDataPoint(influxTags, dp.GetValues(), dp.Timestamp())
+
+		// If CO2PPM value is present and over 1000000000 delete the field
+		values := dp.GetValues()
+		if values.CO2PPM > 1000000000 {
+			log.Printf("[Main] Warning: CO2PPM value %d is over threshold, setting to 0\n", values.CO2PPM)
+			values.CO2PPM = 0
+		}
+
+		translatedDp := provenceMeasurement.CreateDataPoint(influxTags, values, dp.Timestamp())
 
 		if err := influxGateway.AddDatapoint(&translatedDp); err != nil {
 			log.Printf("[Main] Error adding datapoint to influx: %v\n", err)