Добавление назначения базы данных KQL в поток событий

В этой статье показано, как добавить базу данных KQL в качестве назначения в поток событий в потоках событий Microsoft Fabric.

Примечание.

Если вы хотите использовать расширенные возможности, которые находятся в предварительной версии, выберите расширенные возможности в верхней части. В противном случае выберите стандартные возможности. Сведения о расширенных возможностях, которые находятся в предварительной версии, см. в разделе "Общие сведения о потоках событий Fabric".

Необходимые компоненты

  • Доступ к рабочей области Fabric premium, в которой находится ваш поток событий с разрешениями участника или более высокого уровня.
  • Доступ к базе данных KQL, созданной в рабочей области Fabric premium, где у вас есть разрешения участника или более высокого уровня.

Примечание.

Максимальное количество источников и назначений для одного потока событий — 11.

Добавление базы данных KQL в качестве назначения

Чтобы добавить базу данных KQL в качестве назначения, можно выбрать один из двух режимов приема: прямую прием или обработку событий перед приемом.

Режим прямого приема

Прямой прием данных событий непосредственно в базу данных KQL без обработки. Режим прямого приема можно использовать для добавления назначения базы данных KQL в поток по умолчанию.

Внимание

Вы можете использовать прямое прием только для потока по умолчанию. Прямое прием не может следовать операторам обработки или производным потокам. Если вы хотите добавить назначение базы данных KQL после обработки операторов или производных потоков, используйте обработку событий перед приемом .

  1. В режиме редактирования для потока событий выберите "Добавить назначение" на ленте или выберите события преобразования или добавьте конечные карта на холсте, а затем выберите базу данных KQL.

    Снимок экрана: выбор базы данных KQL в раскрывающемся списке

  2. На экране базы данных KQL выберите прямой прием.

  3. Введите имя назначения, рабочую область и базу данных KQL из выбранной рабочей области.

  4. Выберите Сохранить.

    Снимок экрана: экран конфигурации базы данных KQL.

  5. Подключение новое назначение базы данных KQL карта выходным данным потока событий, если оно еще не подключено, а затем нажмите кнопку "Опубликовать".

    Снимок экрана: поток событий с выделенной кнопкой

  6. В режиме реального времени выберите "Настроить" в узле назначения базы данных KQL.

    Снимок экрана опубликованного потока событий с кнопкой

  7. База данных KQL откроется на экране получения данных . Выберите существующую таблицу базы данных KQL или выберите новую таблицу для маршрутизации и приема данных.

  8. Укажите имя подключения к данным или сохраните имя, а затем нажмите кнопку "Далее". Для извлечения данных из потока событий может потребоваться несколько минут.

    Снимок экрана: экран получения данных для назначения базы данных KQL с выделенной кнопкой

  9. На экране проверки данных можно:

    • Выберите формат, чтобы просмотреть способ отправки данных в базу данных KQL.
    • Выберите "Изменить столбцы", чтобы настроить столбцы для данных.
    • Выберите "Дополнительно ", чтобы выбрать события для включения или выбора параметров сопоставления.

    Снимок экрана: форматы данных и дополнительные параметры на экране проверки данных.

  10. Если выбрать "Изменить столбцы", на экране "Изменить столбцы" можно:

    • Выберите " Добавить столбец", чтобы добавить столбец .
    • Выберите исходные столбцы для сопоставления.
    • Применение преобразования сопоставления к столбцам.
    • Изменение примеров значений данных .

    Затем выберите Применить.

    Снимок экрана: экран

  11. После завершения настройки данных нажмите кнопку "Готово " на экране проверки данных .

  12. На экране сводки просмотрите сведения и состояние приема данных, включая таблицу с заданной схемой и соединением между потоком событий и базой данных KQL. Нажмите кнопку "Закрыть", чтобы завершить настройку базы данных KQL.

    Снимок экрана: экран

Теперь можно увидеть назначение базы данных KQL на холсте в режиме реального времени.

Снимок экрана: настроенное назначение базы данных KQL в режиме реального времени.

Обработка событий перед приемом

Обработка событий перед приемом обрабатывает данные события перед приемом данных перед приемом в базу данных KQL. Используйте этот режим, если вы применяете такие операторы, как фильтрация или агрегирование для обработки данных перед приемом или после производного потока.

  1. В режиме редактирования для потока событий наведите указатель мыши на оператор или производный поток, выберите +и выберите KQL Database.

    Снимок экрана: выбор символа +для выходных данных оператора и выбор базы данных KQL.

  2. На экране базы данных KQL обработка событий перед приемом уже должна быть выбрана. Заполните остальные сведения о базе данных KQL и нажмите кнопку "Сохранить".

    Снимок экрана: экран конфигурации базы данных KQL для обработки событий перед приемом.

  3. Чтобы реализовать только что добавленное назначение базы данных KQL, выберите "Опубликовать".

    Снимок экрана: поток событий в режиме редактирования с добавленным назначением базы данных KQL.

