Hogar Hogar inteligente

Código

• MediaTekRx
• nodejs - servidor local
• ThermoStatController.cs
• PIRController.cs
• MoistureController.cs
• LivingRoomController.cs
• LightController.cs
• GPSController.cs
• GasController.cs
• DistanceController.cs
• BedRoomController.cs

MediaTekRx C / C ++

 / * Cliente web Este boceto se conecta a un sitio web usando la funcionalidad Wi-Fi en la plataforma MediaTek LinkIt. Cambie la macro WIFI_AP, WIFI_PASSWORD, WIFI_AUTH y SITE_URL en consecuencia. creado el 13 de julio de 2010 por dlf (Metodo2 srl) modificado el 31 de mayo de 2012 por Tom Igoe modificado el 20 de agosto de 2014 por MediaTek Inc. * / # include  #include  #include  #include  #define WIFI_AP "your ap" #define WIFI_PASSWORD "your password" #define WIFI_AUTH LWIFI_WPA // choose from LWIFI_OPEN, LWIFI_WPA, or LWIFI_WEP. # Define SITE_URL "your ip" // your ip address or azure nombre de dominioLWiFiClient c; configuración vacía () {LWiFi.begin (); Serial.begin (115200); // sigue intentando hasta que te conectes a AP Serial.println ("Conectando a AP"); while (0 ==LWiFi.connect (WIFI_AP, LWiFiLoginInfo (WIFI_AUTH, WIFI_PASSWORD))) {retraso (1000); } // sigue intentándolo hasta que te conectes al sitio web Serial.println ("Conectando al sitio web"); while (0 ==c.connect (SITE_URL, 3000)) {Serial.println ("Reconexión al sitio web"); retraso (1000); }} boolean disabledMsg =false; void loop () {// Asegúrate de que estamos conectados y descarga el contenido de la respuesta en Serial while (! c) {Serial.println ("Servidor desconectado .."); // sigue intentándolo hasta que te conectes al sitio web Serial.println ("Conectando al sitio web"); while (0 ==c.connect (SITE_URL, 3000)) {Serial.println ("Reconexión al sitio web"); retraso (1000); }} Serial.println ("Temperatura de lectura ..."); updateTemperature (); retraso (3000); Serial.println ("Detectando sonido ..."); updateSound (); retraso (3000); Serial.println ("Detectando movimiento de personas ..."); updatePIR (); retraso (3000); Serial.println ("Detectando obstáculo ..."); updateDistance (); retraso (3000); Serial.println ("Actualizando la ubicación del dispositivo ..."); updateGPSTracker (); retraso (3000); Serial.println ("Calculando la humedad del suelo ..."); updateMoisture (); retraso (3000); Serial.println ("Detectando fugas de gas ..."); updateGasLeak (); retraso (3000); Serial.println ("Grabando intensidad de luz ..."); updateLightIntensity (); retraso (3000); updateLivingroomAttributes (); retraso (3000); updateBedroomAttributes (); delay (3000);} void writeToConsole () {// Asegúrate de que estamos conectados y descarga el contenido de la respuesta en Serial while (c) {int v =c.read (); if (v! =-1) {Serial.print ((char) v); }} Serial.println (); Serial.println ("Servidor desconectado ..."); // sigue intentándolo hasta que te conectes al sitio web Serial.println ("Conectando al sitio web"); while (0 ==c.connect (SITE_URL, 3000)) {Serial.println ("Reconexión al sitio web"); retraso (1000); }} void updatePIR () {int s largos sin firmar; DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); JsonObject &deseado =root.createNestedObject ("deseado"); root ["deviceid"] ="/ iot / myhome / livingroom / pir"; // asumir la unidad predeterminada ms deseada ["motionstart"] =String (random (0,1000)); deseado ["motionend"] =Cadena (aleatorio (1000,10000)); String len =String (root.measureLength ()); c.println ("POST / iot / myhome / livingroom / pir HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); // lógica para detectar la respuesta lenta del servidor y publicar la solicitud nuevamente sin esperar una respuesta muerta s =millis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole (); } void updateDistance () {int largo sin firmar; DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); JsonObject &deseado =root.createNestedObject ("deseado"); root ["deviceid"] ="/ iot / myhome / livingroom / distanceensor"; // asumir la unidad predeterminada cm deseada ["obstáculo"] =Cadena (aleatorio (50,450)); String len =String (root.measureLength ()); c.println ("POST / iot / myhome / livingroom / distancia HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole (); } void updateGPSTracker () {int s largos sin firmar; DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); JsonObject &deseado =root.createNestedObject ("deseado"); root ["deviceid"] ="/ iot / mydevice"; deseado ["lat"] =Cadena (aleatorio (20,25)); deseado ["largo"] =Cadena (aleatorio (22,27)); String len =String (root.measureLength ()); c.println ("POST / iot / mydevice / location HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole ();} void updateMoisture () {int long unsigned int; DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); JsonObject &deseado =root.createNestedObject ("deseado"); root ["deviceid"] ="/ iot / mi casa / jardín / humedad"; // asume la unidad deseada por defecto ["humedad"] =String (random (40,60)); String len =String (root.measureLength ()); c.println ("POST / iot / myhome / jardín / humedad HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole (); } void updateGasLeak () {DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); JsonObject &deseado =root.createNestedObject ("deseado"); deseado ["fuga"] ="no"; root ["deviceid"] ="/ iot / myhome / kitchen / gas"; int s largos sin firmar; String len =String (root.measureLength ()); c.println ("POST / iot / myhome / cocina / gas HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole (); } void updateLightIntensity () {DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); JsonObject &deseado =root.createNestedObject ("deseado"); deseado ["intensidad"] ="80"; root ["deviceid"] ="/ iot / myhome / livingroom / light"; int s largos sin firmar; String len =String (root.measureLength ()); c.println ("POST / iot / myhome / livingroom / light HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole (); } void updateLivingroomAttributes () {DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); root ["deviceid"] ="/ iot / myhome / livingroom"; JsonObject &deseado =root.createNestedObject ("deseado"); // API alternativa para los atributos de la sala de estar de loggin todos a la vez deseado ["window"] ="open"; deseado ["puerta"] ="cerrado"; deseado ["ac"] ="apagado"; deseado ["temperatura"] =Cadena (aleatorio (24,28)); deseado ["humedad"] =Cadena (aleatorio (60,65)); int s largos sin firmar; String len =String (root.measureLength ()); c.println ("POST / iot / myhome / livingroom HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole (); } void updateBedroomAttributes () {DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); root ["deviceid"] ="/ iot / myhome / bedroom"; JsonObject &deseado =root.createNestedObject ("deseado"); // API alternativa para los atributos de la sala de estar de loggin todos a la vez deseado ["window"] ="open"; deseado ["puerta"] ="cerrado"; deseado ["ac"] ="apagado"; deseado ["temperatura"] =Cadena (aleatorio (22,23)); deseado ["humedad"] =Cadena (aleatorio (75,80)); int s largos sin firmar; String len =String (root.measureLength ()); c.println ("POST / iot / myhome / bedroom HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole (); } void updateSound () {int s largos sin firmar; long unsigned int e; DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); JsonObject &deseado =root.createNestedObject ("deseado"); deseado ["intensidad"] =Cadena (aleatorio (40,80)); root ["deviceid"] ="/ iot / myhome / livingroom / mic"; root ["timeutc"] =""; root ["firmado por"] =""; String len =String (root.measureLength ()); c.println ("POST / iot / myhome / livingroom / mic HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole ();} void updateTemperature () {long unsigned int s; long unsigned int e; DynamicJsonBuffer jsonBuffer; JsonObject &root =jsonBuffer.createObject (); JsonObject &deseado =root.createNestedObject ("deseado"); deseado ["temperatura"] =Cadena (aleatorio (20,40)); deseado ["humedad"] =Cadena (aleatorio (60,80)); root ["deviceid"] ="/ iot / myhome / livingroom / thermostat"; root ["timeutc"] =""; root ["firmado por"] =""; String len =String (root.measureLength ()); c.println ("POST / iot / myhome / livingroom / thermostat HTTP / 1.1"); c.println ("Host:" SITE_URL); c.println ("Tipo de contenido:aplicación / json"); c.println ("Cache-Control:no-cache"); c.print ("Contenido-Longitud:"); c.println (len); c.println ("Conexión:cerrar"); c.println (); root.printTo (c); root.printTo (Serial); s =milis (); // esperando la respuesta del servidor Serial.println ("esperando respuesta HTTP:"); while (! c. disponible ()) {retraso (100); if ((millis () - s> 3000)) {Serial.println (); Serial.println ("El servidor no responde ..."); descanso; }} Serial.println ("Llamando a escribir en la consola ..."); writeToConsole (); } 

