CN115996334A - A network fault early warning method, device, electronic equipment and storage medium - Google Patents

Abstract

The application provides a network fault early warning method, a device, electronic equipment and a storage medium, wherein the method comprises the following steps: receiving an interrupt alarm message sent by network equipment, wherein the interrupt alarm message comprises equipment identification of the network equipment; querying all user states corresponding to the equipment identifier; judging whether all user states corresponding to the equipment identifier are off-line; if yes, sending early warning information to all users corresponding to the equipment identifier. By judging whether all user states carried by the network equipment are off-line or not, determining that the network equipment is truly faulty only under the condition that all user states are off-line, and sending early warning information to all users corresponding to the equipment identification at the moment, the method effectively avoids the probability that error early warning is caused by sending early warning information under the condition that some users can still normally use the network equipment to surf the internet, and accordingly the accuracy of sending early warning information to corresponding users according to interrupt alarm information is effectively improved.

Description

A network fault early warning method, device, electronic equipment and storage medium

technical field

The present application relates to the technical fields of network communication, fault early warning and big data, and specifically relates to a network fault early warning method, device, electronic equipment and storage medium.

Background technique

At present, in the process of network operators providing services through network equipment, some failures often occur in the network, such as: real-time discovery of equipment failures through network element alarms associated with network element information, such as optical line terminals (Optical LineTerminal, OLT) disconnected from the network, Network element-level faults such as passive optical network (Passive Optical Network, PON) interruption, optical network unit (Optical Network Unit, ONU) offline, etc. These faults are stored in the historical record data, and then after the system finds faults in these historical records, it will actively push the fault warning message to the corresponding users. However, in the specific practice process, it is found that there are misjudgments of network equipment failures, and the high frequency of false alarms brings great troubles and waste of resources to users and operators.

Contents of the invention

The purpose of the embodiments of the present application is to provide a network failure early warning method, device, electronic equipment and storage medium, which are used to improve the problem that the correct rate of sending early warning messages to corresponding users according to interruption warning messages is not high.

An embodiment of the present application provides a network fault early warning method, including: receiving an interruption warning message sent by a network device, where the interruption warning message includes a device identifier of the network device; querying all users carried by the network device according to the device identifier, and determining the corresponding All user status; determine whether all user status corresponding to the device identifier is offline; if so, send early warning information to all users corresponding to the device identifier. In the above implementation process, by judging whether all the user states carried by the network device are offline, only when all user states are offline, it is determined that the network device is a real fault, and at this time it is reported to the All users corresponding to the device identification send early warning information. This method effectively avoids the probability of sending early warning information and causing false early warnings when some users can still use the network device to access the Internet. The correct rate of users sending warning messages.

Optionally, in this embodiment of the present application, querying all users carried by the network device according to the device identifier, and determining the status of all users corresponding to the device identifier includes: querying all user identifiers carried by the network device in the key-value pair storage database, The key-value pair storage database stores the association relationship between the device ID and the user ID; query the user status corresponding to each user ID in all user IDs to obtain all user status. In the above implementation process, by querying all user IDs corresponding to the device ID in the key-value pair storage database, and querying the user status corresponding to each user ID in the key-value pair storage database, the key-value pair The storage database is used as an intermediate data storage component for associated data, thereby effectively improving the query speed of data. Furthermore, the data storage can set the expiration time of the data during storage, so as to ensure that the expired data will not affect the accuracy of the network fault early warning system.

Optionally, in the embodiment of the present application, before querying the key-value pair storage database for all user identifiers correspondingly carried by the network device, it also includes: building a cluster of distributed stream data stream engine servers; The key-value pair storage database is deployed in a distributed manner on the cluster. In the above implementation process, by building a distributed stream data stream engine server cluster, and deploying a key-value pair storage database on the distributed stream data stream engine server cluster in a distributed manner, the communication between the cluster and a single server network is avoided Network problems and program running bottleneck problems, thus effectively improving the data query speed.

Optionally, in this embodiment of the present application, sending early warning information to all users corresponding to the device identifier includes: for each user among all users corresponding to the device identifier, obtaining each user's actual Influence results: generate early warning information for each user, and then determine whether to send early warning information to all users corresponding to the device identifier according to the actual impact results of each user.

