Общие сведения о концентраторе реального времени Fabric (предварительная версия)

Концентратор реального времени — это единственное место для всех перемещаемых данных во всей организации. Каждый клиент Microsoft Fabric автоматически подготавливается к работе с центром. Для настройки или управления ими не требуется никаких дополнительных действий. Он также предоставляет обширные соединители для упрощенного приема данных в Fabric. В этой статье подробно описаны эти функции.

Примечание.

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

Одно место для перемещения данных в организации

Концентратор реального времени — это однопользовательское, единое, логическое место для потоковой передачи данных в движении. Это позволяет легко обнаруживать, прием, управление и использование данных в движении из различных источников. В нем перечислены все потоки и таблицы язык запросов Kusto (KQL), с которыми можно работать напрямую. Кроме того, это дает простой способ приема потоковых данных из продуктов Майкрософт и событий Fabric.

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

Многочисленные соединители для приема данных из различных источников

Центр реального времени содержит множество встроенных соединителей, которые упрощают прием данных в Microsoft Fabric из различных источников. Концентратор реального времени поддерживает следующие соединители:

Потоковая передача данных из других облаков	Google Cloud Pub/Sub Потоки данных Amazon Kinesis
Кластеры Kafka	Confluent Cloud Kafka Apache Kafka Amazon Managed Streaming for Apache Kafka
Каналы отслеживания измененных данных базы данных (CDC)	База данных SQL Azure CDC Postgre База данных SQL CDC Azure Cosmos DB CDC My База данных SQL CDC УПРАВЛЯЕМЫЙ ЭКЗЕМПЛЯР SQL AZURE CDC SQL Server в базе данных CDC виртуальной машины
Источники потоковой передачи Майкрософт	Центры событий Azure центры Интернета вещей;
События Структуры	События учетной записи хранения Azure События элементов рабочей области Fabric (автоматически созданный)

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

Интеграции данных

• Все потоки данных и таблицы

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

• Мои потоки и таблицы

  Доступ ко всем потокам в одном месте в концентраторе реального времени.

• Интеграция с источниками Майкрософт

  Центр реального времени перечисляет все ресурсы потоковой передачи из службы Майкрософт. Независимо от того, Центры событий Azure, Центр Интернета вещей Azure или другие службы, вы можете легко получать данные в концентратор реального времени.

• События Структуры

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

Обработка, анализ и действие потоков данных

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

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

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

• Чтобы действовать на потоках или событиях Fabric, необходимо задать оповещения на основе условий и указать действия, которые необходимо предпринять при выполнении условий.

  

Связанный контент

См. статью "Начало работы с центром реального времени".