Исследуйте события OneLake в хабе Fabric Real-Time (предпросмотр)
События OneLake информируют о происходящих изменениях в озере данных, таких как создание, изменение или удаление файлов и папок.
Real-Time Hub позволяет обнаруживать и подписываться на эти изменения в OneLake, что позволяет мгновенно реагировать. Например, вы можете отслеживать изменения в файлах и папках Lakehouse и использовать возможности оповещения активатора данных для настройки оповещений на основе определенных условий и определения действий, выполняемых при выполнении этих условий. В этой статье описано, как изучить события OneLake с помощью центра Real-Time
Заметка
Использование событий Fabric и Azure через eventstream или Fabric Активатор не поддерживается, если регион емкости потока событий или активатор находится в следующих регионах: Западная Индия, Центральный Израиль, Центральная Корея, Центральный Катар, Сингапур, Центральный ОАЭ, Центральная Испания, Юго-Восточная Бразилия, Центральная часть США, Южный Центральный США, Западная часть США 2, Западная часть США 3.
Просмотр страницы сведений о событиях OneLake
Вконцентратора
Real-Time выберите события Fabric .Выберите события OneLake из списка.
Вы должны увидеть детальное представление событий OneLake.
Действия
В верхней части страницы сведений вы увидите следующие два действия.
Создать поток событий, что позволяет создавать поток на основе событий из выбранного элемента OneLake.
Задать оповещение, которое позволяет установить оповещение при завершении операции для элемента OneLake, например, при создании нового файла.
Эти действия также доступны в представлении списка событий Fabric.
Узнайте, что использует эту категорию
В этом разделе показаны артефакты, связанные с событиями OneLake. Ниже приведены столбцы и их описания:
| Столбец | Описание |
|---|---|
| Имя | Название артефакта, использующего события OneLake. |
| Тип | Тип артефакта — активатор данных или поток событий |
| Рабочая область | Рабочая область, в которой находится артефакт. |
| Источник | Имя рабочей области, которая является источником событий. |
Профиль событий OneLake
Типы событий
Ниже приведены поддерживаемые события OneLake:
| Имя типа события | Описание |
|---|---|
| Microsoft.Fabric.OneLake.FileCreated | Вызывается при создании или замене файла в OneLake. |
| Корпорация Майкрософт. Fabric.OneLake.FileDeleted | Вызывается при удалении файла в OneLake. |
| Корпорация Майкрософт. Fabric.OneLake.ФайлПереименован | Вызывается при переименовании файла в OneLake. |
| Microsoft.Fabric.OneLake.FolderCreated | Вызывается при создании папки в OneLake. |
| Корпорация Майкрософт. Fabric.OneLake.ПапкаУдалена | Вызывается при удалении папки в OneLake. |
| Корпорация Майкрософт. Fabric.OneLake.ПапкаПереименована | Вызывается при переименовании папки в OneLake. |
Схемы
Событие содержит следующие данные верхнего уровня:
| Свойство | Тип | Описание | Пример |
|---|---|---|---|
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 имеет следующие свойства:
| Свойство | Тип | Описание | Пример |
|---|---|---|---|
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 хранилища. | 00001111-aaaa-2222-bbbb-3333cccc4444 |
requestId |
струна | Идентификатор запроса, созданного службой, для операции API хранилища. | 11112222-bbbb-3333-cccc-4444dddd5555 |
contentOffset |
число | Смещение в байтах операции записи, выполненной в точке, в которой приложение, активировающее событие, завершило запись в файл. | 0 |
sequencer |
струна | Непрозрачное строковое значение, представляющее логическую последовательность событий. | 00000000000004420000000000028963 |