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


Обработка потоков данных в потоках событий Fabric

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

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

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

  • Добавление исходного интерфейса:

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

  • Страница "Все потоки данных" :

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

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

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

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

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

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

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