IoT Ultimate at DotNet User Group in Frankfurt

private async Task readCommand()
{
   try
   {
    var cmdMsg =
    await m_QueueClient.Receive(ReceiveMode.ReceiveAndDelete);
    if (cmdMsg == null) return;

    if (cmdMsg.Properties.ContainsKey("Command"))
    {
       string cmd = cmdMsg.Properties["Command"] as string;

       m_GpioStatus.Text =
       String.Format("Received command '{0}'", cmd);

        if (m_Pin27 != null && m_Pin22 != null)
        {
          if (cmd.ToLower() == "on")
          {
             m_Pin27.Write(GpioPinValue.High);
             m_Pin22.Write(GpioPinValue.High);
          }
          else
          {
             m_Pin27.Write(GpioPinValue.Low);
             m_Pin22.Write(GpioPinValue.Low);
           }
        }
    }
    else
        m_GpioStatus.Text = "Unknown command received!";
    }
    catch (Exception ex)
            {

            }
        }

  $("#btnSend").click(function () {
 
     var msgBody = { "message": txtMsg.value, "id": 1234 };
     var props = [{ 'Name': 'Command', 'Value':     
     txtMsg.value },    ]

     var msg = new BrokeredMessage(msgBody, props);

      
     queueClient.sendMessage(msg, function (messagingResult) {
                    $("#result").html(messagingResult.result);
                }, "application/json");
    });

 public async Task Run()
 {
            m_Recognizer = new GestureRecognizer();
            m_Recognizer.OnGesture += recognizer_OnGesture;
            m_Recognizer.RegisterRecognizers(new
            List<IRecognizer>()
            {
              new HandDownRecognizer(),
              new HandUpRecognizer   () });
           

            m_BandClient = await m_Connector.GetClient();

              
         m_BandClient.SensorManager.Accelerometer.ReadingChanged 
         += Accelerometer_ReadingChanged;
                
     m_BandClient.SensorManager.Accelerometer.ReportingInterval =
         TimeSpan.FromMilliseconds(128);

            await        m_BandClient.SensorManager.
            Accelerometer.StartReadingsAsync(
            new CancellationToken());

}

This code shows wow to send data to Azure Event Hub:

   public async Task WriteToStream(dynamic sensorEvent)
        {
            try
            {
                var stringified =
                JsonConvert.SerializeObject(sensorEvent);

                var bytes = Encoding.UTF8.GetBytes(stringified);

                using (MemoryStream stream =
                new MemoryStream(bytes))
                {
                    stream.Flush();
                    var message =
                    new ServiceBus.OpenSdk.Message(stream);

                    await m_EventHubClient.Send(message);
                }              
            }
            catch (Exception ex)
            {
                // rootPage.NotifyUserFileNotExist();
            }
        }

WITH XMoves AS
(
 SELECT
 Count(*) as SAMPLES, 
  DateAdd(second,-2,System.TimeStamp) as WinStartTime,
   system.TimeStamp as WinEndTime,
   deviceId,
   (MAX(x) - MIN(x)) as deltaX,
   (MAX(y) - MIN(y)) as deltaY,
   (MAX(z) - MIN(z)) as deltaZ
 FROM eventstream
 WHERE  sensor = 'Accelerometer' 
 GROUP BY deviceId, TumblingWindow(second, 2)
)
Select * INTO acceleratoralertqueue
from XMoves
WHERE deltaX  > 0.25

Select * INTO charts1
from eventstream
WHERE  sensor = 'Accelerometer' 

Select * INTO chartHR
from eventstream
WHERE sensor = 'HeartRate'