Team Quovantis: Ipinder Singh Suri

Published October 1, 2015 © GPL3+

Sick-urity

Security and monitoring through Microsoft Azure

IntermediateWork in progress1,202

Things used in this project

Hardware components

Raspberry Pi 2 Model B

PIR Motion Sensor (generic)

LED (generic)

Breadboard (generic)

Software apps and online services

Microsoft Windows 10 IoT Core

Story

This project aims to create a cheap and robust security system which can be configured through the web and can provide detailed reports of the activities.

Security is a great concern in today's world and security of home is of utmost importance. We can utilize the power and convenience of Raspberry Pi and cheap PIR Motion sensor to create an exhaustive security system which is configurable through the web and detailed reporting is available through azure.

The system works as follows:

Whenever the Pi senses any movement it sends events to Azure Cloud Service along with the picture of the scene(optional). The cloud service processes these events and decides whether notification is to be sent to the owner or not (which is configurable) and forwards the data to Microsoft Service Bus Event Hub further forwards it to Microsoft Power BI for reporting. The owner can turn on or turn off notification through the convenience web browser.

The construction is as follows:

Firstly, construct a simple motion detection circuit as shown in the attached picture.

This is a simple circuit in which as soon as it detects some motion a led is lit.

Write the code which will send these motion event details to the cloud service. If any network camera is available we can use that to capture the image and we can send that along with the event.

Create Azure cloud service which will have two end points. One on which the camera would be sending the data, and the other one for configuring the notification service.

The notification service end point would be accepting a parameter which would enable or disable the notification system. The other end point would receive the data and based on notification status send email to the user about the motion sensed. It also forwards the event to Microsoft Service Bus Event Hub.

There is a stream analytics job created to consume the data and send it to Microsoft Power BI.

Comprehensive reports can be generated through Power BI on the data. It would show us details like the peak time for movement and the times whenever motion was sensed in the late hours of the day or whenever the notification system was turned on.

Code

using System;
using System.Diagnostics;
using System.Net.Http;
using System.Runtime.InteropServices.WindowsRuntime;
using System.Text;
using System.Threading.Tasks;
using Windows.Devices.Gpio;
using Windows.Storage.Streams;
using Windows.UI.Xaml.Controls;
using Windows.UI.Xaml.Media;
using Windows.UI.Xaml.Media.Imaging;

namespace PIRSensorApp
{
    /// <summary>
    /// An empty page that can be used on its own or navigated to within a Frame.
    /// </summary>
    public sealed partial class MainPage : Page
    {
        private int counter = 0;

        private const int LED_PIN = 5;
        private GpioPin _pinLed;

        private const int DISTANCE_PIN = 6;
        private GpioPin _pinDistance;

        private GpioPin testPin;
        private const int TEST_PIN = 26;
        private bool light = false;

        private DateTime lastMotionTime;
        public MainPage()
        {
            this.InitializeComponent();
            
            Initialize();
            
            Unloaded += MainPage_Unloaded;
        }

        private void Initialize()
        {
            var gpio = GpioController.GetDefault();

            MyText.Text = "START";
            lastMotionTime = DateTime.Now;


            testPin = gpio.OpenPin(TEST_PIN);
            testPin.Write((light ? GpioPinValue.High : GpioPinValue.Low));
            testPin.SetDriveMode(GpioPinDriveMode.Output);

            _pinLed = gpio.OpenPin(LED_PIN);
            _pinLed.Write(GpioPinValue.High);
            _pinLed.SetDriveMode(GpioPinDriveMode.Output);

            _pinDistance = gpio.OpenPin(DISTANCE_PIN);
            _pinDistance.SetDriveMode(GpioPinDriveMode.Input);
            _pinDistance.ValueChanged += EventHandler;

        }

        TimeSpan timeDiff;
        private async void EventHandler(GpioPin sender, GpioPinValueChangedEventArgs args)
        {
            var isOn = args.Edge == GpioPinEdge.FallingEdge;
            if (isOn)
            {
                Debug.WriteLine("Ready ");
            }
            else
            {
                CloudService.PushData(DateTime.Now.ToString(), null, "Camera1");
                Debug.WriteLine("Motion Detected " + counter++);
                timeDiff = DateTime.Now - lastMotionTime;
                if (timeDiff.Seconds >= 2 || counter == 0)
                {
                    light = (light ? false : true);
                }
                lastMotionTime = DateTime.Now;
                testPin.Write((light ? GpioPinValue.High : GpioPinValue.Low));
                await Dispatcher.RunAsync(Windows.UI.Core.CoreDispatcherPriority.Normal, () =>
                {
                    MyText.Text = "Motion Detected " + counter;
                });
                takeImage();
            }
        }


       


        private async void takeImage()
        {
            try
            {
                var url = "http://10.0.0.12/image.jpg";

                HttpClient client = new HttpClient();
                var byteArray = Encoding.UTF8.GetBytes("admin:");
                client.DefaultRequestHeaders.Authorization =
                    new System.Net.Http.Headers.AuthenticationHeaderValue("Basic",
                    Convert.ToBase64String(byteArray));

                var result = await client.GetByteArrayAsync(url);
                ByteToImage(result);
            }
            catch (Exception ex)
            {
                var message = ex.Message;
            }
        }

        public async void ByteToImage(byte[] imageData)
        {

            InMemoryRandomAccessStream randomAccessStream = new InMemoryRandomAccessStream();
            var op = randomAccessStream.WriteAsync(imageData.AsBuffer());
            op.Completed = (info, status) =>
            {

                randomAccessStream.Seek(0);

                Dispatcher.RunAsync(Windows.UI.Core.CoreDispatcherPriority.Normal, () =>
                {
                    BitmapImage biImg = new BitmapImage();
                    biImg.SetSource(randomAccessStream);

                    ImageSource imgSrc = biImg as ImageSource;
                    currentImage.Source = imgSrc;
                });
            };
        }

        private void MainPage_Unloaded(object sender, object args)
        {
            // Cleanup
            _pinLed.Dispose();
            _pinDistance.Dispose();
        }

    }
}

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;

namespace PIRSensorApp
{
    public static class CloudService
    {
        public static void PushData(string dateTime, byte[] image, string cameraId)
        {
            
            // Create a new webrequest to the mentioned URL.   
            WebRequest webRequest = WebRequest.Create("http://www.MYAZURECLOUDSERVICE.com");
            webRequest.Method = "POST";

            var headerCollection = new WebHeaderCollection();

            headerCollection["dateTime"] = dateTime;
            headerCollection["cameraId"] = cameraId;

            webRequest.Headers = headerCollection;

            // Create a new instance of the RequestState.
            // The 'WebRequest' object is associated to the 'RequestState' object.
            // Start the Asynchronous call for response.
            IAsyncResult asyncResult = (IAsyncResult)webRequest.BeginGetResponse(new AsyncCallback(RespCallback), null);
            // Release the WebResponse resource.

        }

        private static void RespCallback(IAsyncResult asynchronousResult)
        {
            //do nothing. We dont want to perform any action with this.
        }
        
        
    }
}

Credits

Ipinder Singh Suri

1 project • 0 followers

Sick-urity

Things used in this project

Hardware components

Software apps and online services

Story

Schematics

Circuit picture

Code

MainPage.xaml

Code for sending events to cloud service

Credits

Ipinder Singh Suri

Comments

Embed the widget on your own site

Sick-urity

Sick-urity

Things used in this project

Hardware components

Software apps and online services

Story

Schematics

Circuit picture

Code

MainPage.xaml

Code for sending events to cloud service

Credits

Ipinder Singh Suri

Comments

Related channels and tags