CN-121979629-A - Event processing method and device based on digital staff and electronic equipment

Abstract

The disclosure provides an event processing method, an event processing device and electronic equipment based on digital staff, which relate to the technical field of computers, in particular to the technical fields of artificial intelligence, large models and the like, and comprise the steps of sensing an event by the digital staff and caching the sensed event in a cache queue; the method comprises the steps of receiving a target event in a buffer queue, reading the candidate event in the buffer queue through an event processor, enabling the candidate event to comprise the sensing event, calling a target processing unit associated with the candidate event, wherein the target processing unit comprises at least one of a target agent and a target service associated with the candidate event, and processing the candidate event through the target processing unit to obtain a processing result corresponding to the candidate event.

Inventors

• Lai Lushuang
• LI AIKUN
• LUO JINCHANG

Assignees

• 北京百度网讯科技有限公司

Dates

Publication Date

20260505

Application Date

20251217

Claims (17)

1. 1. A method of event processing based on digital staff, wherein the method comprises: Sensing the event by a digital employee, and caching the sensing event in a cache queue; reading candidate events in the cache queue through an event processor, wherein the candidate events comprise the perception events; Invoking a target processing unit associated with the candidate event, wherein the target processing unit comprises at least one of a target agent and a target service associated with the candidate event; and processing the candidate event through the target processing unit to obtain a processing result corresponding to the candidate event.
2. 2. The method of claim 1, wherein the invoking the target event handling unit associated with the candidate event comprises: querying, by the event processor, a corresponding event consumption task according to the digital employee and the candidate event; And determining a target processing unit corresponding to the candidate event according to the event consumption task.
3. 3. The method of claim 2, wherein the determining, according to the event consuming task, a target processing unit corresponding to the candidate event includes: Determining aggregation indicating information and event processing flow of the candidate event according to the event consumption task; According to the aggregation indication information, carrying out aggregation treatment on the candidate events to obtain aggregation events; And determining a target processing unit corresponding to the aggregation event according to the event processing flow.
4. 4. The method of claim 3, wherein the aggregating the candidate events according to the aggregation indication information to obtain an aggregate event comprises: Determining an aggregation policy of the candidate event according to the aggregation indication information, wherein the aggregation policy at least comprises an aggregation condition and an aggregation occasion; And carrying out aggregation treatment on the candidate events according to the aggregation conditions and the aggregation time to obtain the aggregation event.
5. 5. The method of claim 3, wherein the determining, according to the event processing procedure, a target processing unit corresponding to the aggregate event includes: decomposing according to the event processing flow to obtain a plurality of sub-flows; determining the corresponding intelligent agent and/or service of each of the plurality of sub-processes; And carrying out logic association on the intelligent agents and/or services corresponding to the multiple sub-processes based on the dependency relationship among the multiple sub-processes to obtain the target processing unit.
6. 6. The method of claim 1, wherein the reading, by an event processor, the candidate event in the cache queue comprises: determining the identification of the event processor, and acquiring a queue identification associated with the identification of the event processor; Determining the queue identification as the identified cache queue, which is the target cache queue associated with the event processor; And reading the candidate event from the target cache queue.
7. 7. The method of any of claims 1-6, wherein the caching the perceived event in a cache queue comprises: filtering the perceived event perceived by the digital staff to obtain an event to be processed; And determining the event to be processed as the candidate event, and caching the candidate event in the cache queue.
8. 8. The method of claim 7, wherein filtering the perceived events perceived by the digital employee to obtain pending events comprises: data filtering and cleaning are carried out on the sensing events to obtain first sensing events; Performing format conversion on the first perception event to obtain a second perception event; And carrying out authority verification on the second perception event to obtain a third perception event passing the authority verification, wherein the third perception event is used as the event to be processed.
9. 9. The method of claim 8, wherein the filtering the perceived event to obtain a pending event comprises: acquiring an event filtering task of the digital employee from a task database; and filtering the perceived event perceived by the digital staff according to the event filtering task to obtain the event to be processed.
10. 10. The method of any of claims 1-6, wherein the caching the perceived event in a cache queue comprises: determining an event type of the perceived event; Determining a cache queue to which the perceived event belongs according to the event type; And caching the perceived event in a cache queue to which the perceived event belongs.
11. 11. The method according to any one of claims 1-6, wherein after the processing, by the target processing unit, the event, a processing result corresponding to the event is obtained, further includes: Determining the processing process of the event and/or event processing states of different nodes in the processing process; and generating a processing log of the event according to the processing process and/or the event processing state of the event, and storing the processing log of the event.
12. 12. The method of any of claims 1-6, wherein the sensing of events by digital staff comprises: receiving front-end configuration operation; performing perception capability configuration on the digital staff according to the front-end configuration operation; and sensing events triggered by different data sources based on the configured sensing capability of the digital staff.
13. 13. The method of any of claims 1-6, wherein the method further comprises: receiving front-end task management operation; and updating the tasks related to the event perception of the digital staff according to the front-end task management operation.
14. 14. An event processing apparatus based on digital staff, wherein the apparatus comprises: the perception module is used for perceiving the event through the digital staff and caching the perceived event in the cache queue; The reading module is used for reading candidate events in the cache queue through an event processor, wherein the candidate events comprise the perception events; a calling module, configured to call a target processing unit associated with the candidate event, where the target processing unit includes at least one of a target agent and a target service associated with the candidate event; and the processing module is used for processing the candidate event through the target processing unit to obtain a processing result corresponding to the candidate event.
15. 15. An electronic device comprising a processor and a memory; wherein the processor runs a program corresponding to executable program code stored in the memory by reading the executable program code for implementing the method according to any one of claims 1-13.
16. 16. A computer readable storage medium, on which a computer program is stored, characterized in that the program, when being executed by a processor, implements the method according to any one of claims 1-13.
17. 17. A computer program product comprising a computer program which, when executed by a processor, implements the method according to any of claims 1-13.