Optionally, in this embodiment of the application, the user information includes: a user offline reason field, a power-down reason field, and an abnormal offline reason field; it is judged that for each user among all users corresponding to the device identifier, obtain each user The actual impact results include: judging whether the user information of each user satisfies the first preset condition, the first preset condition includes: the user offline reason field is abnormal offline, and the power-off reason field is a non-power-off reason, and The abnormal offline reason field has not been backfilled, and whether the time between the receiving time of the interruption warning message and the user’s last offline time exceeds the preset time; if so, confirm that the actual impact result has an actual impact on the user, Otherwise, confirm that the actual impact result is no actual impact on the user.

Optionally, in this embodiment of the present application, the network device is a PON device of a passive optical network. After receiving the interruption alarm message sent by the network device, it further includes: Whether the ONU message record of ONU meets the second preset condition, the second preset condition is that the number of ONU message records is greater than or equal to the preset number, and the proportion of messages whose alarm type is ONU power-off in the ONU message record is greater than or equal to the preset Ratio; if yes, change the alarm type recorded in the ONU message from ONU fiber cut to ONU power down. In the above implementation process, by counting whether the ONU message record corresponding to the device identifier of the PON device meets the second preset condition within the preset time range, the alarm type of the ONU message record is changed from ONU fiber broken to ONU broken Electricity, thereby avoiding the problem of misjudging the alarm type of the ONU device, thereby effectively improving the correct rate of determining the alarm type of the ONU device.

The embodiment of the present application also provides a network failure early warning device, including: an alarm message receiving module, configured to receive an interrupt alarm message sent by a network device, where the interrupt alarm message includes the device identifier of the network device; a user status query module, configured to The device identification queries all users carried by the network device, and determines the status of all users corresponding to the device identification; the user status determination module is used to determine whether all user statuses corresponding to the device identification are offline; the early warning message sending module is used for if the device identification If the status of all corresponding users is offline, an early warning message is sent to all users corresponding to the device identifier.

Optionally, in this embodiment of the application, the user status query module includes: a user identification query module, configured to query all user identifications carried by the network device in the key-value pair storage database, where the key-value pair storage database stores The association relationship between the device ID and the user ID; the user state acquisition module is used to query the user status corresponding to each user ID in all user IDs, and obtain all user statuses.

Optionally, in this embodiment of the application, the user status query module further includes: a service cluster building module, used to build a distributed stream data flow engine server cluster; a key-value pair database module, used to The key-value pair storage database is deployed in a distributed manner on the engine server cluster.

Optionally, in the embodiment of the present application, the early warning message sending module includes: an actual impact result acquisition module, configured to, for each user among all users corresponding to the device identifier, obtain the information of each user according to the user information of each user. The actual impact results; the message generation and sending module is configured to generate early warning information for each user, and then determine whether to send early warning information to all users corresponding to the device identifier according to the actual impact results of each user.

Optionally, in the embodiment of the present application, the user information includes: user offline reason field, power failure reason field and abnormal offline reason field; the actual impact result acquisition module includes: alarm message judging module for judging each Whether the user's user information satisfies the first preset condition, the first preset condition includes: the user offline reason field is abnormal offline, and the power-off reason field is a non-power-off reason, and the abnormal offline reason field is not backfilled, and Whether the duration between the receiving moment of the interrupt warning message and the last offline moment of the user exceeds the preset duration; the actual impact confirmation module is used to confirm the actual impact result if the user information of the user satisfies the first preset condition If it has actual impact on the user, otherwise, confirm that the actual impact result has no actual impact on the user.

Optionally, in the embodiment of the present application, the network device is a passive optical network PON device, and the network fault early warning device further includes: a message record judging module, which is used to judge that the device identification of the PON device is counted within a preset time range Whether the corresponding ONU message record satisfies the second preset condition, the second preset condition is that the number of ONU message records is greater than or equal to the preset number, and the alarm type in the ONU message record is that the proportion of ONU power-down messages is greater than or equal to the preset Set the proportion; the alarm type modification module is used to modify the alarm type of the ONU message record from ONU fiber cut to ONU power down if the ONU message record corresponding to the device identifier satisfies the second preset condition.

