单元 3: 从外部数据源同步数据


主数据相关建模工作完成之后，需要进行数据同步，将外部数据源数据同步到数据资产目录。

步骤 1：在数据源注册服务注册 Open API


需注册以下 Open API：

  • Token API

  • 调用服务的 API

  1. 登录 EnOS 管理控制台，从左侧导航栏中选择 数据源注册。

  2. 点击 新增数据源。

    ../_images/add_data_source.png

  3. 在 新增数据源 页面中，完成相关配置。

  4. 点击 完成，Open API 注册完成。

关于 Open API 注册配置的详细信息，参见 注册 Open API 数据源。

步骤 2：配置数据同步任务


完成数据源模块的注册后，需回到 数据资产目录 服务中配置数据同步任务。

创建风场主数据同步任务


  1. 在 数据资产目录 左侧的导航栏中，点击 同步任务 。

  2. 点击 创建任务 > 自定义同步任务。

  3. 在新建自定义同步任务页面中，填写或选择以下信息：

    • 基本信息：

      • 同步任务名称：输入 sync_site

      • 数据源类型：选择 Open API

      • 数据源选择：选择在 步骤 1 中配置过的数据源

      • 数据获取方式：勾选 全量获取

    • 请求入参：若在 步骤 1 中已给 API 配置请求参数，则在这一项填写相应请求参数。未配置则这一项显示为空。

    • 同步设置：

      • 同步内容：选择 entity 同步，继续选择主数据对象类型 UD_site

      • 内容映射：

        • 字段 name 的返回结果字段：输入 farm_alias

        • 字段 siteId 的返回结果字段：输入 farm_id

      • 数据校验：勾选开启

  4. 点击 确定，风场主数据同步任务创建完成。

  5. 在 同步任务 功能主页面的数据同步任务列表中，点击该风场主数据同步任务行末的 启动 start_icon，启动该数据同步任务。

创建风机主数据同步任务


  1. 在 数据资产目录 左侧的导航栏中，点击 同步任务 。

  2. 点击 创建任务 > 自定义同步任务。

  3. 在新建自定义同步任务页面中，填写或选择以下信息：

    • 基本信息：

      • 同步任务名称：输入 sync_eam_turbine

      • 数据源类型：选择 Open API

      • 数据源选择：选择在 步骤 1 中配置过的数据源

      • 数据获取方式：勾选 全量获取

    • 请求入参：若在 步骤 1 中已给 API 配置请求参数，则在这一项填写相应请求参数。未配置则这一项显示为空。

    • 同步设置：

      • 同步内容：选择 entity 同步，继续选择主数据对象类型 UD_EAM_Turbine

      • 内容映射：

        • 字段 name 的返回结果字段：输入 description

        • 字段 turbineId 的返回结果字段：输入 location

        • 字段 turbineHeight 的返回结果字段：输入 towheight

        • 字段 latitude 的返回结果字段：输入 actual_lat

        • 字段 altitude 的返回结果字段：输入 actual_lon

      • 数据校验：勾选开启

  4. 点击 确定，风机主数据同步任务创建完成。

  5. 在 同步任务 功能主页面的数据同步任务列表中，点击该风机主数据同步任务行末的 启动 start_icon，启动该数据同步任务。

创建监控应用主数据同步任务


  1. 在 数据资产目录 左侧的导航栏中，点击 同步任务 。

  2. 点击 创建任务 > 自定义同步任务。

  3. 在新建自定义同步任务页面中，填写或选择以下信息：

    • 基本信息：

      • 同步任务名称：输入 sync_app

      • 数据源类型：选择 Open API

      • 数据源选择：选择在 步骤 1 中配置过的数据源

      • 数据获取方式：勾选 全量获取

    • 请求入参：若在 步骤 1 中已给 API 配置请求参数，则在这一项填写相应请求参数。未配置则这一项显示为空。

    • 同步设置：

      • 同步内容：选择 entity 同步，继续选择主数据对象类型 UD_APP

      • 内容映射：

        • 字段 name 的返回结果字段：输入 app_name

        • 字段 appVersion 的返回结果字段：输入 app_version

      • 数据校验：勾选开启

  4. 点击 确定，监控应用主数据同步任务创建完成。

  5. 在 同步任务 功能主页面的数据同步任务列表中，点击监控应用主数据同步任务行末的 启动 start_icon，启动该数据同步任务。

创建风机和风机应用之间的关系同步任务


  1. 在 数据资产目录 左侧的导航栏中，点击 同步任务 。

  2. 点击 创建任务 > 自定义同步任务。

  3. 在新建自定义同步任务页面中，填写或选择以下信息：

    • 基本信息：

      • 同步任务名称：输入 sync_turbine_app_relation

      • 数据源类型：选择 Open API

      • 数据源选择：选择在 步骤 1 中配置过的数据源

      • 数据获取方式：勾选 全量获取

    • 请求入参：若在 步骤 1 中已给 API 配置请求参数，则在这一项填写相应请求参数。未配置则这一项显示为空。

    • 同步设置：

      • 同步内容：选择 entity 关系同步，继续选择对象关系 UD_Turbine_APP_Relation

      • 内容映射：

        • 模型 UD_EAM_Turbine 主键 turbineId 的返回结果字段：输入 wtg_id

        • 模型 UD_APP 主键 name 的返回结果字段：输入 app_name

        • 模型 UD_APP 主键 appVersion 的返回结果字段：输入 app_version

  4. 点击 确定，风机和风机应用之间的关系同步任务创建完成。

  5. 在 同步任务 功能主页面的数据同步任务列表中，点击风机和风机应用之间的关系同步任务行末的 启动 start_icon，启动该同步任务。

创建风机和风场之间的关系同步任务


  1. 在 数据资产目录 左侧的导航栏中，点击 同步任务 。

  2. 点击 创建任务 > 自定义同步任务。

  3. 在新建自定义同步任务页面中，填写或选择以下信息：

    • 基本信息：

      • 同步任务名称：输入 sync_site_turbine_relation

      • 数据源类型：选择 Open API

      • 数据源选择：选择在 步骤 1 中配置过的数据源

      • 数据获取方式：勾选 全量获取

    • 请求入参：若在 步骤 1 中已给 API 配置请求参数，则在这一项填写相应请求参数。未配置则这一项显示为空。

    • 同步设置：

      • 同步内容：选择 entity 关系同步，继续选择对象关系 UD_Site_Turbine_Relation

      • 内容映射：

        • 模型 UD_site 主键 siteId 的返回结果字段：输入 site_id

        • 模型 UD_EAM_Turbine 主键 turbineId 的返回结果字段：输入 location

  4. 点击 确定，风机和风场之间的关系同步任务创建完成。

  5. 在 同步任务 功能主页面的数据同步任务列表中，点击风机和风场之间的关系同步任务行末的 启动 start_icon，启动该同步任务。