Руководство по аналитике в режиме реального времени, часть 2. Получение данных с помощью eventstream

  • Статья

Примечание.

Это руководство является частью серии. Предыдущий раздел см. в статье "Учебник 1. Создание ресурсов".

Создание потока событий

  1. Вернитесь на домашнюю страницу аналитики в режиме реального времени. Значок "Главная " направляет вас на домашнюю страницу интерфейса, который вы используете в настоящее время.

  2. В разделе "Создать" выберите Eventstream.

    Снимок экрана: новая кнопка потока событий в Аналитике в режиме реального времени в Microsoft Fabric.

  3. Введите NyTaxiTripsEventstream в качестве имени потока событий и нажмите кнопку "Создать".

    После завершения подготовки отображается целевая страница Eventstream.

    Снимок экрана: целевая страница Eventstream после подготовки.

Потоковая передача данных из Eventstream в базу данных KQL

  1. В области разработки eventstream выберите новый исходный пример>данных.

  2. Введите nytaxitripsdatasource в качестве исходного имени и выберите "Желтый такси " в раскрывающемся списке примеров данных.

  3. Выберите Добавить.

  4. В области разработки eventstream выберите "Создать целевую базу>данных KQL".

  5. В разделе "Режим приема данных" выберите "Прямая прием".

  6. В области базы данных KQL заполните поля следующим образом:

    Поле Предлагаемое значение
    Имя назначения nytaxidatabase
    Рабочая область Рабочая область, в которой вы создали базу данных.
    База данных KQL NycTaxiDB

  7. Нажмите кнопку "Добавить" и настроить ее.

    Откроется область приема данных с выбранной вкладкой "Назначение ".

Настройка загрузки данных в базу данных KQL

  1. Выберите +Создать таблицу и введите nyctaxitrips в качестве имени таблицы.

  2. В разделе "Настройка источника данных" просмотрите значения по умолчанию. Имя подключения к данным производится из имени базы данных и имени потока событий.

    Снимок экрана: вкладка источника для потока событий в Аналитике в режиме реального времени в Microsoft Fabric.

    Входящий источник данных распаковлен, поэтому сохраните тип сжатия как None.

  3. Нажмите кнопку "Рядом ", чтобы проверить данные.

Проверка данных

  1. В раскрывающемся списке "Формат" выберите JSON.

    Снимок экрана: вкладка

    Обратите внимание, что предварительный просмотр данных обновляется и отображает данные в столбцах с автоматически идентифицированными типами данных. Для последующих запросов необходимо изменить некоторые из этих типов данных. Столбцы, отображаемые в предварительной версии, можно управлять, щелкнув стрелку вниз справа от имени столбца.

Изменение типов данных

  1. Выберите "Изменить столбцы", чтобы изменить следующие столбцы на целевые типы данных.

    Снимок экрана: изменение типа данных в окне

    Имя столбца Целевой тип данных
    Идентификатор поставщика int
    passenger_count long
    payment_type real

  2. Щелкните Применить, чтобы сохранить изменения.

  3. Нажмите кнопку Готово.

    В окне подготовки данных все шаги помечаются зелеными проверка метками при успешном создании подключения к данным. Данные из Eventstream автоматически начинают потоковую передачу в таблицу.

Примечание.

Возможно, потребуется обновить страницу, чтобы просмотреть таблицу после установки подключения Eventstream.

Связанный контент

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

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

Руководство, часть 3. Получение исторических данных