Note

Access to this page requires authorization. You can try signing in or .

Access to this page requires authorization. You can try .

Tutorial: Ingest and query monitoring data in Azure Data Explorer

This tutorial shows you how to ingest data from diagnostic and activity logs to an Azure Data Explorer cluster without writing code. By using this simple ingestion method, you can quickly start querying Azure Data Explorer for data analysis.

In this tutorial, you learn how to:

  • Create tables and ingestion mapping in an Azure Data Explorer database.
  • Format the ingested data by using an update policy.
  • Create an event hub and connect it to Azure Data Explorer.
  • Stream data to an event hub from Azure Monitor diagnostic metrics and logs and activity logs.
  • Query the ingested data by using Azure Data Explorer.

Note

Create all resources in the same Azure location or region.

Prerequisites

Azure Monitor data provider: diagnostic metrics and logs and activity logs

View and understand the data provided by the Azure Monitor diagnostic metrics and logs and activity logs in the following sections. You create an ingestion pipeline based on these data schemas. Each event in a log has an array of records. You split this array of records later in the tutorial.

Examples of diagnostic metrics and logs and activity logs

An Azure service emits Azure diagnostic metrics and logs and activity logs. These logs provide data about the operation of that service.

Diagnostic metrics example

Diagnostic metrics aggregate data with a time grain of one minute. The following example shows an Azure Data Explorer metric-event schema on query duration:

{
 "records": [
 {
 "count": 14,
 "total": 0,
 "minimum": 0,
 "maximum": 0,
 "average": 0,
 "resourceId": "/SUBSCRIPTIONS/<subscriptionID>/RESOURCEGROUPS/<resource-group>/PROVIDERS/MICROSOFT.KUSTO/CLUSTERS/<cluster-name>",
 "time": "2018-12-20T17:00:00.0000000Z",
 "metricName": "QueryDuration",
 "timeGrain": "PT1M"
 },
 {
 "count": 12,
 "total": 0,
 "minimum": 0,
 "maximum": 0,
 "average": 0,
 "resourceId": "/SUBSCRIPTIONS/<subscriptionID>/RESOURCEGROUPS/<resource-group>/PROVIDERS/MICROSOFT.KUSTO/CLUSTERS/<cluster-name>",
 "time": "2018-12-21T17:00:00.0000000Z",
 "metricName": "QueryDuration",
 "timeGrain": "PT1M"
 }
 ]
}

Set up an ingestion pipeline in Azure Data Explorer

Setting up an Azure Data Explorer pipeline involves several steps, such as table creation and data ingestion. You can also manipulate, map, and update the data.

Connect to the Azure Data Explorer web UI

In your Azure Data Explorer TestDatabase database, select Query to open the Azure Data Explorer web UI.

👁 Query page.

Create the target tables

The structure of the Azure Monitor logs isn't tabular. You need to manipulate the data and expand each event to one or more records. Ingest the raw data to an intermediate table named ActivityLogsRawRecords for activity logs and DiagnosticRawRecords for diagnostic metrics and logs. At that time, you manipulate and expand the data. By using an update policy, ingest the expanded data into the ActivityLogs table for activity logs, DiagnosticMetrics for diagnostic metrics, and DiagnosticLogs for diagnostic logs. This process means that you need to create two separate tables for ingesting activity logs and three separate tables for ingesting diagnostic metrics and logs.

Use the Azure Data Explorer web UI to create the target tables in the Azure Data Explorer database.

Create tables for the diagnostic metrics

  1. In the TestDatabase database, create a table named DiagnosticMetrics to store the diagnostic metrics records. Use the following .create table management command:

    .create table DiagnosticMetrics (Timestamp:datetime, ResourceId:string, MetricName:string, Count:int, Total:double, Minimum:double, Maximum:double, Average:double, TimeGrain:string)

  2. Select Run to create the table.

    👁 Run query.

  3. Create the intermediate data table named DiagnosticRawRecords in the TestDatabase database for data manipulation by using the following query. Select Run to create the table.

    .create table DiagnosticRawRecords (Records:dynamic)

  4. Set zero retention policy for the intermediate table:

    .alter-merge table DiagnosticRawRecords policy retention softdelete = 0d

Create table mappings

Because the data format is json, you need to create a data mapping. The json mapping connects each JSON path to a table column name. If a JSON path has special characters, escape them as ['Property Name']. For more information, see JSONPath syntax.

Map diagnostic metrics and logs to the table

Use the following query to map the diagnostic metric and log data to the table:

.create table DiagnosticRawRecords ingestion json mapping 'DiagnosticRawRecordsMapping' '[{"column":"Records","Properties":{"path":"$.records"}}]'

Create the update policy for metric and log data

Create data update policy for diagnostics metrics

  1. Create a function that expands the collection of diagnostic metric records so that each value in the collection gets a separate row. Use the mv-expand operator:

    .create function DiagnosticMetricsExpand() {
 DiagnosticRawRecords
 | mv-expand events = Records
 | where isnotempty(events.metricName)
 | project
 Timestamp = todatetime(events['time']),
 ResourceId = tostring(events.resourceId),
 MetricName = tostring(events.metricName),
 Count = toint(events['count']),
 Total = todouble(events.total),
 Minimum = todouble(events.minimum),
 Maximum = todouble(events.maximum),
 Average = todouble(events.average),
 TimeGrain = tostring(events.timeGrain)
}

  2. Add the update policy to the target table. This policy automatically runs the query on any newly ingested data in the DiagnosticRawRecords intermediate data table and ingests its results into the DiagnosticMetrics table:

    .alter table DiagnosticMetrics policy update @'[{"Source": "DiagnosticRawRecords", "Query": "DiagnosticMetricsExpand()", "IsEnabled": "True", "IsTransactional": true}]'

