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


Добавление событий Fabric OneLake в поток событий (предварительная версия)

В этой статье показано, как добавить источник событий Fabric OneLake в поток событий.

Заметка

Использование событий Fabric и Azure через eventstream или Fabric Активатор не поддерживается, если регион емкости потока событий или активатор находится в следующих регионах: Западная Индия, Центральный Израиль, Центральная Корея, Центральный Катар, Сингапур, Центральная ОАЭ, Центральная Испания, Центральная Бразилия, Центральная часть США, Южная центральная часть США, Западная часть США 2, Западная часть США 3.

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

Типы событий

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

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

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

  • Получите доступ к рабочей области в режиме лицензии емкости Fabric (или) в режиме пробной лицензии с разрешениями участника или более высокого уровня.
  • создать поток событий, если у вас еще нет потока событий.

Добавление событий Fabric OneLake в качестве источника

Если вы еще не добавили источник в поток событий, выберите элемент Использовать внешний источник.

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

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

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

На странице Выбор источника данных найдите и выберите Connect на плитке события OneLake.

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

Настройка и подключение к событиям Fabric OneLake

  1. На странице Connect для типов событий выберите типы событий, которые требуется отслеживать.

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  7. Затем выберите Далее в нижней части страницы.

    снимок экрана, показывающий выбор кнопки

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

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

Заметка

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

Просмотр обновленного потока событий

  1. После создания подключения вы увидите источник событий Fabric OneLake, который был добавлен в ваш поток событий в режиме редактирования. Выберите Опубликовать, чтобы опубликовать поток событий и записать события OneLake.

    Снимок экрана источника событий Fabric OneLake, добавленного в поток событий.

    Заметка

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

  2. Если вы хотите преобразовать события Fabric OneLake, откройте поток событий и выберите Изменить на панели инструментов, чтобы перейти в режим редактирования. Затем можно добавить операции для преобразования событий Fabric OneLake или перенаправления их в место назначения, например Lakehouse.

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

Известные ограничения

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