ARTIK + MKR1000 + DHT11 + MQTT

Código

• artik_dht11_sensor.ino
• artik_led_actor.ino

artik_dht11_sensor.ino C / C ++

 #include  #include  #include  #include "DHT.h" #define DHTPIN 2 // a qué pin digital estamos conectados # define DHTTYPE DHT11 / / DHT 11DHT dht (DHTPIN, DHTTYPE); const char * _SSID ="[Wi-Fi SSID]"; const char * _PASSWORD ="[Wi-Fi Password]"; // ARTIK Cloud MQTT paramschar mqttCloudServer [] ="api.artik.cloud"; int mqttCloudPort =8883; char mqttCloudClientName [] ="ARTIK-Arduino"; char mqttCloudUsername [] ="[id-dispositivo]"; char mqttCloudPassword [] ="[token de dispositivo]"; char mqttCloudDataOut [] ="/v1.1/messages/[device-id]"; WiFiSSLClient ipCloudStack; MQTTClient mqttCloudClient; char buf [128]; temperatura de flotación, humedad; int n =0; void getNextSample (float * Temperature, float * Humidity) {// Espere unos segundos entre mediciones. retraso (2000); // ¡La lectura de la temperatura o la humedad tarda unos 250 milisegundos! // Las lecturas del sensor también pueden tener hasta 2 segundos de antigüedad (es un sensor muy lento) * Humidity =dht.readHumidity (); // Leer la temperatura como Celsius (por defecto) * Temperature =dht.readTemperature (); // Lee la temperatura como Fahrenheit (isFahrenheit =true) // float f =dht.readTemperature (true); //printf("Temp=%.2f, Pres =%. 2f, Humi =%. 2f \ n ", Temp_c__f, Pres_hPa__f, Humi_pct__f); Serial.print ("Temperatura ="); Serial.println (* Temperatura); Serial.print ("Humedad ="); Serial.println (* Humedad);} void setup () {Serial.begin (57600); dht.begin (); // Configuración de Wifi WiFi.begin (_SSID, _PASSWORD); while (WiFi.status ()! =WL_CONNECTED) {retraso (500); Serial.print ("."); } Serial.println (); Serial.println ("WiFi conectado"); Serial.print ("dirección IP:"); Serial.println (WiFi.localIP ()); mqttCloudClient.begin (mqttCloudServer, mqttCloudPort, ipCloudStack); Serial.println ("iniciar ARTIK Cloud connect"); Serial.println (); while (! mqttCloudClient.connect (mqttCloudClientName, mqttCloudUsername, mqttCloudPassword)) {Serial.print ("*"); retraso (500); }} void messageReceived (tema de cadena, carga útil de cadena, char * bytes, longitud int sin firmar) {} void sendToArtikCloud (temperatura de flotación, humedad de flotación) {loadBuffer (temperatura, humedad); // carga los valores actuales en el búfer mqttCloudClient.publish (mqttCloudDataOut, buf);} void loadBuffer (temperatura de flotación, humedad de flotación) {StaticJsonBuffer <200> jsonBuffer; JsonObject &dataPair =jsonBuffer.createObject (); dataPair ["temperatura"] =temperatura; dataPair ["humedad"] =humedad; dataPair.printTo (buf, sizeof (buf));} void loop () {if (++ n> 10) {Serial.println ("Detenido"); salir (0); } mqttCloudClient.loop (); retraso (1000); getNextSample (&temperatura y humedad); Serial.println ("Publicando ..."); Serial.println (); sendToArtikCloud (temperatura, humedad); retraso (15000);} 

artik_led_actor.ino C / C ++

 #include  #include  #include  #define LED_RED_PIN 11 # define LED_YELLOW_PIN 13 # define RED_DELAY 5000 # define YELLOW_DELAY 10000const char * _SSID =" ] "; const char * _PASSWORD =" [Contraseña de Wi-Fi] "; // ARTIK Cloud MQTT paramschar mqttCloudServer [] ="api.artik.cloud"; int mqttCloudPort =1883; char mqttCloudClientName [] ="ARTIK-Arduino"; char mqttCloudUsername [] ="[id-dispositivo]"; char mqttCloudPassword [] ="[token de dispositivo]"; char mqttCloudActionsIn [] ="/v1.1/actions/[device-id]"; WiFiClient ipCloudStack; MQTTClient mqttCloudClient; char buf [128]; int SavedRedValue, SavedYellowValue; unsigned long SavedRedTime, SavedYellowTime; void setup () {Serial.begin (57600); pinMode (LED_RED_PIN, SALIDA); pinMode (LED_YELLOW_PIN, SALIDA); SavedRedValue =SavedYellowValue =0; // Configuración de Wifi WiFi.begin (_SSID, _PASSWORD); while (WiFi.status ()! =WL_CONNECTED) {retraso (500); Serial.print ("."); } Serial.println (); Serial.println ("WiFi conectado"); Serial.print ("dirección IP:"); Serial.println (WiFi.localIP ()); mqttCloudClient.begin (mqttCloudServer, mqttCloudPort, ipCloudStack); Serial.println ("iniciar ARTIK Cloud connect"); Serial.println (); while (! mqttCloudClient.connect (mqttCloudClientName, mqttCloudUsername, mqttCloudPassword)) {Serial.print ("*"); retraso (500); } mqttCloudClient.subscribe (mqttCloudActionsIn);} void messageReceived (String topic, String payload, char * bytes, unsigned int length) {Serial.print ("topic ="); Serial.println (tema); Serial.print ("carga útil ="); Serial.println (carga útil); Serial.print ("bytes ="); Serial.println (bytes); Serial.print ("longitud ="); Serial.println (longitud); parseBuffer (carga útil);} void parseBuffer (carga útil de cadena) {StaticJsonBuffer <200> jsonBuffer; String json =carga útil; JsonObject &root =jsonBuffer.parseObject (json); const char * nameparam =root ["acciones"] [0] ["nombre"]; const int actionLEDRed =root ["acciones"] [0] ["parámetros"] ["led_red"]; const int actionLEDYellow =root ["acciones"] [0] ["parámetros"] ["led_yellow"]; Serial.print ("nombre ="); Serial.println (nombreparam); Serial.print ("led_red ="); Serial.println (actionLEDRed); Serial.print ("led_yellow ="); Serial.println (actionLEDYellow); Serial.println (); if (actionLEDRed ==1) {if (SavedRedValue! =actionLEDRed) {digitalWrite (LED_RED_PIN, HIGH); SavedRedValue =actionLEDRed; } SavedRedTime =millis (); } else {if (SavedRedValue! =actionLEDRed) {if (millis () - SavedRedTime> RED_DELAY) {digitalWrite (LED_RED_PIN, LOW); SavedRedValue =actionLEDRed; }}} if (actionLEDYellow ==1) {if (SavedYellowValue! =actionLEDYellow) {digitalWrite (LED_YELLOW_PIN, HIGH); SavedYellowValue =actionLEDYellow; } SavedYellowTime =millis (); } else {if (SavedYellowValue! =actionLEDYellow) {if (millis () - SavedYellowTime> YELLOW_DELAY) {digitalWrite (LED_YELLOW_PIN, LOW); SavedYellowValue =actionLEDYellow; }}}} bucle vacío () {mqttCloudClient.loop (); retraso (500); }