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


Добавление источника событий Хранилище BLOB-объектов Azure в поток событий (предварительная версия)

В этой статье показано, как добавить источник событий Хранилище BLOB-объектов Azure в поток событий. Событие — это наименьший объем информации, который полностью описывает то, что произошло в системе. Хранилище BLOB-объектов Azure события активируются при создании, замене или удалении большого двоичного объекта. Потоки событий Microsoft Fabric позволяют связывать события хранилища BLOB-объектов с событиями Fabric в концентраторе реального времени.

При добавлении Хранилище BLOB-объектов Azure событий в качестве источника событий он автоматически создает системные события в учетную запись хранения BLOB-объектов и связывает их с событиями Fabric в центре реального времени. Затем эти события можно преобразовать в непрерывные потоки данных и преобразовать их перед маршрутизацией в различные назначения в Fabric.

Потоки событий Fabric поддерживают следующие типы событий хранилища BLOB-объектов:

Имя события Description
Microsoft.Storage.BlobCreated Активируется при создании или замене BLOB-объекта.
Microsoft.Storage.BlobDeleted Активируется при удалении BLOB-объекта.
Microsoft.Storage.BlobRenamed Активируется при переименовании BLOB-объекта.
Microsoft.Storage.BlobTierChanged Активируется при изменении уровня доступа к большому двоичному объекту.
Microsoft.Storage.DirectoryCreated Активируется при создании каталога.
Microsoft.Storage.DirectoryRenamed Активируется при переименовании каталога.
Microsoft.Storage.AsyncOperationInitiated Активируется при запуске операции, связанной с перемещением или копированием данных из архива в горячие или холодные уровни.
Microsoft.Storage.DirectoryDeleted Активируется при удалении каталога.
Microsoft.Storage.BlobInventoryPolicyCompleted Активируется при завершении выполнения инвентаризации для правила, определяющего политику инвентаризации.
Microsoft.Storage.LifecyclePolicyCompleted Активируется при выполнении действий, определенных политикой управления жизненным циклом.

Дополнительные сведения о доступных типах событий см. в Хранилище BLOB-объектов Azure в качестве источника сетки событий.

Внимание

Расширенные возможности потоков событий Fabric в настоящее время находятся в предварительной версии.

Примечание.

Этот источник не поддерживается в следующих регионах рабочей области: западная часть Германии, центрально-южная часть США, западная часть США2, западная часть США3, западная часть США 3, Западная Индия.

Несправляемые и потоковые события

Хранилище BLOB-объектов Azure события — это дискретные события с четкими начальными и конечными точками. Центры реального времени Fabric могут записывать эти события в двух форматах:

  • Несправляемые события. Эти события представлены в их необработанном формате как дискретные события. Если события Хранилище BLOB-объектов Azure не передаются в поток событий, они не подключены непосредственно к потоку событий, а поток по умолчанию не создается.

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

    Снимок экрана, на котором показаны несправляемые события Хранилище BLOB-объектов Azure с кнопкой

  • Потоковые события. Эти события преобразуются в непрерывные события, обеспечивая преобразование в режиме реального времени и маршрутизацию в различные назначения в Fabric для дальнейшего анализа. В потоке событий при нажатии кнопки "Поток событий" в непотеченном Хранилище BLOB-объектов Azure источник преобразует события в непрерывные события. Затем поток событий назначается потоком по умолчанию, позволяя добавлять операции и направлять его в другие назначения в Fabric.

    Снимок экрана: потоковые события Хранилище BLOB-объектов Azure в потоке событий.

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

  • Доступ к рабочей области Fabric premium с разрешениями участника или более высокого уровня.
  • Доступ к Хранилище BLOB-объектов Azure учетной записи blockBlobStorage или BlobStorage(storageV2(общего назначения версии 2)) или blobStorage. Тип хранилища (общего назначения версии 1) не поддерживает интеграцию с потоками событий Fabric.

Примечание.

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

Добавление событий Хранилище BLOB-объектов Azure в качестве источника

  1. Выберите eventstream , чтобы создать новый поток событий. Убедитесь, что включен параметр расширенных возможностей (предварительная версия ).

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

  2. На следующем экране выберите "Добавить внешний источник".

    Снимок экрана: выбор

Настройка и подключение к событиям Хранилище BLOB-объектов Azure

  1. На экране "Выбор источника данных" выберите Хранилище BLOB-объектов Azure события.

    Снимок экрана: выбор событий Хранилище BLOB-объектов Azure.

  2. На экране "Подключение" выберите подписку и учетную запись хранения, которую вы хотите записать в потоке событий.

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

  3. Выберите Далее.

  4. На экране "Проверка и создание" просмотрите сводку и нажмите кнопку "Добавить", чтобы завершить настройку для событий Хранилище BLOB-объектов Azure.

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

После создания подключения вы увидите источник событий Хранилище BLOB-объектов Azure, добавленный в поток событий в режиме редактирования. Выберите "Опубликовать", чтобы опубликовать поток событий и начать запись событий Хранилище BLOB-объектов Azure.

Снимок экрана: источник событий Хранилище BLOB-объектов Azure, добавленный в поток событий.

Примечание.

Узел Eventstream в редакторе не создан по умолчанию. Это связано с тем, что события хранилища BLOB-объектов по-прежнему находятся в виде дискретных событий и еще не преобразуются в поток или подключены к потоку событий.

После публикации изменений учетная запись Хранилище BLOB-объектов Azure теперь связана с концентратором реального времени. Перейдите к событиям > Структуры в режиме реального времени > Хранилище BLOB-объектов Azure события, вы можете найти учетную запись Хранилище BLOB-объектов Azure в раскрывающемся списке и задать триггер для выполнения действий в событиях хранилища BLOB-объектов.

Снимок экрана: выбор событий Хранилище BLOB-объектов Azure в разделе

Снимок экрана: страница

Преобразование событий Хранилище BLOB-объектов Azure

После связывания событий Хранилище BLOB-объектов Azure с событиями Fabric в центре реального времени эти события можно преобразовать в поток и выполнить преобразования в потоках событий.

  1. После добавления источника событий Хранилище BLOB-объектов Azure в режиме редактирования выберите поток событий в источнике, чтобы преобразовать события хранилища BLOB-объектов в поток данных.

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

  2. Ответьте "Да " всплывающему окну, который запрашивает, следует ли передавать события хранилища BLOB-объектов в поток событий.

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

  3. В редакторе поток по умолчанию создается в узле eventstream, указывающий, что события хранилища BLOB-объектов преобразуются в поток в качестве потока по умолчанию.

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

  4. Затем необходимо опубликовать поток событий и убедиться, что в Хранилище BLOB-объектов Azure выполняется хотя бы одно событие, чтобы продолжить преобразование или маршрутизацию.

    Снимок экрана опубликованного потока событий в Режиме реального времени.

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

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

  6. После публикации изменений потоковые события Хранилище BLOB-объектов Azure преобразуются и направляются в назначенное место назначения в Fabric.

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

    Вы также можете просмотреть поток данных на вкладке "Потоки данных" центра реального времени для проверки.

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

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

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