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

Изучите события OneLake в хабе Fabric Real-Time

События OneLake информируют о происходящих изменениях в озере данных, таких как создание, изменение или удаление файлов и папок.

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

Заметка

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

Просмотр страницы сведений о событиях OneLake

  1. В центре реального времени выберите события Fabric.

  2. Выберите события OneLake из списка.

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

  3. Вы должны увидеть детальное представление событий OneLake.

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

Действия

В верхней части страницы сведений вы увидите следующие два действия.

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

  • Задать оповещение, которое позволяет установить оповещение при завершении операции для элемента OneLake, например, при создании нового файла.

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

    Эти действия также доступны в представлении списка событий Fabric.

Узнайте, что использует эту категорию

В этом разделе показаны артефакты, связанные с событиями OneLake. Ниже приведены столбцы и их описания:

Column Описание
Имя Название артефакта, использующего события OneLake.
Тип Тип артефакта — активатор или поток событий
Рабочая область Рабочая область, в которой находится артефакт.
Источник Имя рабочей области, которая является источником событий.

Профиль событий OneLake

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

Типы событий

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

Имя типа события Описание
Microsoft.Fabric.OneLake.FileCreated Вызывается при создании или обновлении файла в OneLake.
Корпорация Майкрософт. Fabric.OneLake.FileDeleted Вызывается при удалении файла в OneLake.
Корпорация Майкрософт. Fabric.OneLake.FileRenamed Вызывается при переименовании файла в OneLake.
Microsoft.Fabric.OneLake.FolderCreated Вызывается при создании папки в OneLake.
Корпорация Майкрософт. Fabric.OneLake.FolderDeleted Вызывается при удалении папки в OneLake.
Корпорация Майкрософт. Fabric.OneLake.FolderRenamed Вызывается при переименовании папки в OneLake.

Схемы

Событие содержит следующие данные верхнего уровня:

Property Тип Описание Пример
source струна Определяет контекст, в котором произошло событие. /aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb/workspaces/bbbbbbbb-1111-2222-3333-cccccccccccc/items/cccccccc-2222-3333-4444-dddddddddddd
subject струна Определяет тему события в контексте производителя событий. /Files/FolderA/FileName.txt
type струна Один из зарегистрированных типов событий для этого источника событий. Microsoft.Fabric.OneLake.FileCreated
time метка времени Время события генерируется на основе времени UTC поставщика. 2017-06-26T18:41:00.9584103Z
id струна Уникальный идентификатор события. bbbbbbbb-1111-2222-3333-cccccccccccc
data объект Данные события. Дополнительные сведения см. в следующей таблице.
dataschemaversion струна Версия схемы данных. 1.0
specversion струна Версия спецификации Cloud Event. 1.0

Объект data имеет следующие свойства:

Property Тип Описание Пример
eTag струна Значение, которое можно использовать, чтобы выполнять операции при определённых условиях. "\"0x8D4BCC2E4835CD0\"
contentLength струна Размер файла в байтах. 0
contentType струна Тип контента, указанный для файла. text/plain
blobUrl струна Blob URL для пути к файлу. https://onelake.blob.fabric.microsoft.com/55556666-ffff-7777-aaaa-8888bbbb9999 < 66667777-aaaa-8888-bbbb-9999cccc0000/Files/FolderA/File1.txt
url струна URL OneLake для пути к файлу. https://onelake.dfs.fabric.microsoft.com/eeeeeeee-4444-5555-6666-ffffffffffff < aaaaaaaa-6666-7777-8888-bbbbbbbbbbbb/Files/FolderA/File1.txt
api струна Операция, активировающая событие. CreateFile
clientRequestId струна Идентификатор предоставленного клиентом запроса для операции API хранилища. aaaabbbb-0000-cccc-1111-dddd2222eeee
requestId струна Идентификатор запроса, созданного службой, для операции API хранилища. aaaabbbb-0000-cccc-1111-dddd2222eeee
contentOffset number Смещение в байтах операции записи, выполненной в точке, в которой приложение, активировающее событие, завершило запись в файл. 0
sequencer струна Непрозрачное строковое значение, представляющее логическую последовательность событий. 00000000000004420000000000028963

Разрешение подписки

Дополнительные сведения см. в разделе разрешения на подписку на события Fabric.

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

  • Last updated on