nodejs - servidor local JavaScript

 var express =require ('express'); var router =express.Router (); var buf =require ('buffer'); var request =require ("request"); // reemplace su-ip-o-nombre-de-dominio con su dirección IP real o nombre de dominio // ejemplo iot.azurewebsites.com//example yourdomainname.com//example 47.12.67.16// accept Solicitud POST en homepagerouter.post ('/ iot / myhome / livingroom / thermostat', function (req, res) {var state =req.body; state.timeutc =new Date (); state.signedby ="orangepi"; console.log (estado); var options ={method:'POST', url:'http:// your-ip-or-domain-name / api / iot / myhome / livingroom / thermostat', headers:{'cache -control ':' no-cache ',' content-type ':' application / json '}, body:state, json:true}; request (options, function (error, response, body) {if (error) throw new Error (error); console.log (body);}); res.send ('Se registró la temperatura de la sala de estar');}); // acepta la solicitud POST microuter.post ('/ iot / myhome / livingroom / mic' , divertida ction (req, res) {var state =req.body; state.timeutc =nueva fecha (); state.signedby ="orangepi"; console.log (estado); var options ={método:'POST', url:'http:// su-ip-o-nombre-de-dominio / api / iot / myhome / livingroom / micrófono', encabezados:{'cache-control':'no- cache ',' content-type ':' application / json '}, body:state, json:true}; request (opciones, función (error, respuesta, cuerpo) {si (error) arrojar nuevo Error (error); console.log (cuerpo);}); res.send ('Grabación de la intensidad del sonido de la sala de estar');}); // acepta la solicitud POST pirrouter.post ('/ iot / myhome / livingroom / pir', function (req, res) {var state =req.body; state.timeutc =new Date (); state.signedby ="orangepi"; console.log (estado); var options ={método:'POST', url:'http:// tu-ip-o-nombre-de-dominio / api / iot / myhome / livingroom / pir ', encabezados:{' cache-control ':' no-cache ',' content-type ':' application / json '}, body:state, json:true}; solicitud (opciones, función (error, respuesta, cuerpo) {if (error) throw new Error (error); console.log (body);}); res.send ('Se registró el movimiento pir de la sala de estar');}); / / accept POST request distancerouter.post ('/ iot / myhome / livingroom / distance', function (req, res) {var state =req.body; state.timeutc =new Date (); state.signedby ="orangepi"; console.log (estado); var options ={method:'POST', url:'http:// your-ip-or-domain-name / api / iot / myhome / livingroom / distance', headers:{'cache -control ':' no-cache ',' content-type ':' application / json '}, body:state, js on:true}; request (opciones, función (error, respuesta, cuerpo) {si (error) arrojar nuevo Error (error); console.log (cuerpo);}); res.send ('Obstáculo de la sala registrado');}); // acepta la solicitud POST gpsrouter.post ('/ iot / mydevice / location', function (req, res) {var state =req.body; state.timeutc =new Date (); state.signedby ="orangepi"; console.log (state); var options ={method:'POST', url:'http:// your-ip-or-domain-name / api / iot / mydevice / location / gps ', headers:{' cache-control ':' no-cache ',' content-type ':' application / json '}, body:state, json:true}; request (options, function (error, response, body) {if (error) throw new Error (error); console.log (body);}); res.send ('ubicación del dispositivo registrada');}); // acepta la solicitud POST enrutador de humedad .post ('/ iot / myhome / garden / humedad', function (req, res) {var state =req.body; state.timeutc =new Date (); state.signedby ="orangepi"; console.log (state ); var options ={método:'POST', url:'http:// tu-ip-o-nombre-de-dominio / api / iot / myhome / jardín / humedad', encabezados:{'cache-control':' no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Garden moisture level recorded');});// accept POST request gasrouter.post('/iot/myhome/kitchen/gas', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/kitchen/gas', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Gas leak information recorded');});// accept POST request lightrouter.post('/iot/myhome/livingroom/light', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/livingroom/light', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(optio ns, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Light intensity recorded');});// accept POST request livingroomrouter.post('/iot/myhome/livingroom', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/room/livingroom', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Livingroom attributes recorded');});// accept POST request bedroomrouter.post('/iot/myhome/bedroom', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/room/bedroom', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, fu nction (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Bedroom attributes recorded');});// accept PUT request at /userrouter.put('/user', function (req, res) { res.send('Got a PUT request at /user');});// accept DELETE request at /user//router.delete('/user', function (req, res) {// res.send('Got a DELETE request at /user');//});/* GET home page. */router.get('/', function(req, res, next) { res.render('index', { title:'Express' });});module.exports =router;

