Search

CN-121996441-A - Event processing method and related equipment

CN121996441ACN 121996441 ACN121996441 ACN 121996441ACN-121996441-A

Abstract

The application discloses an event processing method and related equipment, wherein filtering can be performed based on additional states outside the content of an event message, namely filtering rules based on additional conditions, in particular filtering distribution of the event message can be realized based on filtering conditions of the additional states (such as other states of an event source not provided in the event message, surrounding environment states irrelevant to the event source and the like) through actively acquiring the additional states. In addition, the combination logic of the conditions can be realized through the combination arrangement of a plurality of additional conditions, so that a higher-order filtering mode can be generated, an arrangement page can be provided, the combination of the additional conditions can be rapidly generated through arranging the arrangement page in a mode of carrying out the dragging on the arrangement page, and the usability is improved.

Inventors

  • GUO TIANCI
  • CHANG YU

Assignees

  • 花瓣云科技有限公司

Dates

Publication Date
20260508
Application Date
20241108

Claims (14)

  1. 1. A method of event processing, the method comprising: the method comprises the steps that an event bus platform obtains first information and second information, wherein the first information comprises information of a first event, and the second information comprises state information associated with the first event; And under the condition that the event bus platform determines that the first information meets a first condition and the second information meets a second condition, the event bus platform sends a first message to the terminal equipment, wherein the first message is used for indicating that the first information meets the first condition and the second information meets the second condition.
  2. 2. The method according to claim 1, wherein the first event is a fluctuation event of CPU usage of a central processing unit, and the first information includes information of the CPU usage.
  3. 3. The method according to claim 1 or 2, wherein the second information includes any one or more of information of a service success rate and information of a memory usage rate.
  4. 4. A method according to any of claims 1-3, wherein the second condition comprises at least two sub-conditions, the second condition being generated by a combined orchestration of the at least two sub-conditions on a first user interface, the first user interface being a user interface provided by the event bus platform.
  5. 5. The method of claim 4, wherein the second information satisfies a second condition, and specifically comprising the second information satisfying at least one of the at least two sub-conditions.
  6. 6. The method of any of claims 2-5, wherein the first condition is that the CPU utilization is greater than a first preset threshold.
  7. 7. The method according to any one of claims 3-6, wherein the second condition is that the service success rate is less than a second preset threshold and/or the memory usage rate is greater than a third preset threshold.
  8. 8. The method of any of claims 1-7, wherein the first information is obtained in an event source and the second information is obtained in the event source or a status source.
  9. 9. The method of any of claims 1-8, wherein the event bus platform comprises a first processing module and a second processing module, the first processing module configured to determine whether the first information satisfies the first condition, and the second processing module configured to determine whether the second information satisfies the second condition.
  10. 10. The method of any of claims 1-9, wherein prior to the event bus platform obtaining the first information and the second information, the method further comprises: The event bus platform records first setting information, wherein the first setting information is set by a user of the terminal equipment, the first setting information is used for indicating information acquired by the event bus platform and conditions met by the information, the information comprises the first information and the second information, and the conditions comprise the first condition and the second condition.
  11. 11. The method according to any of claims 1-10, wherein the event bus platform sends a first message to a terminal device, specifically comprising: And the event bus platform sends the first message to the terminal equipment through a connector.
  12. 12. An electronic device comprising one or more processors and one or more memories, wherein the one or more memories are coupled to the one or more processors, the one or more memories to store computer program code comprising computer instructions that, when executed by the one or more processors, cause the electronic device to perform the method of any of claims 1-11.
  13. 13. A computer storage medium storing a computer program comprising program instructions which, when run on an electronic device, cause the electronic device to perform the method of any one of claims 1-11.
  14. 14. A computer program product which, when run on a computer, causes the computer to perform the method of any of claims 1-11.

Description

Event processing method and related equipment Technical Field The present application relates to the field of computer technologies, and in particular, to an event processing method and related devices. Background The event bus (EventBridge) is generally applied to a cloud computing scene, is a server-free event bus service provided by an industry cloud manufacturer, can decouple massive event source access from event consumption, solves the problems of no standard, difficult acquisition, information island and weak response of service events, and helps the service to quickly construct a distributed event driven architecture. At present, when an event bus is created in the event bus using process, filtering and delivering of event messages can be achieved through a filtering rule of self-defined event message content, but in the mode, filtering based on the event message content is only supported, and when certain related content is missing in the current event message, event filtering requirements under specific service requirements cannot be met. Disclosure of Invention The embodiment of the application provides an event processing method and related equipment, which can provide a mechanism of additional conditions, realize the filtering of events based on states except for the content of event messages, improve the filtering accuracy of the events and solve the special expansion requirements of services. In a first aspect, an embodiment of the present application provides an event processing method, where the event processing method includes that an event bus platform obtains first information and second information, where the first information includes information of a first event, and the second information includes status information associated with the first event, and when the event bus platform determines that the first information meets a first condition, the event bus platform sends a first message to a terminal device, where the first message is used to indicate that the first information meets the first condition, and the second information meets a second condition. Wherein the first event may be an event generated by an event source, the first information may be an event message as described in the following embodiments, and the second information may be status information other than the content of the event message, such as other status that the event source does not provide within the event message, a status of a surrounding environment unrelated to the event source, and the like. By implementing the method provided in the first aspect, the event bus platform can support the judging capability of the additional condition, so that the event message and the service state can be combined, and in the case that both meet a certain condition, the event can be delivered to the event consumer, for example, the alarm event is delivered, so that the fault processing can be responded immediately. In one possible implementation, the first event is a fluctuating event of CPU utilization of the central processing unit, and the first information includes information of CPU utilization. In this way, the event bus platform can monitor the service health condition of the CPU usage rate when the fluctuation occurs by monitoring the fluctuation event of the CPU usage rate of the service environment and according to the event filtering rule. In one possible implementation manner, the second information comprises any one or more of information of service success rate and information of memory utilization rate. In this way, the event bus platform may support the judgment capability of one or more additional conditions, so that CPU events (e.g., fluctuating events of CPU utilization), service states (e.g., service success rates), memory information (e.g., memory utilization) may be combined, and in the event that the CPU, service states, and/or memory all meet certain conditions, an alert event may be sent to an event consumer, so that fault handling may be responded to immediately. In one possible implementation, the second condition includes at least two sub-conditions, the second condition being generated by combining and orchestrating the at least two sub-conditions on a first user interface, the first user interface being a user interface provided by the event bus platform. Wherein the first user interface may be the user interface exemplarily shown in fig. 10 in the following embodiments. Therefore, the event bus platform can support the combination and arrangement of a plurality of additional conditions through the user interface, so that the filling of condition parameters and the generation of additional condition flow data definition can be automatically completed, the applicability of the additional conditions and the possibility of combination and arrangement of complex additional conditions are improved, the combination and arrangement process of the plurality of additional conditions is simplified, an