nordvpn
System Mechanic® Ultimate Defense™
Coursera Plus

Hot Path Analytics with CosmosDB and Azure Stream Analytics

The Internet of Things (IoT) has opened up a new, virtually inexhaustible source of technical innovations, which are equally valuable for a broad variety of industries. Applying smart connected devices, sensors, and gateways to control each part of the production process, manufacturing, and infrastructure companies are dramatically increasing their operational efficiency. At the same time, the consumer tech market has exploded with an abundance of smart products and spin-off cloud services that they brought to life. In this article, we are going to look at one of the IoT use cases on how to perform Hot Path Analytics with CosmosDB and Azure Stream Analytics.

According to lambda architecture, there are two paths for data to flow in the analytics pipeline

Image – lambda architecture describing various flows

  • A “hot” path where latency-sensitive data, results need to be ready in seconds or less and it flows for rapid consumption by analytics clients.
  • A “cold” path where all data goes and is processed in batches that can tolerate greater latencies until results are ready.

Why Azure Cosmos DB?

Azure Cosmos DB is Microsoft’s globally distributed, multi-model database. With the click of a button, it enables you to elastically and independently scale throughput and storage across any number of Azure’s geographic regions. It offers throughput, latency, availability, and consistency guarantees with comprehensive service level agreements (SLAs), something no other database service can offer.

You can Try Azure Cosmos DB for free without an Azure subscription, free of charge and commitments.Azure Cosmos DB

Image – Azure Cosmos DBAs a globally distributed database service, Azure Cosmos DB provides the following capabilities to help you build scalable, highly responsive applications:

Subscribe to Emails

More than 100,000 subscribers across the world trust & read Upnxtblog articles. Subscribe to emails updates!
* indicates required

Key Capabilities

  • Turnkey global distribution – You can distribute your data to any number of Azure regions, with the click of a button. This enables you to put your data where your users are, ensuring the lowest possible latency to your customers.
  • Multiple data models and popular APIs for accessing and querying data – APIs for the following data models are supported with SDKs available in multiple languages:
    • DocumentDB API: A schema-less JSON database engine with SQL querying capabilities.
    • MongoDB API: A MongoDB database service built on top of Cosmos DB.
    • Table API: A key-value database service built to provide premium capabilities for Azure Table storage applications.
    • Graph (Gremlin) API: A graph database service built following the Apache TinkerPop specification.
    • Cassandra API: A key/value store built on the Apache Cassandra implementation.
  • Elastically scale throughput and storage on demand, worldwide 
  • Support for highly responsive and mission-critical applications
  • “always on” availability
  • No database schema/index management

In the next section, we are going to look at how to

  1. Create a device
  2. Connecting the Pi Simulator to IoT Hub
  3. Send telemetry data to Azure
  4. How to setup Cosmos DB
  5. Streaming analytics with windowing techniques and finally
  6. Store Time Series Data in CosmosDB

#1.Create a device

We will be using Azure IoT Hub service to connect the device simulator and start sending data. Azure IoT Hub is a fully managed service that enables reliable and secure bidirectional communications between millions of IoT devices and a solution back end.

With IoT Hub you can:

Generic Category (English)728x90
  1. Establish bi-directional communication with billions of IoT devices
  2. Authenticate per device for security-enhanced IoT solutions
  3. Register devices at scale with IoT Hub Device Provisioning Service
  4. Manage your IoT devices at scale with device management
  5. Extend the power of the cloud to your edge device

To start, click on Create a resource and click on the Internet of Things.

Image – Create Resource

Recover over 700 unique file formats. Fully recover documents, emails, photos, videos, audio files and more. Supports 8 different data lost scenarios: deleted files recovery, recycle bin recovery, formatted drive recovery, lost partition recovery, externa

Create an IoT Hub to connect your real device or simulator.

Image – Create IoT Hub

Use an existing resource group or create a new one. In the Name field, enter a unique name for your IoT hub. The name of your IoT Hub must be unique across all IoT hubs.

Best VPN Service (English Banners)

Image – Select Tier

In the Tier filed, select S1 tier. You can choose from several tiers depending on how many features you want and how many messages you send through your solution per day.

For details about the tier options, check out Choosing the right IoT Hub tier.

Image – IoT Hub Summary details

Now that IoT Hub is created, we would be connecting Devices in the next steps.

#2.Connect the simulator to IoT Hub

Go To your IoT Hub in the portal and click on IoT Devices, Click on+ Add and enter a Device and click Save.

Image – Create Device on the IoT Hub

Once the device is created, click on the device and copy the Primary Connection String.

Image – Copy Primary Connection string

Go to PI Simulator and replace the connection string with the Primary Connection String copied in the previous step.

Image – Replace the connection string with the primary key connection string

Click Run and start sending messages. LED will start blinking, Messages will start flowing into IoT Hub that we created in the previous step.

#3.Create Cosmos DB account

To start with, click on Create a resource and click on the Azure Cosmos DB.

Image – Create Cosmos DB account

Follow the wizard to create a new database, for this tutorial, I have chosen SQL API which is schema-less JSON database engine with rich SQL querying capabilities. There are also other APIs available that might be suitable for your scenario.

Packt US

Image – Create Cosmos DB account

#3.Create Stream Analytics Job

Azure Stream Analytics is a managed event-processing engine set up real-time analytic computations on streaming data. The data can come from devices, sensors, web sites, social media feeds, applications, infrastructure systems, and more.

From the Azure Portal, click on Create a resource and on the Stream Analytics Job.

Image – Create Stream Analytics Job

Stream Analytics job cab be created to run on the cloud as well as on the Edge. But for this tutorial, we are going to create it on the cloud.

New SSD Cloud Server Packages Now Available from $2.50/Month on Alibaba Cloud

Our next step is to add input to job:

Image – Add input to Stream Analytics Job

Add Cosmos DB as Output for Streaming Job (from the Outputs option on the left pane)

Image – Add output to Steam Analytics Job

You will have to Authorize Cosmos DB connection for Stream analytics to have access to be able to write to Cosmos DB. Once Cosmos DB output is added, we have to add Query and Start the job.

TextNow Download

Image – Add Query,start the Job

Edit Query for Streaming Job:

Image – Query for Streaming Job

Everything is ready, start the stream job which will read data from IoTHub and store data in Cosmos DB.

#4.Explore Streaming Data

Use Cosmos DB data explorer to view data being streamed from IoTHub to Cosmos DB.

Image – Cosmos DB data explorer to view data

From here it flows for rapid consumption by analytics clients.

Congrats! In this article, we have learned how to how to perform Hot Path Analytics with CosmosDB and Azure Stream Analytics.

Like this post? Don’t forget to share it!

Additional Resources :

Summary
Hot Path Analytics with CosmosDB and Azure Stream Analytics
Article Name
Hot Path Analytics with CosmosDB and Azure Stream Analytics
Description
In this article, we are going to look at one of the IoT use cases on how to perform Hot Path Analytics with CosmosDB and Azure Stream Analytics.
Author
Publisher Name
Upnxtblog
Publisher Logo
%d bloggers like this: