• 文档
  • 使用数据联邦分析归档至 Blob 的历史数据

使用数据联邦分析归档至 Blob 的历史数据


本教程帮助你快速学习如何使用数据联邦查询并分析归档至 Blob 的资产历史数据。

前提条件

  • 已被授权使用数据联邦服务和数据归档服务

  • 组织已申请数据联邦资源和数据归档资源

  • 设备数据已完成接入并已向 EnOS 上送数据

  • 已注册 Blob 数据源，用于存储归档文件

备注

本教程中使用的设备资产数据、应用服务账号、归档文件、和示例代码仅供参考。若需实际操作，你需要准备自有的数据进行相应的操作。

操作步骤

使用数据联邦分析归档至 Blob 的历史数据的步骤如下：

  • 创建归档任务将设备数据归档至 Blob 数据源

  • 创建数据联邦读通道，并将 Blob 数据源关联至此读通道

  • 授权并启动联邦读通道

  • 使用联邦查询对 Blob 中的归档数据进行分析

教程目标

本教程要实现的场景是：将 ID 为 VmpNv9KO 的设备进行实时数据归档，将其上送的实时数据归档至 Blob 数据源中，并使用数据联邦查询归档后的设备数据。

创建归档任务

通过以下步骤，创建归档任务将设备数据归档至 Blob 数据源。

  1. 创建归档任务。

    ../_images/creating_archiving_job_1.jpg

  2. 将数据归档至 Blob 数据源，并选择归档模型为 全部。

    ../_images/creating_archiving_job_2.jpg

  3. 通过 设备资产 管理页面，可查看到 ID 为 VmpNv9KO 的设备的测点，并且这些测点已经在上送数据。

    ../_images/creating_archiving_job_3.jpg

创建数据联邦读通道

通过以下步骤，创建数据联邦读通道，并将 Blob 数据源关联至此读通道。

  1. 创建联邦读通道。

    ../_images/creating_federation_channel_1.jpg

  2. 在联邦读通道下关联 Blob 据源。

    ../_images/creating_federation_channel_2.jpg

授权并启动联邦读通道

通过以下步骤，授权应用通过联邦读通道查询数据，并启动联邦通道：

  1. 授权应用通过联邦读通道授权访问数据。

    ../_images/authorizing_app.jpg

  2. 启动联邦读通道并开启跨源分析功能。

    ../_images/starting_channel.jpg

查询 Blob 中的归档数据

通过以下步骤，使用联邦查询对 Blob 中的归档数据进行分析。

  1. 通道启动成功后，通过联邦查询查看 Blob 归档路径下归档的文件。

    ../_images/querying_data_1.jpg

  2. 找到想要查看的文件；例如路径为：/dataconnector/beta/real/20200925/12/real_20200925T1200_zqAzIf.csv

    ../_images/querying_data_2.jpg

  3. 则在编辑器中编写文件数据查询 SQL 语句，例如：

    SELECT * FROM dataconnector002.qatest.`/dataconnector/beta/real/20200925/12/real_20200925T1200_zqAzIf.csv`

  4. 查看数据查询的结果，例如：

    ../_images/querying_data_3.jpg