HiperMATRIX数据引擎模块位于【物模型配置】-【物模型服务】、【设备配置】-【设备服务】、【数据引擎】 三个位置,可作为物模型以及设备中计算属性值的计算工具,也可单独作为数据处理工具使用。【数据引擎】处的组件与【物模型/设备服务】组件差别在于,【数据引擎】菜单下的组件支持跨设备调用,例如将设备A的实时数据过滤后写入到设备B中。
进入数据引擎建立页面,新建数据服务,点击配置按钮后进入计算配置页面。
1. 组件说明
设备服务组件类型
组件名称 | 组件类型 | 说明 |
---|---|---|
设备输入 | 输入组件 | 输入该设备的属性数据 |
物模型输入 | 输入组件 | 输入继承自物模型的设备属性数据 |
HTTP输入 | 输入组件 | 通过http请求接口获取返回的数据,再将数据传递给下一节点,可选择Get、Post请求方式,有参或无参。 |
RabbitMQ输入 | 输入组件 | 订阅RabbitMQ作为数据服务的输入数据 |
MQTT输入 | 输入组件 | 订阅MQTT作为数据服务的输入数据 |
值触发输入 | 输入组件 | 符合触发条件的属性数据作为输入 |
SQL数据库接口 | 输入组件 | 将数据库数据作为数据来源的输入组件,通过查询数据库数据提供给其他组件进行数据处理。 |
定时器 | 控制组件 | 配置时间频率参数,使组件可以定时执行 |
开关 | 控制组件 | 配置不同的规则,将数据输出到不同的节点中 |
联合 | 控制组件 | 将多个数据输入源的输入属性进行匹配,并根据匹配结果决定是否将数据输出到下一个节点。 |
数据过滤 | 数值计算 | 对数据进行条件过滤,将需要的数据传递给下一节点。条件设置可选择 AND/OR, AND意味着同时满足配置的条件,OR意味着满足以下任何一个条件。 |
产量计算 | 数值计算 | 依据前一个节点输入的数据和用户配置条件,进行产量累加并定时输出累加结果的组件 |
过程计算 | 数值计算 | 计算属性点位数据在满足触发条件下的过程时间长度 |
聚合计算 | 数值计算 | 可对数据进行平均值、最大值、最小值、求和的计算,并将计算值传递给下一节点 |
值映射 | 数值计算 | 依据前一个节点输入的数据,通过配置数据字典对数据进行转换处理 |
差值计算 | 数值计算 | 配置属性数据按照设定的时间间隔进行差值运算,需输入时间间隔长度及单位。 |
设备输出 | 输出组件 | 将计算后的数据输出给设备计算属性 |
MQTT输出 | 输出组件 | 将前置节点输入数据发送到指定MQTT、指定Topic |
RabbitMQ输出 | 输出组件 | 将前置节点输入数据发送到指定RabbitMQ、指定Topic |
数据库存储 | 数据存储 | 包含关系型数据库如SQL Server,Mysql,PostgreSQL,以及时序数据库如influxDB。使用数据库存储前需要连接外部数据库,具体操作方法详见数据源配置。创建数据库连接之后可将经过数值计算服务后的数据存储到对应的数据库资源 |
2.配置操作说明
(1)数据引擎计算配置页面采用拖拽方式构建,右上角选择要使用的组件,鼠标选中拖动组件进入画布中心,组件之间使用连线进行连接。
(2)点击上侧“全局设置”按钮,可配置整体pipe的运行时间,在设定的触发时间以外,所有组件均不运行。支持添加多个触发时间,多个时间范围可交叉,最终触发时间按并集计算。
(3)每个组件右上角设置图标点击后在右侧弹出框中进行组件配置。
(4)完成画布中所有组件的配置后,点击右下角“执行并保存按钮”可开启数据计算,或点击右上角“保存”按钮后,数据服务列表页开启“启动”按钮即可开启计算。
(5)开启计算后,组件下发显示该组件当前状态,选中组件,页面下方可查看该组件的历史数据信息与日志。