Получить события OneLake в центре Fabric Real-Time

В этой статье описывается, как получать события OneLake в виде потока событий в узле Fabric Real-Time.

Real-Time хаб позволяет обнаруживать и подписываться на изменения в файлах и папках в OneLake, а затем реагировать на эти изменения в режиме реального времени. Например, вы можете реагировать на изменения в файлах и папках в Lakehouse и использовать возможности оповещения активатора для настройки оповещений на основе условий и указания действий, выполняемых при выполнении условий. В этой статье объясняется, как изучить события OneLake в центре Real-Time.

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

Типы событий

Ниже приведены поддерживаемые события OneLake:

Имя типа события Описание
Microsoft.Fabric.OneLake.ФайлСоздан Вызывается при создании или замене файла в OneLake.
Корпорация Майкрософт. Fabric.OneLake.ФайлУдалён Вызывается при удалении файла в OneLake.
Корпорация Майкрософт. Fabric.OneLake.ФайлПереименован Вызывается при переименовании файла в OneLake.
Microsoft.Fabric.OneLake.ПапкаСоздана Создано уведомление, когда создается папка в OneLake.
Корпорация Майкрософт. Fabric.OneLake.Папка удалена Вызывается при удалении папки в OneLake.
Корпорация Майкрософт. Fabric.OneLake.ПапкаПереименована Вызывается при переименовании папки в OneLake.

Необходимые условия

  • Получите доступ к рабочей области в режиме лицензии на мощность Fabric или в режиме пробной лицензии с разрешениями уровня Сотрудника или выше.
  • Разрешение SusbcribeOneLakeEvent на источники данных.

Дополнительные сведения см. в разделе Обзор событий OneLake.

Создание потоков для событий OneLake

Вы можете создать потоки для событий OneLake в концентраторе Real-Time одним из следующих способов:

Страница источников данных

  1. Войдите в Microsoft Fabric.

  2. Если вы увидите Power BI в нижней левой части страницы, переключитесь в режим работы Fabric, выбрав Power BI, а затем выбрав Fabric.

    снимок экрана, показывающий, как перейти к рабочей нагрузке Fabric.

  3. Выберите Режим реального времени на панели навигации слева.

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

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

    Снимок экрана: страница источников данных в центре Real-Time.

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

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

  1. На странице источники данных выберите категорию события OneLake вверху, а затем выберите Connect на плитке события OneLake. Вы также можете использовать панель поиска для поиска событий OneLake.

    снимок экрана, на котором показана страница

    Теперь используйте инструкции из раздела Настройка и создание потока событий.

Страница событий Fabric

В узле Real-Time выберите события Fabric в левом меню. Вы можете использовать представление списка событий Fabric или представление сведений о событиях OneLake для создания потока событий OneLake.

Использование представления списка

Переместите указатель мыши на события OneLakeи выберите ссылку Create Eventstream или выберите ... и затем выберите Создать поток событий.

снимок экрана, на котором показана страница событий Real-Time hub Fabric.

Использование детального просмотра

  1. На странице события Fabric выберите события OneLake из списка поддерживаемых событий Fabric.

  2. На странице сведений выберите + Создать поток событий в меню.

    снимок экрана, на котором показана страница сведений о событиях OneLake.

    Теперь используйте инструкции из раздела Настройка и создание потока событий, но пропустите первый шаг по использованию страницы Добавление источника.

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

  1. На странице Connect выберите типы событий , за которыми вы хотите следить.

    снимок экрана, на котором показан выбор типов событий OneLake на странице Connect.

  2. Этот шаг является необязательным. Чтобы просмотреть схемы типов событий, выберите Просмотреть выбранные схемы типов событий. Если выбрать его, просмотрите схемы событий, а затем вернитесь на предыдущую страницу, нажав кнопку со стрелкой вверху.

  3. Выберите Добавить источник OneLake в разделе Выбор источника данных для событий.

    снимок экрана, на котором показан выбор кнопки

  4. На странице Выберите данные, которые требуется подключить:

    1. Просмотрите все доступные источники данных или только источники данных (мои данные) или избранные источники данных с помощью кнопок категории в верхней части. Вы можете использовать текстовое поле фильтра для поиска по ключевому слову конкретного источника. Вы также можете использовать кнопку фильтра для фильтрации на основе типа ресурса (база данных KQL, Lakehouse, база данных SQL, хранилище). В следующем примере используется параметр "Мои данные".

    2. Выберите источник данных из списка.

    3. Выберите Далее в нижней части страницы.

      снимок экрана, показывающий выбор определенного источника данных OneLake.

  5. Выберите все таблицы или нужную таблицу, а затем выберите Добавить.

    снимок экрана, показывающий выбор всех таблиц.

  6. Теперь на странице Настройка параметров подключения можно добавить фильтры, чтобы задать условия фильтра, выбрав поля для просмотра и значения оповещения. Чтобы добавить фильтр, выполните приведенные действия.

    1. Выберите + Фильтр.

    2. Выберите поле.

    3. Выберите оператора.

    4. Выберите одно или несколько значений для сопоставления.

      снимок экрана, показывающий добавление фильтра.

Сведения о потоке или источнике

  1. На странице "Подключение" выполните одно из этих действий на основе того, используете ли вы поток событий или концентратор Real-Time.

    • Eventstream:

      В области сведений о источнике справа выполните следующие действия:

      1. Чтобы изменить имя источника, нажмите кнопку Карандаш.

      2. Обратите внимание, что имя потока событий и имя Stream доступны только для чтения.

    • центрReal-Time:

      В разделе сведений о потоке справа выполните следующие действия.

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

      2. Для имени eventstream нажмите кнопку «Карандаш» и введите название для eventstream.

      3. Значение имени потока автоматически создается шляхом добавления -stream к имени eventstream. Этот поток отображается на странице "Все потоки данных " концентратора в режиме реального времени, когда мастер завершит работу.

  2. Нажмите кнопку "Далее" в нижней части страницы "Настройка ".

Проверка и подключение

На экране "Обзор и подключение" просмотрите сводку и выберите "Добавить (Eventstream) или "Connect (Real-Time hub).

Просмотр потока на странице хаба Real-Time

  1. Когда мастер успешно создает поток, используйте ссылку Open eventstream, чтобы открыть поток событий, созданный для вас. Нажмите кнопку Готово, чтобы закрыть мастер настройки.

    снимок экрана, на котором показана страница проверки и создания со ссылками для открытия потока событий.

  2. Выберите Real-Time hub в меню навигации слева и убедитесь, что видите созданный поток. Обновите страницу, если она не отображается.

    снимок экрана, на котором показан поток данных на странице

    Подробные инструкции см. в разделе «Просмотр сведений о потоках данных в Fabric Real-Time Hub».

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