Description

Event processing method and device based on digital staff and electronic equipment Technical Field The disclosure relates to the technical field of computers, in particular to the technical fields of artificial intelligence, large models and the like, and particularly relates to an event processing method, an event processing device and electronic equipment based on digital staff. Background The digital staff is in butt joint with a plurality of data sources at present, each data source has the respective attributes of format, authentication, issuing range and the like, hope that the digital staff can actively and flexibly use various data to complete event processing, realize the functions of various scenes, and the data sources of all the systems are scattered in the respective systems at present and cannot be communicated and cannot be perceived. Disclosure of Invention The present disclosure proposes a method, apparatus, electronic device, storage medium and computer program product for event processing based on digital staff. According to a first aspect of the disclosure, an event processing method based on digital staff is provided, which comprises the steps of sensing an event by the digital staff and caching the sensed event in a cache queue, reading a candidate event in the cache queue by an event processor, wherein the candidate event comprises the sensed event, calling a target processing unit associated with the candidate event, wherein the target processing unit comprises at least one of a target agent and a target service associated with the candidate event, and processing the candidate event by the target processing unit to obtain a processing result corresponding to the candidate event. According to a second aspect of the present disclosure, an event processing device based on a digital employee is provided, which includes a sensing module, a reading module, a calling module, and a processing module, wherein the sensing module is used for sensing an event by the digital employee and caching the sensed event in a cache queue, the reading module is used for reading a candidate event in the cache queue through an event processor, the candidate event includes the sensed event, the calling module is used for calling a target processing unit associated with the candidate event, the target processing unit includes at least one of a target agent and a target service associated with the candidate event, and the processing module is used for processing the candidate event through the target processing unit to obtain a processing result corresponding to the candidate event. According to a third aspect of the present disclosure, an electronic device is provided, comprising at least one processor, and a memory communicatively coupled to the at least one processor, wherein the memory stores instructions executable by the at least one processor, the instructions being executable by the at least one processor to enable the at least one processor to perform the digital employee-based event processing method set forth in the first aspect above. According to a fourth aspect of the present disclosure, a non-transitory computer-readable storage medium storing computer instructions for causing the computer to execute the event processing method based on digital staff as set forth in the first aspect above is provided. According to a fifth aspect of the present disclosure, a computer program product is presented, comprising a computer program which, when executed by a processor, implements the digital employee based event processing method presented in the first aspect above. It should be understood that the description in this section is not intended to identify key or critical features of the embodiments of the disclosure, nor is it intended to be used to limit the scope of the disclosure. Other features of the present disclosure will become apparent from the following specification. Drawings The drawings are for a better understanding of the present solution and are not to be construed as limiting the present disclosure. Wherein: FIG. 1 is a flow chart of a method for digital employee-based event processing according to an embodiment of the present disclosure; FIG. 2 is a flow chart of a method of event processing based on digital employee according to an embodiment of the present disclosure; FIG. 3 is a flow chart of a method of digital employee-based event processing according to an embodiment of the present disclosure; FIG. 4 is a flow chart of a method of digital employee-based event processing according to an embodiment of the present disclosure; FIG. 5 is a schematic diagram of an event processing device based on digital staff according to an embodiment of the disclosure; fig. 6 is a schematic block diagram of an electronic device of an embodiment of the present disclosure. Detailed Description Exemplary embodiments of the present disclosure are described below in conjunction with the accompanying drawing