Datenbank für MQTT einrichten

#include <NanoESP.h>
#include <NanoESP_MQTT.h>
#include "DHT.h"
#include <SoftwareSerial.h>


/*
* NanoESP MQTT
 Change SSID and PASSWORD.
*/
//set your WiFi
#define SSID "Chris"
#define PASSWORD "2548621671438430"


#define LED_WLAN 13
#define DEBUG true


//defines for sensor DHT11
#define DHTPIN A0
#define DHTTYPE DHT11   // DHT 11
DHT dht(DHTPIN, DHTTYPE);


NanoESP nanoesp = NanoESP();
NanoESP_MQTT mqtt = NanoESP_MQTT(nanoesp);


//globale Value for Humidity & Temperature
unsigned int h, t;




//_________________setup WiFi- and MQTT-Connection_______________________
void setup() {
 Serial.begin(19200);


 nanoesp.init();
 nanoesp.configWifiStation(SSID, PASSWORD);
 dht.begin();
 if (nanoesp.wifiConnected()) {
   Serial.println ("Wifi connected");
   digitalWrite(LED_WLAN, HIGH);
 }
 else {
   Serial.println ("Wifi not Connected");
 }


 //Print IP in Terminal
 Serial.println (nanoesp.getIp());


 //if (mqtt.MQTT_Connect(0, "broker.mqttdashboard.com", 1883, "NanoESP")) { //alternative broker


 if (mqtt.connect(0, "192.168.178.136", 1883, "NanoESP")) {


   if (mqtt.publish(0, "a/b", "Hello from NanoESP")) Serial.println ("Published to a/b");
   if (mqtt.publish(0, "test", "Hello from NanoESP")) Serial.println ("Published to test");
   if (mqtt.subscribe(0, "test")) Serial.println ("Subscribed to test");
   if (mqtt.subscribe(0, "a/#")) Serial.println ("Subscribed to a/#");


   //if (MQTT_Unsubscribe(0, "test")) debug("Unsubscribed from test");
   //if (MQTT_Ping(0)) debug("Ping send ");
   //if (MQTT_Disconnect(0)) debug("Disconnect");
 }
}


//_______________calculate temperature and humidity_________________
float calculate_sensor_data(){
 // Reading temperature or humidity takes about 250 milliseconds!
 // Sensor readings may also be up to 2 seconds 'old' (its a very slow sensor)
 //Read humidity
 h = dht.readHumidity();
 // Read temperature as Celsius (the default)
 t = dht.readTemperature();
 
 // Check if any reads failed and exit early (to try again).
 if (isnan(h) || isnan(t)) {
   Serial.println("Failed to read from DHT sensor!");
   return;
 }
}


//_________________Print sensordata in the serial desktop (for tests)_____________
void print_sensor_data(unsigned int humidity,unsigned int temp){
 Serial.print ("Humidity: ");
 Serial.print (humidity);
 Serial.println("%");
 Serial.print ("Temperature: ");
 Serial.print (temp);
 Serial.println("°C");
 return;
}


//__________________publish Temperature & Humidity to the mosquitto-broker IP:192.168.178.136___________
void pub_sensor_data_mqtt(unsigned int humidity,unsigned int temp){
 String HDY = "Humidity: ";
 String pub_string_humidity = HDY + humidity;
 String TEMP = "Temperature: ";
 String pub_string_temp = TEMP + temp;
 mqtt.publish(0, "/greenhouse1/sensor1/humidity", pub_string_humidity); // (ID, Topic, String value)
 mqtt.publish(0, "/greenhouse1/sensor1/Temp", pub_string_temp); // (ID, Topic, String value)
 return;
}


//__________________Forever______________________
void loop() {
 int id, len;


 if (nanoesp.recvData(id, len)) {


   String topic, value;
   if (mqtt.recvMQTT(id, len, topic, value)) {
     Serial.println ("New Message:\nTopic=" + topic + " Value=" + value);
   }


 }
 calculate_sensor_data();
 //print_sensor_data_desktop(h,t); //testing sensor
 pub_sensor_data_mqtt(h,t);
 delay(5000);
 mqtt.stayConnected(0);        //keep the connection to broker alive 
}