После выполнения этих действий поток событий с назначением базы данных KQL доступен для визуализации в режиме реального времени.

Снимок экрана: настроенный поток обработки событий базы данных KQL в режиме реального времени.

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

Необходимые компоненты

Перед началом работы необходимо выполнить следующие предварительные требования:

  • Получите доступ к рабочей области premium с разрешениями участника или выше, где находится ваш поток событий.
  • Доступ к рабочей области premium с разрешениями участника или выше, где находится база данных KQL.

Примечание.

Максимальное количество источников и назначений для одного потока событий — 11.

Добавление базы данных KQL в качестве назначения

Чтобы добавить базу данных KQL в качестве назначения, необходимо создать базу данных KQL в рабочей области и выбрать два режима приема: прямая прием и обработка событий перед приемом.

Прямое прием

Этот режим обрабатывает данные событий непосредственно в базе данных KQL без обработки. Этот режим можно использовать, если вы хотите принять данные события как есть и выполнить любую обработку или преобразование позже в базе данных KQL с помощью запросов KQL.

  1. Выберите новое назначение на ленте или "+" на холсте основного редактора, а затем выберите базу данных KQL. Откроется экран конфигурации целевой базы данных KQL.

  2. Выберите прямой прием, введите имя назначения, выберите рабочую область, выберите базу данных KQL из выбранной рабочей области, а затем нажмите кнопку "Добавить и настроить".

    Примечание.

    Вы можете выбрать только рабочие области с той же емкостью Fabric региона, что и поток событий.

    Снимок экрана: экран целевой конфигурации режима извлечения базы данных KQL.

  3. На странице "Получение данных" перейдите по вкладкам, чтобы завершить настройку:

    1. Настройка. Используйте существующую таблицу базы данных KQL или создайте новую для маршрутизации и приема данных. Заполните обязательные поля и нажмите кнопку "Далее".

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

    2. Проверьте: выберите формат данных и просмотрите способ отправки данных в базу данных KQL.

      Снимок экрана: формат данных экрана приема данных для создания назначения базы данных KQL.

      Вы также можете изменить имя столбца, тип данных или обновить столбец, щелкнув стрелку в заголовке таблицы. Заполните обязательные поля и нажмите кнопку Готово.

      Снимок экрана: изменение столбца экрана приема данных для создания назначения базы данных KQL.

      Снимок экрана: изменение имени столбца, типа данных экрана приема данных для создания назначения базы данных KQL.

    3. Сводка. Просмотрите состояние приема данных, включая таблицу, созданную с заданной схемой, и подключение между потоком событий и базой данных KQL.

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

  4. После настройки всего и нажатия кнопки "Закрыть" на холсте появится назначение базы данных KQL, подключенное к потоку событий.

    Снимок экрана: новое назначение режима извлечения базы данных KQL.

Обработка событий перед приемом

Этот режим обрабатывает данные события перед приемом данных в базу данных KQL. Этот режим можно использовать, если вы хотите применить некоторые обработки или преобразования к данным события перед приемом, например фильтрацией, агрегированием или расширением. Вы можете разработать логику обработки с помощью обработчика событий.

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

    Снимок экрана: экран конфигурации целевого режима отправки базы данных KQL.

  2. Проектирование обработки событий с помощью обработчика событий, а затем нажмите кнопку "Сохранить"

    Снимок экрана: экран обработчика событий в режиме push-уведомлений.

  3. При выборе существующей таблицы Kusto выполняется проверка схемы между текущей схемой в этом потоке событий и целевой таблицей KQL. Если две схемы не совпадают, отображается сообщение об ошибке и напоминает вам, чтобы открыть обработчик событий, чтобы настроить схему в этом потоке событий соответствующим образом.

    Снимок экрана: экран ошибки обработчика событий в режиме push.

    При открытии обработчика событий подробные сведения о несоответствии отображаются на вкладке "Ошибка разработки".

    Снимок экрана: экран несоответствия обработчика событий в режиме push.

  4. После настройки всего и нажатия кнопки "Сохранить" на холсте появится назначение базы данных KQL, подключенное к потоку событий, и вы можете проверка метрики в аналитике данных и журналах в журналах среды выполнения.

    Снимок экрана: новое назначение режима отправки базы данных KQL.

Управление назначением

Изменение и удаление: можно изменить или удалить назначение потока событий с помощью области навигации или холста.

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

Снимок экрана: выбор параметров изменения и удаления для назначений на холсте.

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