为 Azure 数据资源管理器创建 IoT 中心数据连接

本文介绍如何将数据从 IoT 中心(大数据流处理平台和 IoT 引入服务)引入 Azure 数据资源管理器。

若要了解如何在 Azure 门户中或使用 ARM 模板创建连接,请参阅创建 IoT 数据连接

有关从 IoT 中心将数据引入到 Azure 数据资源管理器的常规信息,请参阅连接到 IoT 中心

注意

只有创建数据连接后进入队列的事件才会被引入。

有关基于以前的 SDK 版本的代码示例,请参阅存档的文章

先决条件

创建 IoT 中心数据连接

在本部分,我们将在 IoT 中心与 Azure 数据资源管理器表之间建立连接。 只要建立了此连接,数据就会从 IoT 中心传输到目标表。

  1. 在 Azure 数据资源管理器群集的左侧菜单中,选择“数据库”,然后选择包含目标表的数据库。

    Screenshot of the Azure Data Explorer Web UI, showing a list of databases with testdb selected.

  2. 选择“数据连接”,然后选择“添加数据连接”。 从下拉列表中选择“IoT 中心”。

    Screenshot of the Azure Data Explorer Web UI, showing the Data Ingestion window with the Add data connection tab selected.

  3. 使用以下信息填写窗体。

    设置 字段说明
    数据连接名称 要在 Azure 数据资源管理器中创建的连接的名称
    订阅 事件中心资源所在的订阅 ID。
    IoT 中心 IoT 中心名称
    共享访问策略 共享访问策略的名称。 必须有读取权限
    使用者组 在 IoT 中心的内置终结点中定义的使用者组
    事件系统属性 IoT 中心事件系统属性。 添加系统属性时,创建更新表架构和映射以包括所选属性。

    Screenshot of the Azure Data Explorer Web UI, showing the Data connection form.

    注意

    • 单记录事件支持事件系统属性。
    • 对于 CSV 映射,属性添加到记录的开头。 对于 JSON 映射,将根据下拉列表中显示的名称添加属性。
  4. 可能需要根据用例启用多数据库路由。 有关数据库路由的详细信息,请参阅事件路由

    Screenshot of the Azure Data Explorer Web UI, showing the Data routing settings option set to allow.

  5. 填写以下路由设置:

    设置 建议的值 字段说明
    表名 TestTable 在“testdb”中创建的表。
    数据格式 JSON 支持的格式为 AVRO、CSV、JSON、ORC、PARQUET、PSV、SCSV、SOHSV、TSV、TXT、TSVE、APACHE AVRO 和 W3CLOG。
    映射 TestMapping 在 testdb 中创建的映射将传入的数据映射到 testdb 的列名称和数据类型 。 如果未指定,则将使用从表架构派生的标识数据映射

    Screenshot of the Azure Data Explorer Web UI, showing the default routing settings in the Target table form.

    注意

    • 默认情况下,JSON 数据分析为 multijson。 选择“忽略格式错误”以引入采用严格 JSON 格式的数据。
    • 如果选择了“事件系统属性”,则表架构和映射中必须包含系统属性
  6. 选择“创建” 。

警告

如果进行手动故障转移,请重新创建数据连接。

删除 IoT 中心数据连接

若要从 Azure 门户中删除 IoT 中心连接,请执行以下操作:

  1. 转到你的群集。 在左侧菜单中选择“数据库”。 然后选择包含目标表的数据库。
  2. 从左侧菜单选择“数据连接”。 然后,选中相关的 IoT 中心数据连接旁边的复选框。
  3. 从顶部菜单栏中选择“删除”。