Создание потоков событий по умолчанию и производных событий (предварительная версия)

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

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

Внимание

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

Основные понятия

  • Eventstream — это элемент в рабочей области Fabric, который позволяет выполнять прием, преобразование и маршрутизацию потоков данных в различные назначения в Fabric.

  • Поток — это непрерывный и необвязанный поток событий данных. Когда события данных передаются в потоки событий Fabric, поток формируется внутри потоков событий Fabric для представления событий данных. Существует два типа потоков в потоках событий Fabric:

    • Поток по умолчанию. Каждый элемент потоков событий Fabric поставляется с потоком по умолчанию, который автоматически создается после добавления источника потоковой передачи в поток событий. Он представляет необработанные события, поступающие из источника потоковой передачи. Вы можете преобразовать и перенаправить поток по умолчанию в несколько назначений в Fabric. Поток по умолчанию можно просмотреть из концентратора реального времени.

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

Создание потока по умолчанию

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

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

Создание производного потока

  1. Чтобы создать новый производный поток, добавьте операцию, например "Агрегат " в поток событий. Затем выберите параметр Stream .

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

  2. Присвойте новому потоку имя и нажмите кнопку "Опубликовать ", чтобы зафиксировать изменения.

    Снимок экрана: публикация производного потока.

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

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