CN-121448478-B - Rail transit full-interface signal object consistency supervision and logic verification method

CN121448478BCN 121448478 BCN121448478 BCN 121448478BCN-121448478-B

Abstract

The application provides a method for supervising the consistency of signal objects of a rail transit full interface and verifying logic. The method comprises the steps of establishing a signal object corpus and generating object attribute updating events, responding to the object attribute updating events, determining at least two interfaces associated with corresponding signal objects through interface mapping relations, extracting state values of the corresponding signal objects in the interfaces from an original data record, comparing the state values, generating a state consistency alarm when the state values are inconsistent, responding to the object attribute updating events, determining object types of the signal objects corresponding to the object attribute updating events and updated attribute items, calling configurable rules matched with the object types and the attribute items, checking the attribute relation between the signal objects and at least one associated signal object, and generating the logic consistency alarm when the configurable rules are not met. The application can improve the monitoring coverage of the whole interface, improve the recognition accuracy of complex logic anomalies and enhance the tracing and positioning efficiency of alarms.

Inventors

ZHANG MING
SHI LIWEI
WANG YALI
MENG XIAOTONG
CHEN DINGMING
ZHAO XIAOGANG

Assignees

北京和利时系统工程有限公司

Dates

Publication Date: 20260505
Application Date: 20260107

Claims (9)

