風速計の IoT Edge デバイス化 ②

using System;
using Windows.Devices.Gpio;
using Microsoft.Azure.Devices.Client;
using Newtonsoft.Json;
using System.Text;

namespace Anemometer
{
    public sealed partial class MainPage : Page
    {
        // Azure IoT HubのIDレジストリで作成したもの入力
        static DeviceClient deviceClient;
        static string iotHubUri = "{iot hub hostname}";
        static string deviceKey = "{device key}";

        static DeviceClient deviceClient = DeviceClient.Create(iotHubUri,new DeviceAuthenticationWithRegistrySymmetricKey("myFirstDevice",deviceKey), Microsoft.Azure.Devices.Client.TransportType.Http1);

        private const int PULSEIN_PIN = 13; // 33pin GPIO13
        private GpioPin pin;
        public MainPage()
        {
            this.InitializeComponent();

            PulseCount();    // パルス数のカウント
        }

        // パルス数のカウント
        private void PulseCount()
        {
            int PulseCnt = 0;
            float Velocity;
            long Now, StartTime, DiffTime;
            var gpio = GpioController.GetDefault();
            if (gpio == null)
            {
                pin = null;
                return;
            }

            pin = gpio.OpenPin(PULSEIN_PIN);                     // 入力ピンへセット
            pin.SetDriveMode(GpioPinDriveMode.Input);             // inputにする。
            var sw = new System.Diagnostics.Stopwatch();             // ストップウォッチ
            do
            {
                sw.Start();                                         // タイマースタート
                StartTime = sw.ElapsedMilliseconds;
                do
                {
                    Now = sw.ElapsedMilliseconds;
                    DiffTime = Now - StartTime;
                    if (DiffTime >= 1000)                           // 1sec周期
                    {
                        sw.Reset();                                 // ストップウォッチリセット
                        break;                                     // 測定終了
                    }
                    if (pin.Read() == GpioPinValue.High) {  　　　　 // パルスhigh検出
                        for (; ; )
                        {
                            if (pin.Read() == GpioPinValue.Low)     // パルスlow検出
                            {
                                PulseCnt++;                       // パルス数カウントアップ
                                break;                             // 1pulse検出済みとして終了
                            }
                        }
                    }
                } while (true);
                if (PulseCnt != 0) {
                    Velocity = PulseCnt*0.064f*10f;                  // 0.064は定数、Azure側の処理の入力に合わせて10倍
                }
                else {
                    Velocity = 0;                                   // 風速0m/s
                }
                SendDeviceToCloudMessagesAsync((int)Velocity);     // データの送信()
                PulseCnt = 0;                                      // パルス数のクリア
            } while (true);
        }

        private async void SendDeviceToCloudMessagesAsync(int iVelocity)
        {
            var SendData = new
            {
                DataTimeStamp = DateTime.Now,
                Velocity = iVelocity,                                // 風速データ
	    };
            var messageString = JsonConvert.SerializeObject(SendData);
            var message = new Message(Encoding.UTF8.GetBytes(messageString));
            await deviceClient.SendEventAsync(message);
        }
    }
}