Fabric 实时中心简介

实时中心是整个组织内所有动态数据的单一位置。 每个 Microsoft Fabric 租户都会自动预配中心。 无需执行额外的步骤即可设置或管理。 它还提供丰富的连接器,用于简化将数据引入 Fabric 的过程。 本文详细介绍了这些功能。

在整个组织中进行数据移动的单一位置

实时中心是用于流式处理动态数据的单一、租户范围的统一逻辑位置。 它使你能够轻松发现、引入、管理和使用来自各种来源的动态数据。 它列出了你可以直接处理的所有流和 Kusto 查询语言 (KQL) 表。 它还提供了从 Microsoft 产品和 Fabric 事件引入流式处理数据的简单方法。

租户中的每个用户都可以查看和编辑其有权访问的所有事件或流。 借助实时中心,可轻松地在一个位置协作和开发流式处理应用程序。

显示“实时中心”页的屏幕截图,该页面中选择了“所有数据流”。

用于从各种来源引入数据的众多连接器

实时中心具有许多现成的连接器,使你可轻松地从各种源将数据引入 Microsoft Fabric。 实时中心支持以下连接器:

   
从其他云流式传输数据
  • Google Cloud Pub/Sub
  • Amazon Kinesis 数据流
Kafka 群集
  • Confluent Cloud Kafka
  • Apache Kafka
  • Amazon Managed Streaming for Apache Kafka
数据库变更数据捕获 (CDC) 信息提要
  • Azure SQL 数据库 CDC
  • PostgreSQL 数据库 CDC
  • MySQL 数据库 CDC
  • Azure Cosmos DB CDC
  • Azure SQL 托管实例 CDC
  • 虚拟机 (VM) 上的 SQL Server DB CDC
Microsoft 流式处理源
  • Azure 事件中心
  • Azure 服务总线
  • Azure IoT 中心
Fabric 事件 Fabric 工作区项事件(自动生成)
Azure 活动 Azure 存储账户事件

借助实时中心,可以轻松地将这些源连接到事件流、KQL 数据库和 Fabric Activator 等实时中心中的组件。

数据集成

  • 所有数据流和表

    对于正在运行的事件流和 KQL 数据库,所有来自事件流的流输出和来自可访问的 KQL 数据库的表都会自动显示在实时中心。

  • 我的流和表

    在实时中心的一个位置访问所有流。

  • 与 Microsoft 源集成

    实时中心列出来自 Microsoft 服务的所有流式处理资源。 无论是 Azure 事件中心、Azure IoT 中心还是其他服务,都可以将数据无缝引入实时中心。

  • Fabric 事件

    通过 Fabric 项目和外部源生成的事件在 Fabric 中可用,以支持事件驱动的应用场景,例如实时警报和触发下游操作。 可以监视和回应事件,包括 Fabric 工作区项事件和 Azure Blob 存储事件。 这些事件可用于触发其他操作或工作流,例如调用数据管道或通过电子邮件发送通知等。 用户还可以通过 Fabric 事件流将这些事件发送到其他目标。

处理、分析数据流并采取行动

实时中心让你能为支持的源创建流。 创建流后,可对其进行处理、分析并设置警报。

  • 处理流,在编辑器中打开父事件流,添加“聚合”、“展开”、“筛选”、“分组依据”、“管理字段”和“联合”等转换,以转换或处理流式传输到 Fabric 中的数据,然后将转换中的输出数据发送到受支持的目标。

  • 分析流,打开与数据流关联的事件流,添加 KQL 数据库目标以将数据发送到 KQL 表,然后打开 KQL 数据库并针对 KQL 表运行查询。 要在实时中心分析表,请打开父级 KQL 数据库并针对 KQL 表运行查询。

  • 要对流或 Fabric 事件采取行动,请根据条件设置警报,并指定满足条件时要执行的操作。

    显示实时中心体系结构概念图像的屏幕截图。

请参阅开始使用实时中心。