Optionally, in this embodiment of the present application, the network device includes: a passive optical network PON device, an optical line terminal device, or an optical network unit ONU.

The embodiment of the present application also provides an electronic device, including: a processor and a memory, the memory stores machine-readable instructions executable by the processor, and the machine-readable instructions execute the method as described above when executed by the processor.

The embodiment of the present application also provides a computer-readable storage medium, where a computer program is stored on the computer-readable storage medium, and when the computer program is run by a processor, the method as described above is executed.

Description of drawings

In order to more clearly illustrate the technical solutions of the embodiments of the present application, the following will briefly introduce the accompanying drawings that need to be used in the embodiments of the present application. It should be understood that the following drawings only show some embodiments of the embodiments of the present application , so it should not be regarded as a limitation on the scope. For those skilled in the art, other related drawings can also be obtained according to these drawings without creative work.

FIG. 1 shows a schematic flow diagram of a network failure early warning method provided by an embodiment of the present application;

Figure 2 shows a schematic diagram of the network architecture of the network failure early warning system provided by the embodiment of the present application;

The schematic flow diagram of the modified ONU alarm type provided by the embodiment of the present application shown in Fig. 3;

FIG. 4 shows a schematic structural diagram of a network failure early warning device provided by an embodiment of the present application;

FIG. 5 shows a schematic structural diagram of an electronic device provided by an embodiment of the present application.

Detailed ways

The following will clearly and completely describe the technical solutions in the embodiments of the present application with reference to the accompanying drawings in the embodiments of the present application. Apparently, the described embodiments are only part of the embodiments of the present application, not all of them. The components of the embodiments of the application generally described and illustrated in the figures herein may be arranged and designed in a variety of different configurations. Therefore, the following detailed description of the embodiments of the present application provided in the drawings is not intended to limit the scope of the claimed embodiments of the present application, but merely represents selected embodiments of the embodiments of the present application. Based on the embodiments of the embodiments of the present application, all other embodiments obtained by those skilled in the art without making creative efforts belong to the protection scope of the embodiments of the present application.

Before introducing the network failure early warning method provided by the embodiment of this application, some concepts involved in the embodiment of this application are first introduced:

Passive Optical Network (PON), also known as passive optical network, is a kind of optical fiber communication network. Its characteristic is that signal processing can be completed without power supply, just like a mirror at home, which can reflect images without electricity , except that the terminal equipment needs to use electricity, the nodes in the middle are composed of exquisite and compact optical fiber components.

Optical Network Unit (ONU) is a terminal device for optical fiber access, which has the functions of optical/electrical conversion and electrical/optical conversion, and also has the function of digital/analog and analog/digital conversion of voice signals and complex The functions of use, signaling processing, and maintenance management can usually be used in conjunction with an Optical Line Terminal (OLT) to provide users with multiple service interfaces.

Optical Line Terminal (OLT), also known as optical link terminal, is an OLT device in the application of PON technology, and it is also a very important local end device. A PON device consists of a central office node, called Optical Link Terminal (OLT), and one or more user nodes, called Optical Network Unit (ONU) or Optical Network Terminals (ONT).

A key-value store database is a non-relational database that uses a simple key-value approach to storing data. A key-value database stores data as a collection of key-value pairs, where the key acts as a unique identifier. Both keys and values can be anything from simple objects to complex compound objects. Key-value databases are highly partitionable and allow horizontal scaling at scales not possible with other types of databases.

Flink is an open source stream processing framework, also known as Apache Flink, whose core is a distributed stream data flow engine written in Java language and Scala language; Flink executes arbitrary stream data programs in data parallel and pipeline mode, and Flink's pipeline The runtime system can execute both batch and stream processing programs.

