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


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

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

Единственная платформа для потоковых данных в вашей организации

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

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

снимок экрана, показывающий, как запустить подключение к источнику данных.

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

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

   
Передача потоковых данных от других облачных сервисов
  • Google Cloud Pub/Sub (сервис обмена сообщениями)
  • Потоки данных Amazon Kinesis
Кластеры Kafka
  • Confluent Cloud Kafka
  • Apache Kafka
  • Услуга управляемой потоковой передачи данных Amazon для Apache Kafka
Каналы отслеживания измененных данных базы данных (CDC)
  • База данных SQL Azure CDC
  • PostgreSQL база данных CDC
  • База данных MySQL CDC
  • Azure Cosmos DB CDC
  • Управляемый экземпляр Azure SQL CDC
  • SQL Server на виртуальной машине (ВМ) БД CDC
Источники потоковой передачи Майкрософт
  • Центры событий Azure
  • Служебная шина Azure
  • Центр Интернета вещей Azure
События Фабрики События элементов рабочей области Fabric (автоматически созданные)
Мероприятия Azure События учетной записи хранения Azure

Центр Real-Time Hub позволяет без труда подключать эти источники к компонентам Real-Time Hub, таким как Eventstream, база данных KQL и Активатор Fabric.

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

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

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

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

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

  • События Fabric и Azure

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

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

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

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

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

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

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

См. Начало работы с узлом реального времени.