数据链路故障预警方法及系统与流程

本申请涉及工业物联网边缘计算与数据链路可观测性，具体涉及一种数据链路故障预警方法及系统。

背景技术：

1、在工业物联网（industrial internet of things，iiot）场景中，工业现场数据通常经由多个节点串联形成的数据链路，以非实时方式逐级传递并最终回传至云端。云端负责对整个数据链路的状态进行监控，其监控主要依赖各节点定期上报或随数据回传时附带上报的对账计数、心跳信息及结构化运行日志。

2、然而，当数据链路中的核心节点或其关键服务发生损坏（如关键进程宕机、磁盘写满或通讯中断等）时，该节点不仅无法继续转发业务数据，甚至其自身的诊断证据（例如对账计数与日志）也将停止产生或无法向云端上报。在此期间，云端无法收到该节点及其下游的任何信号，从而形成监控盲区，难以及时感知数据链路的节点异常。

技术实现思路

1、提供一种数据链路故障预警方法及系统，旨在及时感知数据链路的节点异常。

2、第一方面，提供一种数据链路故障预警方法，应用于部署在站端的本地诊断引擎，所述方法包括如下步骤：获取所述数据链路中目标节点的本地指标；响应于所述目标节点的本地指标满足预设告警条件，生成告警事件；执行向本地监控系统发送所述告警事件和将所述告警事件通过业务数据的回传通道回传到云端中的至少一者；其中，在将所述告警事件通过所述回传通道回传到所述云端的情况下，所述告警事件的回传优先级高于所述业务数据。

3、在一些实施例中，所述本地指标包括所述目标节点的中央处理器使用率、内存使用量、磁盘使用率、子模块的运行状态、子模块的累计重启次数、归档文件数以及规约连接状态中的至少一种。

4、在一些实施例中，确定所述目标节点的本地指标满足预设告警条件，包括以下至少一种：确定子模块运行状态异常；确定磁盘剩余空间不足；确定通讯连接中断；确定归档停滞；确定子模块异常重启；确定设备资源不足。

5、在一些实施例中，所述子模块运行状态异常包括所述子模块的运行状态为非运行状态；所述磁盘剩余空间不足包括指定挂载点的磁盘使用率超过第一预设阈值；所述通讯连接中断包括所述规约连接状态为异常状态；所述归档停滞包括所述归档文件数在连续多个采集周期均为零；所述子模块异常重启包括所述子模块的累计重启次数在预设周期内超过第二预设阈值；所述设备资源不足包括所述中央处理器使用率超过第三预设阈值或者所述内存使用量超过第四预设阈值。

6、在一些实施例中，所述将所述告警事件通过所述业务数据的所述回传通道回传到所述云端，包括：将所述告警事件写入预设存储路径，以形成事件文件；在所述业务数据回传时，所述事件文件与所述业务数据通过同一所述回传通道回传至所述云端，且所述事件文件的回传优先级高于所述业务数据。

7、在一些实施例中，所述告警事件包括目标节点标识、故障根因和故障产生时间。

8、第二方面，提供一种数据链路故障预警方法，应用于云端，所述方法包括如下步骤：接收部署在站端的本地诊断引擎通过业务数据的回传通道回传的告警事件；其中，所述告警事件是所述本地诊断引擎响应于所述数据链路中目标节点的本地指标满足预设告警条件所生成并发送的，所述告警事件在所述回传通道中的回传优先级高于所述业务数据；根据接收到的所述告警事件，生成所述数据链路的故障处理任务。

9、在一些实施例中，所述告警事件包括目标节点标识、故障根因和故障产生时间；所述方法还包括：接收所述目标节点回传的诊断证据；在所述诊断证据与所述告警事件指向相同的故障实例的情况下，将所述告警事件中的故障根因作为诊断结论，并将所述诊断证据作为补充信息合并入所述故障处理任务，其中，所述告警事件的置信优先级高于基于所述诊断证据生成的诊断结果。

10、在一些实施例中，所述接收部署在站端的本地诊断引擎通过所述业务数据的所述回传通道回传的告警事件，包括：接收通过所述回传通道回传的事件文件；所述事件文件是所述本地诊断引擎将所述告警事件写入预设存储路径形成的，所述事件文件的回传优先级高于所述业务数据，以使所述事件文件先于所述业务数据到达所述云端。

11、第三方面，提供一种数据链路故障预警系统，包括：本地诊断引擎，部署于站端，所述本地诊断引擎用于获取所述数据链路中目标节点的本地指标；以及，响应于所述目标节点的本地指标满足预设告警条件，生成告警事件；以及，执行向本地监控系统发送所述告警事件和将所述告警事件通过业务数据的回传通道回传到云端中的至少一者；其中，在将所述告警事件通过所述回传通道回传到所述云端的情况下，所述告警事件的回传优先级高于所述业务数据；云端，用于接收通过所述业务数据的回传通道回传的告警事件，以及根据接收到的所述告警事件，生成所述数据链路的故障处理任务。

12、本申请实施例的方法，通过站端本地诊断引擎获取目标节点的本地指标，并在本地指标满足预设告警条件时生成告警事件，因而能够在云端无法取得目标节点的诊断证据时，在站端形成表征节点异常的告警信息。通过向本地监控系统发送告警事件，能够使现场人员较早获知节点异常；通过业务数据的回传通道回传告警事件并使告警事件具有高于业务数据的回传优先级，能够使告警事件尽早到达云端，从而缩短数据链路节点异常的感知时间。

13、本申请实施例的方法，通过接收站端本地诊断引擎优先回传的告警事件，并根据告警事件生成数据链路的故障处理任务，使云端能够利用站端形成的告警信息启动故障处理，降低故障处理对目标节点回传诊断证据的依赖，提高故障处理任务的生成及时性。

14、本申请实施例的系统，通过本地诊断引擎与云端配合，使站端生成的告警事件能够用于本地告警和云端故障处理中的至少一者，并在经业务数据的回传通道回传时获得高于业务数据的回传优先级，从而提高数据链路节点异常在站端和云端的感知及时性。

1.一种数据链路故障预警方法，其特征在于，应用于部署在站端的本地诊断引擎，所述方法包括如下步骤：

2.根据权利要求1所述的数据链路故障预警方法，其特征在于，所述本地指标包括所述目标节点的中央处理器使用率、内存使用量、磁盘使用率、子模块的运行状态、子模块的累计重启次数、归档文件数以及规约连接状态中的至少一种。

3.根据权利要求2所述的数据链路故障预警方法，其特征在于，确定所述目标节点的本地指标满足预设告警条件，包括以下至少一种：

4.根据权利要求3所述的数据链路故障预警方法，其特征在于，

5.根据权利要求1所述的数据链路故障预警方法，其特征在于，所述将所述告警事件通过所述业务数据的所述回传通道回传到所述云端，包括：

6.根据权利要求1所述的数据链路故障预警方法，其特征在于，所述告警事件包括目标节点标识、故障根因和故障产生时间。

7.一种数据链路故障预警方法，其特征在于，应用于云端，所述方法包括如下步骤：

8.根据权利要求7所述的数据链路故障预警方法，其特征在于，所述告警事件包括目标节点标识、故障根因和故障产生时间；所述方法还包括：

9.根据权利要求7所述的数据链路故障预警方法，其特征在于，所述接收部署在站端的本地诊断引擎通过所述业务数据的所述回传通道回传的告警事件，包括：

10.一种数据链路故障预警系统，其特征在于，包括：