It should be noted that the network failure early warning method provided in the embodiment of the present application can be executed by an electronic device, where the electronic device refers to a device terminal with the function of executing a computer program or the above-mentioned server, such as a smart phone, a personal computer ( personal computer (PC), tablet computer, personal digital assistant (personal digital assistant, PDA) or mobile Internet device (mobile Internet device, MID), etc. Examples of servers: x86 servers and non-x86 servers, non-x86 servers include: mainframes, minicomputers and UNIX servers.

The applicable application scenarios of the network fault early warning method are introduced below, and the application scenarios here include but are not limited to: application home broadband scenarios based on Point-to-Point Protocol Over Ethernet (PPPoE) on Ethernet. These scenarios are specific for example: use the network fault early warning method to warn the faults of network equipment such as OLT, PON or ONU, so as to improve the correctness of sending early warning messages to corresponding users according to the interruption alarm message; you can also use the network fault The early warning method enhances the functions of the home broadband smart monitoring system. For example, when using the home broadband smart monitoring system to send early warning messages to corresponding users according to interruption alarm messages, the correct rate of sending early warning messages to corresponding users can be improved.

In the specific practice process, it is found that there is a misjudgment of the fault of the network device. For example, although the interruption alarm message sent by the network device is received, some of the multiple users corresponding to the bearer under the same network device You can still use the network device to surf the Internet normally, which means that the network device is still working normally. In the network fault early warning method, it is confirmed that the network device is actually faulty only when all users are offline, and then an early warning message is sent to the corresponding user. Therefore, the use of the network failure early warning method can reduce the occurrence of false early warnings, and improve the correct rate of sending early warning messages to corresponding users according to the interruption alarm messages.

Please refer to the schematic flow diagram of the network fault early warning method provided by the embodiment of the present application shown in Fig. 1; When the user status is not online, it is determined that the network device is a real failure, and then an early warning message is sent to all users corresponding to the device identification. This method effectively prevents some users from still using the network device normally. In the case of surfing the Internet, the probability of sending early warning information leads to false early warning, thereby effectively improving the correct rate of sending early warning messages to corresponding users according to the interruption warning message. The above-mentioned network failure early warning methods may include:

Step S110: the electronic device receives the interruption warning message sent by the network device, and the interruption warning message includes the device identification of the network device.

Please refer to the schematic diagram of the network architecture of the network fault early warning system provided by the embodiment of the present application shown in Figure 2; the network fault early warning system includes: network equipment, broadband-oriented remote access gateway (Broadband Remote Access Server, BRAS), home broadband intelligent monitoring system , remote authentication dial in user service (Remote Authentication Dial In User Service, RADIUS) system, integrated resource system, SMS gateway and centralized fault management system; among them, the home broadband smart monitoring system is connected with RADIUS system, integrated resource system, SMS gateway and The centralized fault management systems communicate with each other, and the BRAS communicates with the network equipment and the RADIUS system respectively. The foregoing network equipment may include: a passive optical network (PON), an optical line terminal (OLT), an optical network unit (ONU), and the like. The network device communicates with devices such as personal computers of broadband users through an optical modem (also called an optical modem).

The implementation of the above step S110 is for example: the home broadband smart monitoring system can be run on the electronic device, and when the network device has an interruption alarm, the interruption alarm message can be sent sequentially through the BRAS and RADIUS systems, wherein the interruption alarm message can include the network device. Equipment Identity. Of course, in a specific practical process, if the network connection route between the network device and the electronic device is different, the interruption alarm message sent by the network device may also be sent through a different network connection route. Then, the electronic device receives the interruption warning message sent by the network device, where the interruption warning message includes the device identification of the network device. In the above network fault warning system, PPPoE scenarios can also be integrated with the broadband authentication RADIUS system, and the electronic equipment running the home broadband smart monitoring system can be used to collect network big data of the integrated resource system, centralized fault management system and RADIUS system , and analyze the big data and monitor the situation of RADIUS online users in real time, so as to discover the home broadband network failures that affect the business in real time.

After step S110, step S120 is executed: the electronic device queries all users carried by the network device according to the device identifier, and determines the status of all users corresponding to the device identifier.

It can be understood that the above-mentioned users may be users in the RADIUS system. There are many ways to implement the above step S120, including but not limited to the following:

The first implementation mode is to query all user states corresponding to the device identifier in the key-value pair storage database. This implementation mode may include:

Step S121: Query all user identifiers carried by the network device in the key-value pair storage database, where the association relationship between the device identifier and the user identifier is stored.

Optionally, before using key-value pairs to store queries in the database, it is also necessary to build a key-value pair storage database. The implementation of building a key-value pair storage database may include: building a distributed stream data flow engine server cluster based on Flink, where The cluster can adopt high-availability (High-Availability, HA) cluster. Deploy the key-value pair storage database in a distributed manner on the distributed flow data flow engine server cluster.

The implementation of the above step S121 is, for example: query all user IDs corresponding to the device ID in a key-value pair storage database such as Redis or Memcached, and the key-value pair storage database stores the association relationship between the device ID and the user ID.

Step S122: Query the user status corresponding to each user ID among all user IDs, and obtain all user statuses.

The implementation manner of the above-mentioned step S122 is for example: the above-mentioned key-value pair storage database can also store the corresponding relationship between the user identifier and the user state, then you can query all user identifiers in the above-mentioned key-value pair storage database such as Redis or Memcached The user state corresponding to the user ID, to obtain all user states.

The second implementation mode is to query all user statuses corresponding to the device identification in a relational database or a non-relational database. This implementation may include: querying in a relational database or a non-relational database for all user identifications carried by a device identification, And query the user status corresponding to each user ID in all user IDs in the relational database or non-relational database to obtain all user status; among them, the relational databases that can be used, such as: Mysql, PostgreSQL, Oracle and SQLSever, etc., can be The non-relational databases used include: grakn database, Neo4j graph database, Hadoop subsystem HBase, MongoDB and CouchDB, etc.

After step S120, step S130 is executed: the electronic device determines whether all user statuses corresponding to the device identification are offline.

In the specific practice process, there are different judgment methods for different network devices. The function of judging whether all the user statuses carried by the device identification are not online is to determine whether the network device actually fails. The above-mentioned network equipment can be OLT equipment, PON equipment or ONU equipment, therefore, the implementation mode of above step S130 includes but not limited to the following several:

In the first embodiment, if the network device is an OLT device, it is judged whether all the user states corresponding to the device identifier of the OLT device are offline. For example, after receiving an interruption alarm message sent by the OLT device, the OLT device can be synchronously queried Whether the user status of all RADIUS users corresponding to the device identifier (for example, the IP address of the OLT device) is offline, so as to determine whether it is a real OLT device interruption fault. The specific process of querying the user status of all RADIUS users corresponding to the device ID of the OLT device. For example: first query the user records of all RADIUS users corresponding to the device ID. Find the corresponding user status in the record (that is, find the online status of the current user in the RADIUS service system). This part of the user record data is accumulated through the long-term RADIUS system, that is to say, whenever the electronic device receives a user record sent by the RADIUS system, it parses out the OLT device identifier associated with the user ID from the user record ( Such as OLT_IP) or/and PON device identifiers (such as PON_ID) and other network device identifiers, and then store the user ID and network device identifier in the Redis cluster, where the key (key) is set to OLT_IP or OLT_IP+PON_ID, value (value) Set to a Set collection composed of users.

In the second embodiment, if the network device is a PON device, it is judged whether all user states corresponding to the device identifier of the PON device are offline. For example, after receiving an interruption alarm message sent by the PON device, the PON device can be queried synchronously. Whether all user statuses corresponding to the device identification are offline, so as to determine whether it is a real PON device interruption fault. In the specific practice process, after generating the warning message corresponding to each user, users can also be screened and marked. Actual impact on offline", and set the reason field of user abnormal offline to "PON interruption" and so on.

In a third embodiment, if the network device is an ONU device, it is judged whether all user states corresponding to the device identifier of the ONU device are offline. The specific implementation of the ONU device will be described in detail after step S140 below.

After step S130, step S140 is executed: if all users corresponding to the device identifiers are offline, the electronic device sends warning information to all users corresponding to the device identifiers.

The implementation manner of the above-mentioned step S140 is for example: if all user states corresponding to the device identification are not online, then send a message to All users corresponding to the device ID send warning information.

In the process of the electronic device sending the warning information to all the users corresponding to the device identifier, it may be determined for each user among all the users corresponding to the device identifier whether the user is actually affected. Among them, whether the user has actual influence can be judged according to whether the user information satisfies the first preset condition. Specifically, for example: judging whether the user information of each user satisfies the first preset condition. The first preset condition includes: the user goes offline The reason field is an abnormal offline, and the power-off reason field is a non-power-off reason, and the abnormal offline reason field has not been backfilled (that is, it is filled again), and the time between the receiving time of the interruption alarm message and the user's last offline time If the user information of the user satisfies the first preset condition, then confirm that the actual impact result has an actual impact on the user; otherwise, confirm that the actual impact result has no actual impact on the user.

Generate early warning information for each user based on the user information of each user, for example: fill each user information into the early warning information template to generate early warning information for each user; then determine whether to send All users corresponding to the device ID send early warning information. For example, if there is an actual impact on the user, you can set the user's abnormal offline failure cause field to device interruption, and then send early warning information to the user. Of course, in the specific During the process, you can also choose not to send warning information to the user. If there is no actual impact on the user, it is enough to record this warning information to the database log.

In the above implementation process, by judging whether all user states corresponding to the device identification are offline, only when all user states are offline, it is determined that the network device is a real fault, and at this time, the device identification All corresponding users send early warning information. This method effectively avoids the probability of wrong early warning caused by sending early warning information when some users can still use the network device to access the Internet. The accuracy of warning messages.

Please refer to the schematic flow chart of the correction ONU alarm type provided by the embodiment of the present application shown in Figure 3; optionally, the alarm type of the interruption alarm message of the above-mentioned optical network unit ONU may include: ONU fiber break and ONU power-off; After receiving the interrupt alarm message sent by the network equipment in step S110, the ONU alarm type can also be corrected, and the implementation of the ONU alarm type can include:

Step S210: Determine whether the ONU message record corresponding to the device identifier of the PON device within the preset time range is counted to meet the second preset condition, the second preset condition is that the number of ONU message records is greater than or equal to the preset number, and The proportion of messages whose alarm type is ONU power-off in the ONU message records is greater than or equal to the preset proportion.

The implementation manner of above-mentioned step S210 is for example: first query the ONU message record corresponding to the equipment identification of PON equipment, comprise the IP address (being OLT_IP) of the OLT equipment corresponding to ONU equipment identification and ONU equipment and the port number of PON equipment in ONU message record (i.e. PON_PORT); then, count the ONU message records corresponding to each OLT device in the preset time range (that is, the specified time period); finally, judge whether the ONU message records corresponding to the device identification meet the second preset condition , the second preset condition is that the number of ONU message records is greater than or equal to the preset number, and the proportion of messages whose alarm type is ONU power down in the ONU message records is greater than or equal to the preset proportion. The second preset condition here is specifically for example: the number of ONU message records is greater than or equal to 3, and the proportion of messages whose alarm type is ONU power down in the ONU message records is greater than or equal to 66%.

Step S220: If the ONU message record corresponding to the device identifier of the PON device meets the second preset condition within the preset time range, change the alarm type of the ONU message record from ONU fiber cut to ONU power down.

The implementation manner of the above-mentioned step S220 is for example: if the ONU message record corresponding to the device identifier of the PON device is counted within the preset time range to meet the second preset condition (for example, the number of ONU message records is greater than or equal to 3, and the ONU message record If the alarm type is that the ONU power-off ratio is greater than or equal to 66%), then first filter out the ONU message records whose alarm type is ONU fiber disconnection; then, record the warning message generated by the mark as "misjudgment"; The alarm type of the message record is changed from ONU fiber cut to ONU power down.

Please refer to the schematic structural diagram of the network fault early warning device provided by the embodiment of the present application shown in FIG. 4; the embodiment of the present application provides a network fault early warning device 300, including:

The alarm message receiving module 310 is configured to receive an interruption alarm message sent by a network device, where the interruption alarm message includes a device identifier of the network device.

The user status query module 320 is configured to query all users carried by the network device according to the device ID, and determine the status of all users corresponding to the device ID.

The user status determination module 330 is configured to determine whether all user statuses corresponding to the device identifiers are offline.

The early warning message sending module 340 is configured to send early warning information to all users corresponding to the device identifier if all users corresponding to the device identifier are offline.

Optionally, in this embodiment of the application, the user status query module includes:

The user identification query module is used to query all user identifications carried by the network device in the key-value pair storage database, and the key-value pair storage database stores the association relationship between the device identification and the user identification.

The user status obtaining module is configured to query the user status corresponding to each user ID in all user IDs, and obtain all user statuses.

Optionally, in this embodiment of the application, the user status query module further includes:

The service cluster building module is used to build a distributed stream data flow engine server cluster.

The key-value pair database module is used to deploy the key-value pair storage database in a distributed manner on the server cluster of the distributed stream data flow engine.

Optionally, in this embodiment of the application, the warning message sending module includes:

The actual impact result acquisition module is configured to acquire the actual impact result of each user according to the user information of each user for each user among all users corresponding to the device identifier;

The message generating and sending module is configured to generate early warning information for each user, and then determine whether to send early warning information to all users corresponding to the device identifier according to the actual impact result of each user.

Optionally, in the embodiment of the present application, the user information includes: a user offline reason field, a power-down reason field, and an abnormal offline reason field; the actual impact result acquisition module includes:

The alarm message judging module is used to judge whether the user information of each user satisfies the first preset condition. The first preset condition includes: the user offline reason field is abnormal offline, and the power-off reason field is a non-power-off reason, and The abnormal logout reason field has not been backfilled, and whether the time between the receiving time of the interruption warning message and the user's last offline time exceeds the preset time.

The actual impact confirmation module is used to confirm that the actual impact result has an actual impact on the user if the user information of the user satisfies the first preset condition, otherwise, confirm that the actual impact result has no actual impact on the user.

Optionally, in the embodiment of the present application, the network device is a passive optical network PON device, and the network fault early warning device further includes:

The message record judging module is used to judge whether the ONU message record corresponding to the device identification of the PON device within the preset time frame is counted and meets the second preset condition, and the second preset condition is that the number of ONU message records is greater than or equal to the preset The number is set, and the proportion of messages whose alarm type is ONU power-off in the ONU message record is greater than or equal to the preset proportion.

The alarm type modification module is used to modify the alarm type of the ONU message record from ONU fiber cut to ONU power down if the ONU message record corresponding to the device identifier satisfies the second preset condition.

Optionally, in this embodiment of the present application, the network device includes: a passive optical network PON device, an optical line terminal device, or an optical network unit ONU.

It should be understood that the device corresponds to the above-mentioned embodiment of the network fault early warning method, and can perform various steps involved in the above-mentioned method embodiment. The specific functions of the device can refer to the description above. To avoid repetition, details are omitted here appropriately. describe. The device includes at least one software function module that can be stored in a memory in the form of software or firmware (firmware) or solidified in an operating system (operating system, OS) of the device.

Please refer to FIG. 5 , which is a schematic structural diagram of an electronic device provided by an embodiment of the present application. An electronic device 400 provided in an embodiment of the present application includes: a processor 410 and a memory 420, the memory 420 stores machine-readable instructions executable by the processor 410, and the machine-readable instructions are executed by the processor 410 to perform the above method .

The embodiment of the present application also provides a computer-readable storage medium 430, on which a computer program is stored, and the computer program is executed by the processor 410 to execute the above method.

Wherein, the computer-readable storage medium 430 can be realized by any type of volatile or non-volatile storage device or their combination, such as static random access memory (Static Random Access Memory, referred to as SRAM), electrically erasable Electrically Erasable Programmable Read-Only Memory (EEPROM for short), Erasable Programmable Read Only Memory (EPROM for short), Programmable Read-Only Memory (PROM for short) ), read-only memory (Read-Only Memory, referred to as ROM), magnetic memory, flash memory, magnetic disk or optical disk.

