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

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

Примечание.

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

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

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

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

Снимок экрана: страница концентратора реального времени с выбранной вкладкой

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

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

   
Потоковая передача данных из других облаков
  • Google Cloud Pub/Sub
  • Amazon Kinesis Data Потоки
Кластеры Kafka
  • Confluent Cloud Kafka
Каналы отслеживания измененных данных базы данных (CDC)
  • База данных SQL Azure CDC
  • Postgre База данных SQL CDC
  • Azure Cosmos DB CDC
  • My База данных SQL CDC
Источники потоковой передачи Майкрософт
  • Центры событий Azure
  • центры Интернета вещей;
События Структуры
  • События учетной записи хранения Azure
  • События элементов рабочей области Fabric
    (автоматически созданный)

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

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

  • Потоки и таблицы

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

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

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

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

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

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

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

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

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

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

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

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