ARTIK + MKR1000 + DHT11 + MQTT

Code

• artik_dht11_sensor.ino
• artik_led_actor.ino

artik_dht11_sensor.inoC/C++

#include #include #include #include "DHT.h"#define DHTPIN 2 // met welke digitale pin we zijn verbonden#define DHTTYPE DHT11 / / DHT 11DHT dht(DHTPIN, DHTTYPE);const char* _SSID ="[Wi-Fi SSID]";const char* _PASSWORD ="[Wi-Fi-wachtwoord]"; // ARTIK Cloud MQTT paramschar mqttCloudServer[] ="api.artik.cloud";int mqttCloudPort =8883;char mqttCloudClientName[] ="ARTIK-Arduino";char mqttCloudUsername[] ="[apparaat-id]"; char mqttCloudPassword[] ="[apparaat-token]"; char mqttCloudDataOut[] ="/v1.1/messages/[apparaat-id]"; WiFiSSSLient ipCloudStack;MQTTClient mqttCloudClient;char buf[128];float temperatuur, vochtigheid;int n =0;void getNextSample(float* Temperature, float* Humidity){ // Wacht een paar seconden tussen metingen. vertraging (2000); // Het lezen van temperatuur of vochtigheid duurt ongeveer 250 milliseconden! // Sensormetingen kunnen ook tot 2 seconden 'oud' zijn (het is een zeer trage sensor) *Vochtigheid =dht.readHumidity(); // Lees temperatuur als Celsius (de standaardinstelling) *Temperature =dht.readTemperature(); // Lees temperatuur als 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("Temperatuur="); Serial.println(*Temperatuur); Serial.print("Vochtigheid="); Serial.println(*Vochtigheid);}void setup() {Serial.begin(57600); dht.begin(); // Wifi-instelling WiFi.begin (_SSID, _PASSWORD); while (WiFi.status() !=WL_CONNECTED) { delay(500); Serieel.print("."); } Serieel.println(); Serial.println("WiFi verbonden"); Serial.print("IP-adres:"); Serial.println(WiFi.localIP()); mqttCloudClient.begin(mqttCloudServer, mqttCloudPort, ipCloudStack); Serial.println ("start ARTIK Cloud connect"); Serieel.println(); while (!mqttCloudClient.connect(mqttCloudClientName, mqttCloudUsername, mqttCloudPassword)) { Serial.print("*"); vertraging (500); }}void messageReceived (String-onderwerp, String-payload, char * bytes, niet-ondertekende int-lengte) {}void sendToArtikCloud (float-temperatuur, float-vochtigheid) { loadBuffer (temperatuur, vochtigheid); // laad huidige waarden in de buffer mqttCloudClient.publish(mqttCloudDataOut, buf);}void loadBuffer (float temperatuur, float vochtigheid) { StaticJsonBuffer<200> jsonBuffer; JsonObject&dataPair =jsonBuffer.createObject(); dataPair["temperatuur"] =temperatuur; dataPair["vochtigheid"] =vochtigheid; dataPair.printTo(buf, sizeof(buf));}void loop() { if (++n> 10) { Serial.println("Gestopt."); uitgang (0); } mqttCloudClient.loop(); vertraging (1000); getNextSample(&temperatuur, &vochtigheid); Serial.println("Publiceren..."); Serieel.println(); sendToArtikCloud (temperatuur, vochtigheid); vertraging (15000);}

artik_led_actor.inoC/C++

#include #include #include #define LED_RED_PIN 11#define LED_YELLOW_PIN 13#define RED_DELAY 5000#define YELLOW_DELAY 10000const char* _SSID ="[Wi-Fi SSID ]";const char* _PASSWORD ="[Wi-Fi-wachtwoord]"; // ARTIK Cloud MQTT paramschar mqttCloudServer[] ="api.artik.cloud";int mqttCloudPort =1883;char mqttCloudClientName[] ="ARTIK-Arduino";char mqttCloudUsername[] ="[apparaat-id]"; char mqttCloudPassword[] ="[apparaat-token]"; char mqttCloudActionsIn[] ="/v1.1/actions/[apparaat-id]"; WiFiClient ipCloudStack;MQTTClient mqttCloudClient;char buf[128];int savedRedValue, savedYellowValue;unsigned long savedRedTime, savedYellowTime;void setup() { Serial.begin(57600); pinMode (LED_RED_PIN, UITGANG); pinMode (LED_YELLOW_PIN, UITGANG); SavedRedValue =SavedYellowValue =0; // Wifi-instelling WiFi.begin (_SSID, _PASSWORD); while (WiFi.status() !=WL_CONNECTED) { delay(500); Serieel.print("."); } Serieel.println(); Serial.println("WiFi verbonden"); Serial.print("IP-adres:"); Serial.println(WiFi.localIP()); mqttCloudClient.begin(mqttCloudServer, mqttCloudPort, ipCloudStack); Serial.println ("start ARTIK Cloud connect"); Serieel.println(); while (!mqttCloudClient.connect(mqttCloudClientName, mqttCloudUsername, mqttCloudPassword)) { Serial.print("*"); vertraging (500); } mqttCloudClient.subscribe(mqttCloudActionsIn);}void messageReceived(String topic, String payload, char * bytes, unsigned int lengte) { Serial.print("topic="); Serial.println(onderwerp); Serial.print("payload="); Serial.println(lading); Serieel.print("bytes="); Serieel.println(bytes); Serieel.print("length="); Serial.println(lengte); parseBuffer(payload);}void parseBuffer(String payload) { StaticJsonBuffer<200> jsonBuffer; String json =lading; JsonObject&root =jsonBuffer.parseObject(json); const char* nameparam =root["acties"][0]["naam"]; const int actionLEDRed =root["actions"][0]["parameters"]["led_red"]; const int actionLEDYellow =root["actions"][0]["parameters"]["led_yellow"]; Serial.print("naam="); Serial.println(naamparam); Serial.print("led_red="); Serial.println(actionLEDRed); Serial.print("led_yellow="); Serial.println(actionLEDYellow); Serieel.println(); if (actionLEDRed ==1) {if (savedRedValue!=actionLEDRed) {digitalWrite(LED_RED_PIN, HIGH); saveRedValue =actionLEDRed; } saveRedTime =millis(); } else {if (savedRedValue!=actionLEDRed) {if (millis() - savedRedTime> RED_DELAY) {digitalWrite(LED_RED_PIN, LOW); saveRedValue =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; } } } }void loop() { mqttCloudClient.loop(); vertraging (500); }