Monitoreo ambiental de Arduino

Código

• Bosquejo de monitoreo ambiental
• Entorno click-deviceType.json

Boceto de monitoreo del entorno Arduino

 #include  #include  #include  #include  #include  #include  #include  #include "WolkConn.h" #include "MQTTClient.h" / * Número de outbound_message_t para almacenar * / # define STORAGE_SIZE 32 # define SEALEVELPRESSURE_HPA (1013.25) / * Búfer circular para almacenar mensajes salientes para persistir * / typedef struct {boolean valid; outbound_message_t outbound_messages [STORAGE_SIZE]; uint32_t head; uint32_t tail; booleano vacío; booleano completo;} Mensajes; datos de mensajes estáticos; / * Detalles de la conexión * / const char * ssid ="ssid"; const char * wifi_pass ="wifi_pass"; const char * device_key ="device_key"; const char * device_password ="device_password "; const char * hostname =" api-demo.wolkabout.com "; int portno =1883; WiFiClient espClient; Cliente PubSubClient (espClient); / * Contexto del conector WolkConnect-Arduino * / static wolk_ctx_t wolk; / * Iniciar almacenamiento flash * / FlashStorage (flash_store, Messages); / * Inicia la comunicación del sensor i2c * / Adafruit_BME680 bme; RTCZero rtc; bool read; / * Lee el sensor cada minuto. Si cambia este parámetro, asegúrese de que sea <60 * / const byte readEvery =1; bool publish; / * Publish cada 10 minutos. Si cambia este parámetro, asegúrese de que sea <60 * / const byte publishEvery =10; byte publishMin; / * Almacenamiento Flash e implementación de persistencia personalizada * / void _flash_store () {data.valid =true; flash_store.write (data);} void aumento_pointer (uint32_t * pointer) {if ((* pointer) ==(STORAGE_SIZE - 1)) {(* pointer) =0; } else {(* puntero) ++; }} void _init () {datos =flash_store.read (); if (data.valid ==false) {data.head =0; data.tail =0; data.empty =verdadero; data.full =falso; }} bool _push (outbound_message_t * outbound_message) {if (data.full) {incremento_pointer (&data.head); } memcpy (&data.outbound_messages [data.tail], outbound_message, sizeof (outbound_message_t)); aumentar_pointer (&data.tail); data.empty =falso; data.full =(data.tail ==data.head); return true;} bool _peek (outbound_message_t * outbound_message) {memcpy (outbound_message, &data.outbound_messages [data.head], sizeof (outbound_message_t)); return true;} bool _pop (outbound_message_t * outbound_message) {memcpy (outbound_message, &data.outbound_messages [data.head], sizeof (outbound_message_t)); aumentar_pointer (&data.head); data.full =falso; data.empty =(data.tail ==data.head); return true;} bool _is_empty () {return data.empty;} void init_wifi () {if (WiFi.status ()! =WL_CONNECTED) {while (WiFi.begin (ssid, wifi_pass)! =WL_CONNECTED) {delay (1000 ); }}} void setup_wifi () {retraso (10); if (WiFi.status ()! =WL_CONNECTED) {int numAttempts =0; while (WiFi.begin (ssid, wifi_pass)! =WL_CONNECTED) {numAttempts ++; if (numAttempts ==10) {Serial.println ("¡No se pudo conectar WiFi!"); descanso; } retraso (1000); }}} configuración vacía () {pinMode (LED_BUILTIN, SALIDA); digitalWrite (LED_BUILTIN, BAJO); / * Inicializar la estructura circular del búfer * / _init (); init_wifi (); wolk_init (&wolk, NULL, NULL, NULL, NULL, device_key, device_password, &client, hostname, portno, PROTOCOL_JSON_SINGLE, NULL, NULL); wolk_init_custom_persistence (&wolk, _push, _peek, _pop, _is_empty); / * El LED integrado se encenderá si algo salió mal * / if (! Bme.begin ()) {digitalWrite (LED_BUILTIN, HIGH); } / * Sensor init * / bme.setTemperatureOversampling (BME680_OS_8X); bme.setHumidityOversampling (BME680_OS_2X); bme.setPressureOversampling (BME680_OS_4X); bme.setIIRFilterSize (BME680_FILTER_SIZE_3); bme.setGasHeater (320, 150); // 320 * C para un retraso de 150 ms (200); leer =verdadero; publicar =verdadero; / * Obtener la época actual del servidor * / wolk_connect (&wolk); retraso (100); wolk_update_epoch (&wolk); while (! (wolk.pong_received)) {wolk_process (&wolk); escritura digital (LED_BUILTIN, ALTO); retraso (1000); } digitalWrite (LED_BUILTIN, BAJO); wolk_disconnect (&wolk); rtc.begin (); rtc.setEpoch (wolk.epoch_time); rtc.setAlarmTime (rtc.getHours (), (rtc.getMinutes () + readEvery)% 60, rtc.getSeconds ()); rtc.enableAlarm (rtc.MATCH_MMSS); rtc.attachInterrupt (alarmMatch); publishMin =(rtc.getMinutes () + publishEvery)% 60; WiFi.lowPowerMode ();} void loop () {/ * Para mantener la rutina de interrupción lo más corta posible, la rutina solo establece las tareas a realizar read =true significa que la lectura del sensor debe realizarse. las lecturas deben publicarse en la plataforma o conservarse en flash si la conexión no está disponible * / if (read) {read =false; if (! bme.performReading ()) {digitalWrite (LED_BUILTIN, HIGH); } wolk_add_numeric_sensor_reading (&wolk, "T", bme.temperature, rtc.getEpoch ()); wolk_add_numeric_sensor_reading (&wolk, "H", bme.humidity, rtc.getEpoch ()); wolk_add_numeric_sensor_reading (&wolk, "P", bme.pressure / 100.0, rtc.getEpoch ()); wolk_add_numeric_sensor_reading (&wolk, "GR", bme.gas_resistance, rtc.getEpoch ()); wolk_add_numeric_sensor_reading (&wolk, "A", bme.readAltitude (SEALEVELPRESSURE_HPA), rtc.getEpoch ()); / * establecer una nueva alarma * / int alarmMin =(rtc.getMinutes () + readEvery)% 60; rtc.setAlarmMinutes (alarmMin); retraso (100); } si (publicar) {publicar =falso; setup_wifi (); wolk_connect (&wolk); if (! wolk.is_connected) {_flash_store (); } retraso (100); if (wolk_publish (&wolk) ==W_TRUE) {_flash_store (); } / * establecer una nueva hora de publicación * / publishMin =(rtc.getMinutes () + publishEvery)% 60; retraso (100); wolk_disconnect (&wolk); retraso (100); } retraso (100); } / * Rutina de interrupción temporizada * / void alarmMatch () {read =true; if (publishMin ==rtc.getMinutes ()) {publish =true; }} 