In the several embodiments provided in the embodiments of the present application, it should be understood that the disclosed devices and methods may also be implemented in other ways. The device embodiments described above are only illustrative. For example, the flowcharts and block diagrams in the accompanying drawings show possible implementation architectures of devices, methods, and computer program products according to multiple embodiments of the embodiments of the present application. function and operation. In this regard, each block in a flowchart or block diagram may represent a module, program segment, or portion of code that contains one or more executable instruction. It should also be noted that, in some alternative implementation manners, the functions noted in the block may also occur out of the order noted in the drawings. For example, two blocks in succession may, in fact, be executed substantially concurrently, or they may sometimes be executed in the reverse order, depending upon the functionality involved.

In addition, the functional modules of the various embodiments in the embodiments of the present application may be integrated to form an independent part, or each module may exist independently, or two or more modules may be integrated to form an independent part.

In this document, relational terms such as first and second etc. are used only to distinguish one entity or operation from another without necessarily requiring or implying any such relationship between these entities or operations. Actual relationship or sequence.

The above description is only an optional implementation of the embodiment of the present application, but the scope of protection of the embodiment of the present application is not limited thereto. Anyone familiar with the technical field can Changes or substitutions that can easily be thought of should fall within the scope of protection of the embodiments of the present application.

Claims (10)

