Поделиться через

Руководство по аналитике Real-Time, часть 4. Запрос потоковых данных с помощью KQL

  • Статья

Заметка

Это руководство является частью серии. В предыдущем разделе см. руководство по Real-Time аналитике, часть 3. Преобразование данных в базу данных KQL.

В этой части руководства вы узнаете, как запрашивать данные потоковой передачи с помощью KQL. Вы записываете запрос KQL и визуализируете данные в диаграмме времени.

Написание запроса KQL

Имя таблицы, созданной из политики обновления на предыдущем шаге, — TransformedData. Используйте это имя (с учетом регистра) в качестве источника данных для запроса.

Совет

Если у вас есть достаточная подписка, вы можете использовать функцию Copilot для написания запросов. Copilot предоставляет запросы на основе данных вашей таблицы и подсказок на естественном языке. Дополнительные сведения см. в Copilot для Real-Time Intelligence (предварительная версия)

  1. Введите следующий запрос. Затем нажмите клавишу SHIFT+ВВОД, чтобы запустить запрос.

    TransformedData
| where BikepointID > 100 and Neighbourhood == "Chelsea"
| project Timestamp, No_Bikes
| render timechart

    Этот запрос создает диаграмму времени, показывющую количество велосипедов в районе Челси в виде диаграммы времени.

    снимок экрана: диаграмма времени велосипедов в Real-Time Intelligence.

Создание материализованного представления

На этом шаге создается материализованное представление, которое возвращает результат up-to-date запроса агрегирования (всегда свежий). Запрос материализованного представления является более производительным, чем выполнение агрегирования непосредственно над исходной таблицей.

  1. Скопируйте и вставьте и выполните следующую команду, чтобы создать материализованное представление, показывающее последнее количество велосипедов на каждой станции велосипедов:

    .create-or-alter materialized-view with (folder="Gold") AggregatedData on table TransformedData
{
   TransformedData
   | summarize arg_max(Timestamp,No_Bikes) by BikepointID
}

  2. Скопируйте и вставьте и выполните следующий запрос, чтобы просмотреть данные в материализованном представлении, визуализированном в виде диаграммы столбцов:

    AggregatedData
| sort by BikepointID
| render columnchart with (ycolumns=No_Bikes,xcolumn=BikepointID)

Этот запрос будет использоваться на следующем шаге для создания панели мониторинга Real-Time.

Важный

Если вы пропустили любой из шагов, используемых для создания таблиц, обновления политики, функций или материализованных представлений, используйте этот скрипт для создания всех необходимых ресурсов: скрипт с командами из учебника.

Связанное содержимое

Дополнительные сведения о задачах, выполняемых в этом руководстве, см. здесь:

Следующий шаг

Руководство, часть 5: Создание Real-Time панели мониторинга