Air Quality Monitoring Delivery

 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

#!/usr/bin/python
# -*- coding: UTF-8 -*-

# Requires pyserial. Install via:
# pip install pyserial

from __future__ import print_function
from serial import Serial, EIGHTBITS, STOPBITS_ONE, PARITY_NONE
import time, struct
import string 
import pynmea2
import json
import uuid

from azure.iot.device import IoTHubDeviceClient, Message

port = "/dev/ttyUSB0" # Set this to your serial port.
baudrate = 9600

gpsPort="/dev/ttyAMA0"
gpsBaudrate= 9600


device_client= IoTHubDeviceClient.create_from_connection_string("YOUR_IOTHUB_CONNECTION_STRING")
 
device_client.connect()

MSG_PAYLOAD= '{{"pm_25": {pm_25},"pm_10": {pm_10},"lat": {lat},"lng": {lng}}}'
# Prepare serial connection.
ser = Serial(port, baudrate=baudrate, bytesize=EIGHTBITS, parity=PARITY_NONE, stopbits=STOPBITS_ONE)
ser.flushInput()

HEADER_BYTE = b"\xAA"
COMMANDER_BYTE = b"\xC0"
TAIL_BYTE = b"\xAB"

byte, previousbyte = b"\x00", b"\x00"

while True:
    previousbyte = byte
    byte = ser.read(size=1)
    #print(byte)
    
    # We got a valid packet header.
    if previousbyte == HEADER_BYTE and byte == COMMANDER_BYTE:
        packet = ser.read(size=8) # Read 8 more bytes
        #print(packet)
        
        # Decode the packet - little endian, 2 shorts for pm2.5 and pm10, 2 ID bytes, checksum.
        readings = struct.unpack('<HHcccc', packet)
        
        # Measurements.
        pm_25 = readings[0]/10.0
        pm_10 = readings[1]/10.0

        #gps
        gpsSer= Serial(gpsPort,9600,timeout=0.5)
        dataout= pynmea2.NMEAStreamReader()
        
        newdata= gpsSer.readline().decode('utf-8',errors='ignore')
        lat=0
        lng=0
        print(newdata)
        # ID
        id = packet[4:6]
        
        # Prepare checksums.
        checksum = readings[4][0]
        calculated_checksum = sum(packet[:6]) & 0xFF
        checksum_verified = (calculated_checksum == checksum)
        
        # Message tail.
        tail = readings[5]
        if tail == TAIL_BYTE and checksum_verified:
            #print("PM 2.5:", pm_25, "μg/m^3  PM 10:", pm_10, "μg/m^3")
            if newdata[0:6] == "$GPRMC":
                newmsg= pynmea2.parse(newdata)
                lat= newmsg.latitude
                lng=newmsg.longitude
                payload= MSG_PAYLOAD.format(pm_25=pm_25, pm_10=pm_10, lat=lat, lng=lng)
                msg= Message(payload)
                msg.message_id= uuid.uuid4()
                msg.content_encoding= "utf-8"
                msg.custom_properties["deviceId"]= "ola"
                msg.content_type= "application/json"
                print("sending message: {}".format(msg))
                device_client.send_message(msg)
                time.sleep(2)
                print("PM 2.5:", pm_25, "µg/m³  PM 10:", pm_10, "µg/m³  ID:", bytes(id).hex())
            
            

 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

 public class TelemetryTrigger
    {
        private readonly IConfiguration _configuration;
        public TelemetryTrigger(IConfiguration configuration)
        {
            _configuration = configuration;
        }

        [FunctionName("TelemetryToPubSub")]
        public async Task TelemetryToPubSub([CosmosDBTrigger(
            databaseName: "airqualitymonitoringdelivery",
            collectionName: "telemetry",
            ConnectionStringSetting = "cosmosconnection",
            LeaseCollectionName = "leases",
            CreateLeaseCollectionIfNotExists = true)]IReadOnlyList<Document> input,
            ILogger log)
        {
            if (input != null && input.Count > 0)
            {
                log.LogInformation("Documents modified " + input.Count);
                log.LogInformation("First document Id " + input[0].Id);

                var serviceClient = new WebPubSubServiceClient(_configuration["WebPubSubConnectionString"], _configuration["HubName"]);
                await serviceClient.SendToAllAsync(JsonConvert.SerializeObject(input));
            }
        }
    }

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