1. A network failure early warning method, characterized in that, comprising: receiving an interruption warning message sent by a network device, where the interruption warning message includes a device identifier of the network device; Querying all users carried by the network device according to the device identifier, and determining the status of all users corresponding to the device identifier; Judging whether all user states corresponding to the device identifier are offline; If yes, send early warning information to all users corresponding to the device identifier. 2. The method according to claim 1, wherein the querying all users carried by the network device according to the device identifier, and determining the status of all users corresponding to the device identifier comprises: Querying all user identifiers carried by the network device in the key-value pair storage database, where the key-value pair storage database stores an association between the device identifier and the user identifier; Query the user status corresponding to each user ID in the all user IDs to obtain the status of all the users. 3. The method according to claim 2, further comprising: Build a distributed stream data flow engine server cluster; The key-value pair storage database is deployed in a distributed manner on the distributed stream data flow engine server cluster. 4. The method according to claim 1, wherein the sending warning information to all users corresponding to the device identifier comprises: For each user among all users corresponding to the device identifier, obtain the actual impact result of each user according to the user information of each user; Generate early warning information for each user, and then determine whether to send early warning information to all users corresponding to the device identifier according to the actual impact result of each user. 5. The method according to claim 4, wherein the user information includes: a user offline reason field, a power-down reason field, and an abnormal offline reason field; Actual impact results for each user described, including: Judging whether the user information of each user satisfies a first preset condition, the first preset condition includes: the user offline reason field is abnormal offline, and the power-down reason field is a non-power-down reason, And the abnormal offline reason field is not backfilled, and whether the time length between the receiving moment of the interruption warning message and the user's last offline time exceeds the preset time length; If yes, confirm that the actual impact result has an actual impact on the user; otherwise, confirm that the actual impact result has no actual impact on the user. 6. The method according to any one of claims 1-5, wherein the network device is a passive optical network PON device, and after receiving the interruption alarm message sent by the network device, further comprising: Judging whether the ONU message record corresponding to the device identifier of the PON device is counted within the preset time range and whether it satisfies a second preset condition, the second preset condition is that the number of ONU message records is greater than or equal to the preset quantity, and the alarm type in the ONU message record is that the proportion of ONU power-down messages is greater than or equal to the preset proportion; If yes, modify the alarm type recorded in the ONU message from ONU fiber cut to ONU power down. 7. The method according to any one of claims 1-5, wherein the network equipment comprises: a passive optical network (PON) equipment, an optical line terminal equipment or an optical network unit (ONU). 8. A network failure early warning device, characterized in that it comprises: An alarm message receiving module, configured to receive an interruption alarm message sent by a network device, where the interruption alarm message includes a device identifier of the network device; A user status query module, configured to query all users carried by the network device according to the device identifier, and determine the status of all users corresponding to the device identifier; A user status determination module, configured to determine whether all user statuses corresponding to the device identifier are offline; The early warning message sending module is configured to send early warning information to all users corresponding to the device identifier if all users corresponding to the device identifier are offline. 9. An electronic device, characterized in that it comprises: a processor and a memory, the memory stores machine-readable instructions executable by the processor, and when the machine-readable instructions are executed by the processor, they perform as follows: The method according to any one of claims 1 to 7. 10. A computer-readable storage medium, wherein a computer program is stored on the computer-readable storage medium, and when the computer program is run by a processor, the method according to any one of claims 1 to 7 is executed.

Images