单元 3: 从外部数据源同步数据¶
主数据相关建模工作完成之后,需要进行数据同步,将外部数据源数据同步到数据资产目录。
步骤 1:在数据源注册服务注册 Open API¶
需注册以下 Open API:
- Token API
- 调用服务的 API
登录 EnOS 管理控制台,从左侧导航栏中选择 数据源注册。
点击 新增数据源。
在 新增数据源 页面中,完成相关配置。
点击 完成,Open API 注册完成。
关于 Open API 注册配置的详细信息,参见 注册 Open API 数据源。
步骤 2:配置数据同步任务¶
完成数据源模块的注册后,需回到 数据资产目录 服务中配置数据同步任务。
创建风场主数据同步任务¶
- 在 数据资产目录 左侧的导航栏中,点击 同步任务 。
- 点击 创建任务 > 自定义同步任务。
- 在新建自定义同步任务页面中,填写或选择以下信息:
- 基本信息:
- 同步任务名称:输入
sync_site
- 数据源类型:选择
Open API
- 数据源选择:选择在 步骤 1 中配置过的数据源
- 数据获取方式:勾选
全量获取
- 同步任务名称:输入
- 请求入参:若在 步骤 1 中已给 API 配置请求参数,则在这一项填写相应请求参数。未配置则这一项显示为空。
- 同步设置:
- 同步内容:选择
entity 同步
,继续选择主数据对象类型UD_site
- 内容映射:
- 字段 name 的返回结果字段:输入
farm_alias
- 字段 siteId 的返回结果字段:输入
farm_id
- 字段 name 的返回结果字段:输入
- 数据校验:勾选开启
- 同步内容:选择
- 基本信息:
- 点击 确定,风场主数据同步任务创建完成。
- 在 同步任务 功能主页面的数据同步任务列表中,点击该风场主数据同步任务行末的 启动
,启动该数据同步任务。
创建风机主数据同步任务¶
- 在 数据资产目录 左侧的导航栏中,点击 同步任务 。
- 点击 创建任务 > 自定义同步任务。
- 在新建自定义同步任务页面中,填写或选择以下信息:
- 基本信息:
- 同步任务名称:输入
sync_eam_turbine
- 数据源类型:选择
Open API
- 数据源选择:选择在 步骤 1 中配置过的数据源
- 数据获取方式:勾选
全量获取
- 同步任务名称:输入
- 请求入参:若在 步骤 1 中已给 API 配置请求参数,则在这一项填写相应请求参数。未配置则这一项显示为空。
- 同步设置:
- 同步内容:选择
entity 同步
,继续选择主数据对象类型UD_EAM_Turbine
- 内容映射:
- 字段 name 的返回结果字段:输入
description
- 字段 turbineId 的返回结果字段:输入
location
- 字段 turbineHeight 的返回结果字段:输入
towheight
- 字段 latitude 的返回结果字段:输入
actual_lat
- 字段 altitude 的返回结果字段:输入
actual_lon
- 字段 name 的返回结果字段:输入
- 数据校验:勾选开启
- 同步内容:选择
- 基本信息:
- 点击 确定,风机主数据同步任务创建完成。
- 在 同步任务 功能主页面的数据同步任务列表中,点击该风机主数据同步任务行末的 启动
,启动该数据同步任务。
创建监控应用主数据同步任务¶
- 在 数据资产目录 左侧的导航栏中,点击 同步任务 。
- 点击 创建任务 > 自定义同步任务。
- 在新建自定义同步任务页面中,填写或选择以下信息:
- 基本信息:
- 同步任务名称:输入
sync_app
- 数据源类型:选择
Open API
- 数据源选择:选择在 步骤 1 中配置过的数据源
- 数据获取方式:勾选
全量获取
- 同步任务名称:输入
- 请求入参:若在 步骤 1 中已给 API 配置请求参数,则在这一项填写相应请求参数。未配置则这一项显示为空。
- 同步设置:
- 同步内容:选择
entity 同步
,继续选择主数据对象类型UD_APP
- 内容映射:
- 字段 name 的返回结果字段:输入
app_name
- 字段 appVersion 的返回结果字段:输入
app_version
- 字段 name 的返回结果字段:输入
- 数据校验:勾选开启
- 同步内容:选择
- 基本信息:
- 点击 确定,监控应用主数据同步任务创建完成。
- 在 同步任务 功能主页面的数据同步任务列表中,点击监控应用主数据同步任务行末的 启动
,启动该数据同步任务。
创建风机和风机应用之间的关系同步任务¶
- 在 数据资产目录 左侧的导航栏中,点击 同步任务 。
- 点击 创建任务 > 自定义同步任务。
- 在新建自定义同步任务页面中,填写或选择以下信息:
- 基本信息:
- 同步任务名称:输入
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
- 模型 UD_EAM_Turbine 主键 turbineId 的返回结果字段:输入
- 同步内容:选择
- 基本信息:
- 点击 确定,风机和风机应用之间的关系同步任务创建完成。
- 在 同步任务 功能主页面的数据同步任务列表中,点击风机和风机应用之间的关系同步任务行末的 启动
,启动该同步任务。
创建风机和风场之间的关系同步任务¶
- 在 数据资产目录 左侧的导航栏中,点击 同步任务 。
- 点击 创建任务 > 自定义同步任务。
- 在新建自定义同步任务页面中,填写或选择以下信息:
- 基本信息:
- 同步任务名称:输入
sync_site_turbine_relation
- 数据源类型:选择
Open API
- 数据源选择:选择在 步骤 1 中配置过的数据源
- 数据获取方式:勾选
全量获取
- 同步任务名称:输入
- 请求入参:若在 步骤 1 中已给 API 配置请求参数,则在这一项填写相应请求参数。未配置则这一项显示为空。
- 同步设置:
- 同步内容:选择
entity 关系同步
,继续选择对象关系UD_Site_Turbine_Relation
- 内容映射:
- 模型 UD_site 主键 siteId 的返回结果字段:输入
site_id
- 模型 UD_EAM_Turbine 主键 turbineId 的返回结果字段:输入
location
- 模型 UD_site 主键 siteId 的返回结果字段:输入
- 同步内容:选择
- 基本信息:
- 点击 确定,风机和风场之间的关系同步任务创建完成。
- 在 同步任务 功能主页面的数据同步任务列表中,点击风机和风场之间的关系同步任务行末的 启动
,启动该同步任务。