1. The method for supervising the consistency and logically checking the signal objects of the full interface of the rail transit is characterized by comprising the following steps: Receiving data messages from a plurality of interfaces of the track traffic signal system through a message queue, and uniformly packaging the data messages to obtain an original data record containing a time identifier and a data source identifier; Establishing a signal object corpus based on preconfigured line condition data, wherein the signal object corpus comprises a plurality of signal objects, and object identifiers, object categories, attribute sets and interface mapping relations corresponding to each signal object; Analyzing the data message according to the interface mapping relation, writing the analyzed attribute value into an attribute set of a corresponding signal object, and generating an object attribute update event when the attribute value is updated; responding to an object attribute updating event, determining at least two interfaces associated with the corresponding signal object through an interface mapping relation, extracting the state value of the corresponding signal object at each interface from an original data record, comparing, and generating a state consistency alarm when the state values are inconsistent; responding to an object attribute updating event, determining an object category of a signal object corresponding to the object attribute updating event and an updated attribute item, calling a configurable rule matched with the object category and the attribute item, checking an attribute relationship between the signal object and at least one associated signal object, and generating a logic consistency alarm when the configurable rule is not satisfied; Associating the original data record, the attribute data of the signal object, the configurable rule identifier and the state consistency alarm and/or the logic consistency alarm to form an association record and storing the association record; The step of calling a configurable rule matched with the object category and the attribute item, verifying the attribute relationship between the signal object and at least one associated signal object, and generating a logic consistency alarm when the configurable rule is not satisfied, wherein the step of generating the logic consistency alarm comprises the following steps: Searching a target configurable rule with triggering conditions consistent with rule triggering information in a configurable rule base based on the rule triggering information, wherein the target configurable rule is a script rule, and the script rule is provided with a rule identifier; Determining at least one associated signal object logically associated with the signal object from line condition data according to an object association relation preset in the target configurable rule, and acquiring attribute data corresponding to the signal object and the at least one associated signal object as rule input data; invoking a script execution engine to load and execute the script rule, and outputting a verification result based on the rule input data; And when the verification result indicates that the attribute relationship does not meet the script rule, generating a logic consistency alarm.
2. The method of claim 1, wherein the uniformly encapsulating the data message to obtain the original data record comprising the time identifier and the data source identifier comprises: when a data message is received through a message queue, acquiring the receiving time of the data message and generating a time identifier corresponding to the receiving time; determining a data source identifier corresponding to the data message according to a message queue to which the data message belongs and/or interface identifier information carried by the data message; Combining the time identifier, the data source identifier and the message payload of the data message to generate an original data record, and writing the original data record into the cache memory area for subsequent extraction and association.
3. The method of claim 1, wherein the creating a signal object corpus based on pre-configured line condition data comprises: Generating a plurality of signal objects according to the signal object definition information, and configuring an object identifier, an object category and an attribute set for bearing object attribute values for each signal object; establishing an interface mapping relation for each signal object according to the mapping information, wherein the interface mapping relation is used for indicating an interface set associated with the signal object and mapping fields in the data message into mapping relations of corresponding attribute items in the attribute set; and writing the plurality of signal objects and the corresponding interface mapping relations into a signal object corpus for analyzing the data message and calling subsequent consistency supervision and logic verification.
4. The method according to claim 1, wherein the parsing the data message according to the interface mapping relationship, writing the parsed attribute value into the attribute set of the corresponding signal object, and generating the object attribute update event when the attribute value is updated, includes: Determining an interface corresponding to the data message according to the data source identifier in the original data record, and determining a target signal object and attribute item mapping information corresponding to the target signal object in an interface mapping relation based on the interface; Analyzing the message load of the data message according to the attribute item mapping information to obtain at least one attribute value corresponding to the attribute item mapping information; writing the at least one attribute value into an attribute item corresponding to the attribute item mapping information in the attribute set of the target signal object, and acquiring the written attribute value and the attribute value before writing; and when the written attribute value is inconsistent with the attribute value before writing, generating an object attribute update event, wherein the object attribute update event comprises an object identifier of the target signal object and an attribute item identifier updated.
5. The method of claim 1, wherein extracting and comparing state values of corresponding signal objects at each interface from the raw data record, and generating a state consistency alarm when the state values are inconsistent, comprises: Determining an object identifier of a target signal object according to an object attribute updating event, and determining an interface set associated with the target signal object based on an interface mapping relation of the target signal object; For each interface in the interface set, acquiring a state value corresponding to an object identifier according to a time identifier and a data source identifier in the original data record; Consistency comparison is carried out on all the state values obtained from the interface set, and a state consistency alarm is generated under the condition that at least two state values are different; and associating the state consistency alarm with the object identifier, the interface set and the inconsistent state value for subsequent association processing.
6. The method of claim 1, wherein determining the object class of the signal object corresponding to the object attribute update event and the updated attribute item in response to the object attribute update event comprises: acquiring an object identifier and an attribute item identifier in an object attribute updating event; Searching the signal object corpus based on the object identification to obtain a target signal object, and reading an object category corresponding to the target signal object; Determining an updated attribute item based on the attribute item identifier in an attribute set of a target signal object, and acquiring an attribute name of the attribute item and an updated attribute value; And outputting the object category and the attribute name as rule triggering information, and matching the rule corresponding to the rule triggering information in the configurable rule and executing logic verification.
7. The utility model provides a track traffic full interface signal object uniformity supervision and logic verification device which characterized in that includes: the receiving module is used for receiving data messages from a plurality of interfaces of the track traffic signal system through the message queue, and uniformly packaging the data messages to obtain an original data record containing a time identifier and a data source identifier; the system comprises a building module, a processing module and a processing module, wherein the building module is used for building a signal object corpus based on preconfigured line condition data, and the signal object corpus comprises a plurality of signal objects, and object identifiers, object categories, attribute sets and interface mapping relations corresponding to each signal object; The analysis module is used for analyzing the data message according to the interface mapping relation, writing the analyzed attribute value into the attribute set of the corresponding signal object, and generating an object attribute update event when the attribute value is updated; the comparison module is used for responding to the object attribute updating event, determining at least two interfaces associated with the corresponding signal object through the interface mapping relation, extracting the state value of the corresponding signal object at each interface from the original data record, comparing, and generating a state consistency alarm when the state values are inconsistent; The verification module is used for responding to the object attribute updating event, determining the object category of the signal object corresponding to the object attribute updating event and the attribute item updated, calling a configurable rule matched with the object category and the attribute item, verifying the attribute relationship between the signal object and at least one associated signal object, and generating a logic consistency alarm when the configurable rule is not satisfied; The association module is used for associating the original data record, the attribute data of the signal object, the configurable rule identifier and the state consistency alarm and/or the logic consistency alarm to form and store an association record; The verification module is used for searching a target configurable rule with trigger conditions consistent with the rule trigger information in a configurable rule base based on the rule trigger information, wherein the target configurable rule is a script rule, the script rule is provided with a rule identifier, at least one associated signal object logically associated with the signal object is determined from line condition data according to an object association relation preset in the target configurable rule, attribute data corresponding to the signal object and the at least one associated signal object are obtained and used as rule input data, a script execution engine is called to load and execute the script rule, a verification result is output based on the rule input data, and a logic consistency alarm is generated when the verification result indicates that the attribute relation does not meet the script rule.
8. An electronic device comprising a memory, a processor and a computer program stored on the memory and running on the processor, characterized in that the processor implements the steps of the method according to any one of claims 1 to 6 when executing the computer program.
9. A computer readable storage medium storing a computer program, characterized in that the computer program when executed by a processor implements the steps of the method according to any one of claims 1 to 6.

