1.一种数据采集方法,其特征在于,所述方法包括:
接收管汇场景下目标设备发送的工业数据,所述工业数据包括所述目标设备通过传感器采集的数据;
获取所述管汇场景对应的管汇拓扑结构,所述管汇拓扑结构是通过扫描所述管汇场景中的实际管汇得到的;
将所述目标设备作为初始的起点设备节点,循环执行以下过程:基于所述起点设备节点的标识信息,在所述管汇拓扑结构中确定将所述起点设备节点作为起点的目标管汇线路,并基于所述起点设备节点的工业数据,确定所述目标管汇线路包括的中间管汇节点和设备终点的工业数据,其中所述工业数据包括用于唯一标识所述目标设备的标识信息,且所述管汇拓扑结构中各节点具有用于唯一标识所述节点的标识信息;若所述设备终点不是所述管汇场景下的目标设备终点,则将所述设备终点作为新的起点设备节点,直到所述设备终点为所述管汇场景下的目标设备终点;
将所述管汇节点和所述设备节点的工业数据转发至云平台。
2.根据权利要求1所述的方法,其特征在于,所述目标设备为多个,所述基于所述起点设备节点的标识信息,在所述管汇拓扑结构中确定将所述起点设备节点作为起点的目标管汇线路,包括:在将多个所述目标设备作为起点设备节点的情况下,基于所述起点设备节点的标识信息,在所述管汇拓扑结构中确定将所述起点设备节点作为起点的多条目标管汇线路;
所述基于所述起点设备节点的工业数据,确定所述目标管汇线路包括的中间管汇节点和设备终点的工业数据,包括:在所述多条目标管汇线路的设备终点相同的情况下,将所述起点设备节点的工业数据作为与所述起点设备节点处于同一管汇线路的中间管汇节点的工业数据,并基于多个所述起点设备节点的工业数据,确定所述设备终点的工业数据,其中所述工业数据为排量或作业时间。
3.根据权利要求1所述的方法,其特征在于,所述工业数据包括所述起点设备节点的时间戳,所述基于所述起点设备节点的工业数据,确定所述目标管汇线路包括的中间管汇节点和设备终点的工业数据,包括:在所述目标管汇线路中,确定所述中间管汇节点与所述起点设备节点之间的第一距离,并确定所述设备终点与所述起点设备节点之间的第二距离;
基于所述目标管汇线路中流体的流速和所述第一距离,计算第一流动时间,并基于所述起点设备节点的时间戳和所述第一流动时间,确定所述中间管汇节点的时间戳;
基于所述目标管汇线路中流体的流速和所述第二距离,计算第二流动时间,并基于所述起点设备节点的时间戳和所述第二流动时间,确定所述设备终点的时间戳。
4.根据权利要求1所述的方法,其特征在于,所述方法还包括:
获取所述管汇场景下的历史工业数据,并确定所述历史工业数据中的第一流体数据和第二流体数据,其中所述第一流体数据为从所述目标设备获取到的流体成分数据,所述第二流体数据包括所述管汇场景下的流体指标数据或所述管汇场景下除所述目标设备外的设备和管汇中的流体成分数据;
基于所述第一流体数据和所述第二流体数据训练流体预测模型,所述流体预测模型用于根据输入的、从所述目标设备获取的流体成分数据,输出流体指标数据或对应设备和管汇中的流体成分数据;
所述基于所述起点设备节点的工业数据,确定所述目标管汇线路包括的中间管汇节点和设备终点的工业数据,包括:在所述起点设备节点的工业数据中,确定与所述第一流体数据的类型相同的目标流体数据,并将所述目标流体数据输入训练好的所述流体预测模型,得到所述目标管汇线路对应的流体指标数据或所述目标管汇线路包括的中间管汇节点和设备终点对应的流体成分数据。
5.根据权利要求1‑4任一项所述的方法,其特征在于,所述管汇拓扑结构是通过如下方式得到的:接收扫描终端发送的、在所述管汇场景中扫描到的实际管汇信息;
确定对所述实际管汇信息中各节点标注的端点位置信息和流体方向,其中每一所述节点具有用于唯一标识所述节点的标识信息,所述端点位置信息用于表征所述节点为起点、中间节点和终点中的一者;
基于各节点对应的所述端点位置信息和所述流体方向,建立二维表形式的管汇拓扑结构,其中所述二维表的数据为键值对数据,所述键值对数据中的键用于表征所述节点的端点位置信息,所述键值对数据中的值用于表征所述节点的标识信息。
6.根据权利要求1‑4任一项所述的方法,其特征在于,所述接收管汇场景下目标设备发送的工业数据,包括:通过消息队列或所述云平台的平台网关接收管汇场景下目标设备发送的工业数据;
所述将所述管汇节点和所述设备节点的工业数据转发至云平台,包括:
若通过所述消息队列接收管汇场景下目标设备发送的工业数据,则将所述管汇节点和所述设备节点的工业数据转发至所述消息队列;
若通过所述平台网关接收管汇场景下目标设备发送的工业数据,则将所述管汇节点和所述设备节点的工业数据转发至所述平台网关。
7.一种数据采集装置,其特征在于,所述装置包括:
第一接收模块,用于接收管汇场景下目标设备发送的工业数据,所述工业数据包括所述目标设备通过传感器采集的数据;
第一获取模块,用于获取所述管汇场景对应的管汇拓扑结构,所述管汇拓扑结构是通过扫描所述管汇场景中的实际管汇得到的;
第一确定模块,用于将所述目标设备作为初始的起点设备节点,循环执行以下过程:基于所述起点设备节点的标识信息,在所述管汇拓扑结构中确定将所述起点设备节点作为起点的目标管汇线路,并基于所述起点设备节点的工业数据,确定所述目标管汇线路包括的中间管汇节点和设备终点的工业数据,其中所述工业数据包括用于唯一标识所述目标设备的标识信息,且所述管汇拓扑结构中各节点具有用于唯一标识所述节点的标识信息;若所述设备终点不是所述管汇场景下的目标设备终点,则将所述设备终点作为新的起点设备节点,直到所述设备终点为所述管汇场景下的目标设备终点;
转发模块,用于将所述管汇节点和所述设备节点的工业数据转发至云平台。
8.一种非临时性计算机可读存储介质,其上存储有计算机程序,其特征在于,该程序被处理器执行时实现权利要求1‑6中任一项所述方法的步骤。
9.一种电子设备,其特征在于,包括:
存储器,其上存储有计算机程序;
处理器,用于执行所述存储器中的所述计算机程序,以实现权利要求1‑6中任一项所述方法的步骤。