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

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

Примечание.

Концентратор реального времени в настоящее время находится в предварительной версии.

Открытие потока событий

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

  • Получите интерфейс событий :

    В конце создания этого потока на странице проверки и создания вы увидите ссылку Open eventstream , чтобы открыть поток событий, связанный с потоком в редакторе.

  • Вкладка потоков данных:

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

  • Страница сведений:

    Выберите поток, родительский объект которого является потоком событий на вкладке "Потоки данных", чтобы просмотреть страницу сведений о потоке. На этой странице можно выбрать ссылку open eventstream на ленте.

Добавление преобразований в поток

После открытия потока событий в редакторе можно добавить такие преобразования, как "Агрегат", "Развернуть", "Фильтр", "Группировать по", "Управление полями" и "Объединение", чтобы преобразовать или обработать потоковую передачу данных в Fabric, а затем отправить выходные данные из преобразований в поддерживаемые назначения. Дополнительные сведения о преобразованиях см. в разделе "Поддерживаемые операции преобразования".

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

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