Description

Rail transit full-interface signal object consistency supervision and logic verification method Technical Field The application relates to the technical field of monitoring of rail transit signal systems, in particular to a method for supervising consistency and logically checking of all-interface signal objects of rail transit. Background The track traffic signal system is used for guaranteeing safe and efficient operation of trains and generally comprises a train control center, a wireless block center, a temporary speed limiting server, computer interlocking, scheduling centralized equipment and the like, wherein data interaction is carried out among the equipment through multiple interface protocols such as Ethernet, serial ports, field buses and the like, so that a complex signal transmission network is formed. To ensure safe and reliable system operation, the consistency of the data of each interface and the logic correctness of the state of the signal object need to be checked. In the prior art, a common technical scheme comprises the steps of deploying a data acquisition and protocol analysis module aiming at a single interface to realize interface byte stream analysis and abnormal threshold judgment, checking and alarming local logic relations of a small number of signal objects based on fixed rules, and independently supervising single object types such as a track section, a signal machine and the like. In addition, the signal object set is mostly dependent on pre-configuration, is difficult to update in real time along with the dynamic changes of temporary speed limit, direction switching and the like, and the interface data, the object data and the alarm information are stored and dispersed, and the association traceability among the data, the objects, the rules and the alarms is lacked, so that the fault location and the problem investigation are not facilitated. Disclosure of Invention In view of the above, the embodiment of the application provides a method for supervising the consistency of all interface signal objects and checking logic of rail transit, which aims to solve the problems of incomplete interface coverage, poor suitability for rule curing, lack of consistency and double checking logic in the prior art. The first aspect of the embodiment of the application provides a method for supervising the consistency and logic checking of signal objects of a track traffic full interface, which comprises the steps of receiving data messages from a plurality of interfaces of a track traffic signal system through a message queue, and uniformly packaging the data messages to obtain an original data record containing a time identifier and a data source identifier; the method comprises the steps of establishing a signal object corpus based on preconfigured line condition data, wherein the signal object corpus comprises a plurality of signal objects and object identifications, object categories, attribute sets and interface mapping relations corresponding to the signal objects, analyzing data information according to the interface mapping relations, writing analyzed attribute values into the attribute sets of the corresponding signal objects, generating object attribute updating events when the attribute values are updated, responding to the object attribute updating events, determining at least two interfaces associated with the corresponding signal objects through the interface mapping relations, extracting state values of the corresponding signal objects at the interfaces from an original data record, comparing the state values, generating state consistency alarms when the state values are inconsistent, responding to the object attribute updating events, determining the object category of the signal object corresponding to the object attribute updating events and the attribute item subjected to updating, calling configurable rules matched with the object categories and the attribute items, checking the attribute relation between the signal object and at least one associated signal object, generating logic consistency alarms when the configurable rules are not met, and storing the original data record, the attribute data, the configurable rule identifications and the state consistency alarms and/or the logic consistency alarms of the corresponding signal objects in an associated record. The second aspect of the embodiment of the application provides a device for supervising and logically checking the consistency of all interface signal objects of rail transit, which comprises a receiving module, a data processing module and a data processing module, wherein the receiving module is used for receiving data messages from a plurality of interfaces of a rail transit signal system through a message queue and uniformly packaging the data messages to obtain an original data record containing a time identifier and a data source identifier; the system comprises a building module, a comparison module, a ve