Create an Azure Event Hubs namespace

Azure diagnostic settings enable exporting metrics and logs to a storage account or to an event hub. In this tutorial, you route the metrics and logs through an event hub. You create an event hub namespace and an event hub for the diagnostic metrics and logs in the following steps. Azure Monitor creates the event hub insights-operational-logs for the activity logs.

  1. Create an event hub by using an Azure Resource Manager template in the Azure portal. To follow the rest of the steps in this article, right-click the Deploy to Azure button, and then select Open in new window. The Deploy to Azure button takes you to the Azure portal.

    👁 Deploy to Azure button.

  2. Create an Event Hubs namespace and an event hub for the diagnostic logs. Learn how to create an Event Hubs namespace.

  3. Fill out the form with the following information. For any settings not listed in the following table, use the default values.

    Setting Suggested value Description
    Subscription Your subscription Select the Azure subscription that you want to use for your event hub.
    Resource group test-resource-group Create a new resource group.
    Location Select the region that best meets your needs. Create the event hub namespace in the same location as other resources.
    Namespace name AzureMonitoringData Choose a unique name that identifies your namespace.
    Event hub name DiagnosticData The event hub sits under the namespace, which provides a unique scoping container.
    Consumer group name adxpipeline Create a consumer group name. Consumer groups enable multiple consuming applications to each have a separate view of the eventstream.

Connect Azure Monitor metrics and logs to your event hub

Now you need to connect your diagnostic metrics and logs and your activity logs to the event hub.

Connect diagnostic metrics and logs to your event hub

Select a resource from which to export metrics. Several resource types support exporting diagnostic data, including event hubs namespace, Azure Key Vault, Azure IoT Hub, and Azure Data Explorer clusters. In this tutorial, use an Azure Data Explorer cluster as your resource. You can review query performance metrics and ingestion results logs.

  1. Select your Kusto cluster in the Azure portal.

  2. Select Diagnostic settings, and then select the Turn on diagnostics link.

    👁 Diagnostic settings.

  3. The Diagnostics settings pane opens. Take the following steps:

    1. Give your diagnostics log data the name ADXExportedData.

    2. Under LOG, select both SucceededIngestion and FailedIngestion check boxes.

    3. Under METRIC, select the Query performance check box.

    4. Select the Stream to an event hub check box.

    5. Select Configure.

      👁 Diagnostics settings pane.

  4. In the Select event hub pane, configure how to export data from diagnostic logs to the event hub you created:

    1. In the Select event hub namespace list, select AzureMonitoringData.
    2. In the Select event hub name list, select DiagnosticData.
    3. In the Select event hub policy name list, select RootManagerSharedAccessKey.
    4. Select OK.

  5. Select Save.

See data flowing to your event hubs

  1. Wait a few minutes until the connection is defined, and the activity-log export to the event hub finishes. Go to your event hubs namespace to see the event hubs you created.

    👁 Event hubs created.

  2. See data flowing to your event hub:

    👁 Event hub's data.

Connect an event hub to Azure Data Explorer

Now you need to create the data connections for your diagnostic metrics and logs and activity logs.

Create the data connection for diagnostic metrics and logs and activity logs

  1. In your Azure Data Explorer cluster named kustodocs, select Databases in the left menu.

  2. In the Databases window, select your TestDatabase database.

  3. In the left menu, select Data ingestion.

  4. In the Data ingestion window, select + Add Data Connection.

  5. In the Data connection window, enter the following information:

    👁 Event hub data connection.

  1. Use the following settings in the Data Connection window:

    Data source:

    Setting Suggested value Field description
    Data connection name DiagnosticsLogsConnection The name of the connection you want to create in Azure Data Explorer.
    Event hub namespace AzureMonitoringData The name you chose earlier that identifies your namespace.
    Event hub DiagnosticData The event hub you created.
    Consumer group adxpipeline The consumer group defined in the event hub you created.

    Target table:

    There are two options for routing: static and dynamic. For this tutorial, you use static routing (the default), where you specify the table name, the data format, and the mapping. Leave My data includes routing info unselected.

    Setting Suggested value Field description
    Table DiagnosticRawRecords The table you created in the TestDatabase database.
    Data format JSON The format used in the table.
    Column mapping DiagnosticRawRecordsMapping The mapping you created in the TestDatabase database, which maps incoming JSON data to the column names and data types of the DiagnosticRawRecords table.

  2. Select Create.

Query the new tables

You now have a pipeline with data flowing. Ingestion through the cluster takes five minutes by default, so wait a few minutes before you start querying.

Query the diagnostic metrics table

The following query analyzes query duration data from diagnostic metric records in Azure Data Explorer:

DiagnosticMetrics
| where Timestamp > ago(15m) and MetricName == 'QueryDuration'
| summarize avg(Average)

Query results:

avg_Average
00:06.156

Related content

Feedback

Was this page helpful?

Additional resources

  • Last updated on