public class Connection
    {
        private readonly ILogger<Connection> _logger;

        public Connection(ILogger<Connection> log)
        {
            _logger = log;
        }

        [FunctionName("GetConnectionUrl")]
        [OpenApiOperation(operationId: "Run", tags: new[] { "name" })]
        [OpenApiParameter(name: "name", In = ParameterLocation.Query, Required = true, Type = typeof(string), Description = "The **Name** parameter")]
        [OpenApiResponseWithBody(statusCode: HttpStatusCode.OK, contentType: "text/plain", bodyType: typeof(string), Description = "The OK response")]
        public async Task<WebPubSubConnection> GetConnectionUrl(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = "negotiate")] HttpRequest req, [WebPubSubConnection(Hub = "AQMD", UserId = "{query.userid}")] WebPubSubConnection connection)
        {
            Console.WriteLine("login");
            return await Task.FromResult(connection);
        }
    }

 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

<!DOCTYPE html>
<html>
<head>
    <title>AQMD</title>

    <meta charset="utf-8" />
    <meta http-equiv="x-ua-compatible" content="IE=Edge" />
    <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no" />
    <!-- Add references to the Azure Maps Map control JavaScript and CSS files. -->
    <link rel="stylesheet" href="https://atlas.microsoft.com/sdk/javascript/mapcontrol/2/atlas.min.css" type="text/css" />
    <script src="https://atlas.microsoft.com/sdk/javascript/mapcontrol/2/atlas.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/@aspnet/[email protected]/dist/browser/signalr.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/[email protected]/dist/axios.min.js"></script>

    <script type='text/javascript'>

    function GetConnectionInfo() {
    return axios.get('https://func-raspberrypi.azurewebsites.net/api/negotiate?userid=test')
        .then(function (response) {
            return response.data
        }).catch(console.error)
}
GetConnectionInfo().then(info  =>{
        info.accessToken = info.accessToken || info.accessKey;
        info.url = info.url || info.endpoint;
        const options = {
            accessTokenFactory: () => info.accessToken
        };
        const connection = new WebSocket(info.url);

        connection.onopen = () => console.log('connected');
        connection.onmessage= (event) => newMessage(event);
        connection.onclose= () => console.log('disconnected');
        
    });

    let counter = 0;
    let datasource;
    let aqmd = [];
    function newMessage(message) {
        var parseData= JSON.parse(message.data);
        console.log(parseData);
        var newAqmdPin = new atlas.Shape(new atlas.data.Point([parseData[0].Body.lng, parseData[0].Body.lat]), parseData[0].id);
        newAqmdPin.addProperty('pm_25', parseData[0].Body["pm_25"]);
        newAqmdPin.addProperty('pm_10', parseData[0].Body["pm_10"]);
        aqmd[parseData[0].id] = newAqmdPin;
        datasource.setShapes(Object.values(aqmd));
    }

    function generateUser() {
            return 'User ' + Math.random().toString(36).replace(/[^a-z]+/g, '').substr(0, 5);
        }

    var map;
    function GetMap() {
            //Initialize a map instance.
            map = new atlas.Map('myMap', {
                center:  [80.1683535,13.136500833333333],
                style: 'light',
                zoom: 8,
                //Add your Azure Maps subscription key to the map SDK. Get an Azure Maps key at https://azure.com/maps
                authOptions: {
                    authType: 'subscriptionKey',
                    subscriptionKey: 'YOUR_SUBSCRIPTION_KEY'
                }
            });
            //Wait until the map resources are ready.
            map.events.add('ready', function () {
                datasource = new atlas.source.DataSource();
                map.sources.add(datasource);
                //Create a symbol layer using the data source and add it to the map
                map.layers.add(
                    new atlas.layer.SymbolLayer(datasource, null, {
                        iconOptions: {
                        ignorePlacement: true,
                        allowOverlap: true,
                        size:0.5
            },
                        textOptions: {
                            textField: ['concat', ['to-string', ['get', 'pm_25']], ',', ['get', 'pm_10']],
                            color: 'orange'
                        }
                        

                    })
                );  
            });
        }
    </script>
</head>
<body onload="GetMap()">
    <div id="myMap" style="position:relative;width:100%;min-width:290px;height:600px;"></div>
</body>
</html>