De data in een json payload gezet die vervolgens verstuurt wordt naar de raspberry pi

This commit is contained in:
Yannick van Etten
2024-12-12 16:40:24 +01:00
parent 730d2b47b8
commit c0cf6f1360

View File

@@ -77,6 +77,12 @@ void reconnect() {
} }
void loop() { void loop() {
// Zorg ervoor dat MQTT verbonden blijft
if (!client.connected()) {
reconnect();
}
client.loop();
float h = dht.readHumidity(); float h = dht.readHumidity();
float t = dht.readTemperature(); float t = dht.readTemperature();
@@ -93,18 +99,22 @@ void loop() {
return; return;
} }
// Print de sensorwaarden naar de seriële monitor // Maak een JSON-payload
Serial.print("Luchtvochtigheid: "); String payload = "{";
Serial.print(h); payload += "\"humidity\":" + String(h) + ",";
Serial.print(" %\tTemperatuur: "); payload += "\"temperature\":" + String(t) + ",";
Serial.print(t); payload += "\"mq5\":" + String(mq5Value) + ",";
Serial.println(" *C"); payload += "\"tvoc\":" + String(sgp.TVOC) + ",";
payload += "\"eco2\":" + String(sgp.eCO2);
payload += "}";
Serial.print("MQ5 waarde: "); // Verzend de payload via MQTT
Serial.println(mq5Value); if (client.publish(mqtt_topic, payload.c_str())) {
Serial.println("Bericht verzonden: " + payload);
} else {
Serial.println("Fout bij verzenden van bericht!");
}
Serial.print("TVOC "); Serial.print(sgp.TVOC); Serial.print(" ppb\t"); // Wacht 5 seconden voor de volgende meting
Serial.print("eCO2 "); Serial.print(sgp.eCO2); Serial.println(" ppm"); delay(5000);
delay(500);
} }