Entorno click-deviceType.json JSON

 [{"name":"Environment click", "description":"Tipo de dispositivo para el sensor BME680 en la placa de MikroElektronika Environment Click", "guid":" def68ff6-63c5-4f9c-a066-bcc944b7bd2d "," deviceType ":" ESTÁNDAR "," protocolo ":" JSON "," ConnectType ":null," firmwareUpdateType ":null," feeds ":[{" nombre ":" Temperatura "," descripción ":nulo," referencia ":" T "," unidad ":{" nombre ":" CELSIUS "," guid ":" 7c805d10-a879-11e9-83cd-0a0027000005 "}}, {" name ":" Humedad "," descripción ":nulo," referencia ":" H "," unidad ":{" name ":" HUMIDITY_PERCENT "," guid ":" 7c8080a3-a879-11e9-83cd-0a0027000005 "} }, {"nombre":"Presión", "descripción":nulo, "referencia":"P", "unidad":{"nombre":"MILLIBAR", "guid":"7c807980-a879-11e9-83cd -0a0027000005 "}}, {" nombre ":" Resistencia al gas "," descripción ":nulo," referencia ":" GR "," unidad ":{" nombre ":" OHM "," guid ":" 7c805890- a879-11e9-83cd-0a0027000005 "}}, {" nombre ":" Altitud "," descripción ":nulo," referencia e ":" A "," unidad ":{" nombre ":" MEDIDOR "," guid ":" 7c805a59-a879-11e9-83cd-0a0027000005 "}}]," actuadores ":[]," alarmas ":[], "configs":[], "atributos":[{"nombre":"CONNECTIVITY_TYPE", "dataType":"ENUM", "validationRegex":"^ (MQTT | HTTP) $", "opciones":["MQTT", "HTTP"], "defaultValue":"MQTT", "required":true, "readOnly":true}, {"name":"FIRMWARE_UPDATE_ENABLED", "dataType":"BOOLEAN", "validationRegex ":" ^ (true | false) $ "," options ":null," defaultValue ":null," required ":false," readOnly ":true}, {" name ":" FIRMWARE_VERSION "," dataType ":"STRING", "validationRegex":null, "options":null, "defaultValue":null, "required":false, "readOnly":true}, {"name":"FILE_DIRECT_DOWNLOAD_ENABLED", "dataType":"BOOLEAN "," validationRegex ":" ^ (true | false) $ "," options ":null," defaultValue ":null," required ":false," readOnly ":true}, {" name ":" FILE_URL_DOWNLOAD_ENABLED ", "dataType":"BOOLEAN", "validationRegex":"^ (true | false) $", "options":null, "defaultValue":null, "required":false, " readOnly ":true}]}] 

WolkAbout Environment Monitoring

Arduino WiFi 101 Shield

Controlador de sensor unificado Adafruit

Biblioteca Adafruit BME680

Biblioteca RTC para Arduino

Biblioteca FlashStorage para Arduino

WolkConnect-Arduino

Esquemas