ThermoStatController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Newtonsoft.Json;using Microsoft.WindowsAzure.Storage;using Microsoft.WindowsAzure.Storage.Auth;using Microsoft.WindowsAzure.Storage.Table;// For more information on enabling MVC for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/livingroom/[Controller]")] public class ThermoStatController :IoTController { // GET:// public IActionResult Index() { return View(); } [HttpPost] public IActionResult Post([FromBody]IotTemperature iotTemperature) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotTemperature.PartitionKey ="thermostat"; iotTemperature.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotTemperature); // Execute the insert operation. table.Execute(insertOperation); return Ok("Temperature data logged to azure cloud.."); } } public class IotTemperature :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string temperature { get; colocar; } public string humidity { get; colocar; }}}} 

PIRController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/livingroom/[Controller]")] public class PIRController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotPIR iotPIR) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotPIR.PartitionKey ="pir"; iotPIR.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotPIR); // Execute the insert operation. table.Execute(insertOperation); return Ok("PIR data logged to azure cloud.."); } } public class IotPIR :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string motionstart { get; colocar; } public string motionend { get; colocar; }}}} 

MoistureController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/garden/[Controller]")] public class MoistureController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotMoisture iotMoisture) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotMoisture.PartitionKey ="moisture"; iotMoisture.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotMoisture); // Execute the insert operation. table.Execute(insertOperation); return Ok("Moisture data logged to azure cloud.."); } } public class IotMoisture :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string moisture { get; colocar; } } }}

LivingRoomController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/room/[controller]")] public class LivingRoomController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotLivingRoom iotLivingRoom) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotLivingRoom.PartitionKey ="livingroom"; iotLivingRoom.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotLivingRoom); // Execute the insert operation. table.Execute(insertOperation); return Ok("Living room attributes logged to azure cloud.."); } } public class IotLivingRoom :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string window { get; colocar; } public string door { get; colocar; } public string ac { get; colocar; } public string temperature { get; colocar; } public string humidity { get; colocar; }}}} 

LightController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/livingroom/[Controller]")] public class LightController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotLight iotLight) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotLight.PartitionKey ="light"; iotLight.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotLight); // Execute the insert operation. table.Execute(insertOperation); return Ok("Light intensity logged to azure cloud.."); } } public class IotLight :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string intensity { get; colocar; } } }}

GPSController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/mydevice/location/[Controller]")] public class GPSController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotGPS iotGPS) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotGPS.PartitionKey ="gps"; iotGPS.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotGPS); // Execute the insert operation. table.Execute(insertOperation); return Ok("GPS data logged to azure cloud.."); } } public class IotGPS :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string lat { get; colocar; } [JsonProperty("long")] public string longitude { get; colocar; }}}} 

GasController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/kitchen/[Controller]")] public class GasController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotGas iotGas) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotGas.PartitionKey ="gas"; iotGas.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotGas); // Execute the insert operation. table.Execute(insertOperation); return Ok("Gas leak information logged to azure cloud.."); } } public class IotGas :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string leak { get; colocar; } } }}

DistanceController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/livingroom/[Controller]")] public class DistanceController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotDistance iotDistance) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotDistance.PartitionKey ="distance"; iotDistance.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotDistance); // Execute the insert operation. table.Execute(insertOperation); return Ok("Obstacle data logged to azure cloud.."); } } public class IotDistance :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string obstacle { get; colocar; }}}} 

BedRoomController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/room/[controller]")] public class BedRoomController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotBedRoom iotBedRoom) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotBedRoom.PartitionKey ="bedroom"; iotBedRoom.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotBedRoom); // Execute the insert operation. table.Execute(insertOperation); return Ok("Bed room attributes logged to azure cloud.."); } } public class IotBedRoom :TableEntity { public string deviceid { get; colocar; } public string timeutc { get; colocar; } public string signedby { get; colocar; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; colocar; } public class Desired { public string window { get; colocar; } public string door { get; colocar; } public string ac { get; colocar; } public string temperature { get; colocar; } public string humidity { get; colocar; }}}} 

Media Tek Smart home - Source code for data logging

Esquemas