快速建置物聯網系統: Azure IoT Suite - Remote Monitoring 簡介及客製化

   1  2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135

 //[設定連線Azure IoT Suite 物件]      private const string DeviceConnectionString = "HostName=hermanIoT15a.azure-devices.net;SharedAccessKeyName=device;SharedAccessKey= [modify to YOUR SHARED ACCESS KEY]";        static string IOTHUB_RUI = "[modify to YOUR IOTHUB RUI]";        DeviceClient _deviceClient = DeviceClient.Create(IOTHUB_RUI, new DeviceAuthenticationWithRegistrySymmetricKey("[DEVICE ID]", "[DEVICE KEY]"), TransportType.Http1); //傳送遙測資訊到Azure IoT Suite 範例        async Task SendEvent(DeviceClient deviceClient, double distance)        {            RemoteMonitorTelemetryData rmtd = new RemoteMonitorTelemetryData();            rmtd.Humidity = distance;            Random random = new Random();            int i = random.Next(15);            rmtd.Temperature = 15 + i; //產生隨機資料            rmtd.ExternalTemperature = 35; //假資料            rmtd.DeviceId = "HermanRP2_001a";            var msgString = JsonConvert.SerializeObject(rmtd);            var msg2 = new Message(Encoding.ASCII.GetBytes(msgString));            await _deviceClient.SendEventAsync(msg2);            Debug.WriteLine("\t{0}> Sending message: {1}, Data: [{2}]", DateTime.Now.ToLocalTime(), 0, msgString);        }        //接收 IoT Suite上傳給裝置的指令        async Task ReceiveCommands(DeviceClient deviceClient)        {            Debug.WriteLine("\nDevice waiting for commands from IoTHub...\n");            Message receivedMessage;            string messageData;            while (true)            {                receivedMessage = await deviceClient.ReceiveAsync();                if (receivedMessage != null)                {                    messageData = Encoding.ASCII.GetString(receivedMessage.GetBytes());                    Debug.WriteLine("\t{0}> Received message: {1}", DateTime.Now.ToLocalTime(), messageData);                    //this.firstText.Text = "Received Command:";                    await deviceClient.CompleteAsync(receivedMessage);                }                await Task.Delay(TimeSpan.FromSeconds(10));            }        }        //設定裝置狀態為啟動        private async void StartDevice()        {            JObject device = new JObject();   // 需修改為實際值            JObject deviceProps = new JObject();            deviceProps.Add("DeviceID", "HermanRP2_001a");            deviceProps.Add("HubEnabledState", 1);            deviceProps.Add("CreatedTime", DateTime.UtcNow);            deviceProps.Add("DeviceState", "normal");            deviceProps.Add("UpdatedTime", null);            deviceProps.Add("Manufacturer", "Raspberry Pi Org");            deviceProps.Add("ModelNumber", "Raspberry Pi 2 B+");            deviceProps.Add("SerialNumber", "A9090");            deviceProps.Add("FirmwareVersion", "10.0586");            deviceProps.Add("Platform", "Windows10 IoT Core");            deviceProps.Add("Processor", "ARM");            deviceProps.Add("Latitude", 35.626897);            deviceProps.Add("Longitude", 139.740729);            device.Add("DeviceProperties", deviceProps);            device.Add("Commands", new JArray());            device.Add("IsSimulatedDevice", 0);            device.Add("ObjectType", "DeviceInfo");            device.Add("Version", "1.0");            JObject command01 = new JObject();            command01.Add("Name", "SetTemperature");            command01.Add("Parameters", null);            JObject command02 = new JObject();            command02.Add("Name", "PingDevice");            command02.Add("Parameters", null);            JObject command03 = new JObject();            command03.Add("Name", "StartTelemetry");            command03.Add("Parameters", null);            JObject command04 = new JObject();            command04.Add("Name", "StopTelemetry");            command04.Add("Parameters", null);            dynamic commands = GetSupportedCommands(device);            commands.Add(command01);            commands.Add(command02);            commands.Add(command03);            commands.Add(command04);            var messageString = JsonConvert.SerializeObject(device);            var message = new Message(Encoding.ASCII.GetBytes(messageString));            await _deviceClient.SendEventAsync(message);            Debug.WriteLine("Send Start Device Info: " + messageString);        }        //設定裝置接受那些指令        public static dynamic GetSupportedCommands(dynamic device)        {            if (device == null)            {                throw new ArgumentNullException("device");            }            dynamic commands = device.Commands;            if (commands == null)            {                commands = new JArray();                device.Commands = commands;            }            return commands;        }  // 遙測資訊格式    public class RemoteMonitorTelemetryData    {        public string DeviceId { get; set; }        public double Temperature { get; set; }        public double Humidity { get; set; }        public double? ExternalTemperature { get; set; }    }