Send your data to Azure SQL

Get your KPN Things device data in a Azure SQL database. This QuickStart will help you set up a KPN Things flow towards an Azure Eventhub. The Azure Eventhub is used to ingest data in to the Azure platform. An Azure Streamanalytics job will process incoming data. The data will be stored in an Azure SQL database. For this QuickStart you’ll need a KPN Things account with an active device (or download the device simulator app) and an active Azure subscription.

In this QuickStart you’ll learn how to:

• Create and configure the necessary Azure resources

  • Create and configure Azure Eventhub

  • Create an Azure SQL database with appropriate data tables

  • Create and configure a Stream Analytics job

• Setup a KPN Things Flow with Azure Eventhub destination

Prerequisites

• KPN Things Account with active device

  • If you don’t have an KPN Things account create a free developer account.

• Azure subscription

  • If you don't have an Azure subscription, create a free account.

Step 1: Setting up the Azure environment

In this section you’ll be guided through the creation and configuration of an Azure event hub, a stream analytics job and an Azure SQL database. It’s advised to create a new resource group in which to bundle these newly created resources.

Creating and configuring Azure event hub

The Azure EventHub is used for the ingestion of data. Don't have an Azure Event Hub yet? Head on over to the Microsoft documentation to learn to create an Azure Event Hub:

Azure Quickstart - Create an event hub using the Azure portal - Azure Event Hubsdocsmsft

From this point, when following the link, you’ve created everything to ingest data to Azure. You have created a resource group, an Event Hubs namespace, and an event hub.

Create an Azure SQL database with appropriate data tables

Now we have prepared the input data by creating the Event Hub. We can now proceed to the creation of the Azure SQL database for the data output. Don't have an Azure SQL database yet? Head on over to the Microsoft documentation to learn how to create an Azure SQL database:

At creation, remember to select the resource group created earlier. This way all resources for this quick start will be grouped together. Furthermore, make sure to write down the ‘Server admin login’ and ‘Password’. Under additional settings don’t select sample as we want to create our own data table later on.

Create a single database - Azure SQL Databasedocsmsft

Query the database

When the creation of the database is complete we can create the necessary table. Go to the query editor in the Azure portal as described in the documentation link:

Create a single database - Azure SQL Databasedocsmsft

In the query window run the query underneath to create a new data table in the database:

CREATE TABLE [dbo].[eventhub](
  [Id] [int] IDENTITY(1,1) NOT NULL,
  [EventProcessedUtcTime] [datetime] NULL, 
  [bn] nvarchar NULL, 
  [bt] [float] NULL, 
  [EventEnqueuedUtcTime] [datetime] NULL, 
  [n] nvarchar NULL, 
  [u] nvarchar NULL, 
  [v] [numeric](18, 2) NULL, 
  [vs] nvarchar NULL, 
  [PartitionId] datetime2 NULL, 
  PRIMARY KEY CLUSTERED
  ( 
    [Id] ASC 
  )WITH (STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF) ON [PRIMARY]
) ON [PRIMARY] 
GO

CREATE INDEX eventhubbn 
ON eventhub (bn) 
GO

CREATE INDEX eventhubbt 
ON eventhub (bt) 
GO

When completed a new data table called eventhub will be created. Additionally, two indexes will be created to enable quick searches on ‘bn’ and ‘bt’. These columns will hold the KPN Things device identifier and measurement timestamp. The newly created data table will be visible in the left view under tables.

At this point you’ve created the data input and the data output by leveraging an Event Hub and an Azure SQL database. In the next step we’ll set up the data stream from input to output by using Azure Streamanalytics.

Create and configure a Stream Analytics job

Now we have prepared the input data by creating the Event Hub and the data output by creating an Azure SQL data store. Now let’s set up Streamanalytics to tie it all together.

The following Microsoft quickstart will guide you through the creation of an streamanalytics job. The entire article describes the usage of an iothub for input data and blob storage for output. Remember in this quickstart we will be using Eventhub for input and Azure SQL database as output.

At ‘Configure job input’ select Event Hub and point to the Eventhub created earlier. Use ‘eventhubinput’ as alias.

At ‘Configure job output’ select SQL database and point to the Azure SQL database created earlier. Set the database table to ‘eventhub’ to match the table created during the previous step. Use ‘sqloutput’ as alias.

At ‘Define the transformation query’ select Query and update with the query underneath. Make sure you are using the input and output aliases as created under input and output

--Saving the measurements to SQL
SELECT
    CASE
      WHEN bn IS NULL THEN  LAG(bn) OVER (PARTITION BY EventEnqueuedUtcTime LIMIT DURATION(second, 1)WHEN bn IS NOT NULL)
      ELSE bn
    END as bn,
    CASE
      WHEN bt IS NULL THEN  LAG(bt) OVER (PARTITION BY EventEnqueuedUtcTime LIMIT DURATION(second, 1)WHEN bt IS NOT NULL)
      ELSE bt
    END as bt,
    EventProcessedUtcTime,
    EventEnqueuedUtcTime,
    n,
    u,
    v,
    vs,
    PartitionId
INTO
    [sqloutput]  
FROM 
    [eventhubinput]

Quickstart - Create a Stream Analytics job by using the Azure portaldocsmsft

Now Save your input and start the Stream Analytics job.

At this point you’ve created a data ingestion point (Event Hub) a streaming data processor (Stream analytics job) and data storage (Azure SQL database) . In the next step we’ll connect KPN Things to Azure!

Step 2: Setup a KPN Things Flow with Azure Event Hub destination

Let’s put things together! Now everything is set up in Azure all we need to do is setup a data flow in KPN Things. This Flow will send device data towards an Azure Event Hub destination.

• Go to KPN Things and add a flow and give it a name and description

• Link new or existing device(s)

• Now go back to the flow and set up the data processing by enabling the decoders for the selected device

• Add a destination for the flow. Select ‘Create new Destination’. Fill in all necessary details related to the Azure event hub created in Step 1. Don’t know where to find all the required parameters? Follow the instructions below:

When all parameters are set the destination should be active. You should now have a working KPN Things Flow towards Azure Event hub.

Congratulations!

You’ve created your first flow towards Azure. All Data produced by the devices in the flow will now be sent to Azure, get processed by the Stream Analytics Job and will be stored in the Azure SQL database.