Real-time business event analysis and monitoring

Patent metadata

Field	Value
Publication number	US-11093505-B2
Application number	US-201313830378-A
Country	US
Kind code	B2
Filing date	Mar 14, 2013
Priority date	Sep 28, 2012
Publication date	Aug 17, 2021
Grant date	Aug 17, 2021

Abstract

Techniques for managing real-time business event analysis and monitoring are provided. In some examples, a logical request may be received at a business intelligence server configured with a continuous query service. Additionally, the continuous query service may be configured to translate the logical request into a physical request. Further, business intelligence information may be provided based at least in part on querying against an event data stream with a continuous query configured based at least in part on the physical request translated by the continuous query service.

First claim

What is claimed is:

1. A system, comprising:
a memory storing a plurality of instructions; and
one or more processors configured to access the memory, wherein the one or more processors are further configured to execute the plurality of instructions to at least:
receive, at a business intelligence server configured with a continuous query service, a request from a user in a natural language form, the request identifying an alert to be provided in response to identification of a business event pattern over time that predicts a risk metric, the risk metric associated with a key performance indicator of a plurality of key performance indicators identified in the request, the business event pattern over time corresponding to a change over time in a business event driving metric that measures business event data, the change over time predicting, based at least in part on a regression of outcomes to the business event data, the risk metric, the request further configuring a percentage range function for the key performance indicator, and the request further configuring range boundaries and the alert for the percentage range function for the key performance indicator;
translate, by the continuous query service, the request that is in the natural language form into a continuous query for at least the key performance indicator;
generate a relation based at least in part on a stream of the business event data that includes the business event pattern over time;
query the relation using the continuous query to receive data corresponding to the business event pattern over time and the key performance indicator associated with the business event data;
provide the data corresponding to the business event pattern over time and the key performance indicator to an event sink of the business intelligence server;
enable output events of the continuous query, from the event sink, to be stored in a plurality of output tables, each output table of the plurality of output tables corresponding to a respective key performance indicator watch list user interface (UI) of a plurality of key performance indicator watch list user interfaces (UIs), each respective key performance indicator watch list UI configured to display real-time data of each respective key performance indicator;
map each of the plurality of key performance indicator watch UIs to multiples of the plurality of key performance indicators;
for each output event of the continuous query:
determine affected key performance indicators;
identify, based at least in part on the mapping, respective key performance indicator watch list UIs to be updated with the real-time data; and
update an entry in each corresponding output table of the plurality of output tables;

generate the alert, for a particular key performance indicator watch list UI, according to the updated entry in the corresponding output table being over a threshold corresponding to the affected key performance indicators;
provide business intelligence information associated with the business event pattern over time from the event sink to a client device for presentation as part of the alert in a risk dashboard UI comprising a visualization of at least the particular key performance indicator watch list UI; and
update the particular key performance indicator watch list UI in the risk dashboard UI based at least in part on subsequent output events of the continuous query.

2. The system of claim 1 , wherein the one or more processors are further configured to execute the plurality of instructions to at least implement a continuous query engine as part of the continuous query service.

3. The system of claim 2 , wherein the continuous query engine is configured to receive the business event data of the event data stream from the business intelligence server.

4. The system of claim 1 , wherein the business intelligence server is configured to manage the business intelligence information associated with the user.

5. The system of claim 4 , wherein the business intelligence information includes at least one of a result of the continuous query or the alert configured to identify the result of the continuous query.

6. The system of claim 1 , wherein the risk dashboard user interface comprises a graphical user interface displaying a trend line of real-time measurements of the key performance indicator corresponding to the data and based at least in part on the continuous query, the continuous query comprising a real-time continuous query.

7. The system of claim 1 , wherein the request includes at least a tactical query generated based at least in part on a request from the user for the business intelligence information.

8. The system of claim 7 , wherein the tactical query is received by the continuous query service from a logical business model of the business intelligence server.

9. The system of claim 1 , wherein the one or more processors are further configured to execute the plurality of instructions to:
identify a second metric based at least in part on the risk metric associated with the key performance indicator; and
receive data associated with the second metric based at least in part on a second query.

10. The system of claim 9 , wherein:
the second metric includes information quantifying the risk metric and affecting the key performance indicator; and
the one or more processors are further configured to execute the plurality of instructions to listen to output events of a pre-existing query for monitoring the stream.

11. The system of claim 1 , wherein a report cache:
runs the continuous query for the key performance indicator;
listens to output of the continuous query for the key performance indicator; and
maintains a Coherence data table comprising key performance indicator information, the Coherence data table serving as a data model for a watch list view of the risk dashboard user interface.

12. The system of claim 11 :
wherein an association between the key performance indicator and the watch list is maintained in a map; and
wherein, responsive to a new continuous query event associated with the key performance indicator, the report cache looks up the map to determine whether the watch list is affected; and
wherein, responsive to the watch list being affected, the report cache updates the Coherence data table and generates a change list event for the watch list.

13. A non-transitory computer-readable memory storing a plurality of instructions executable by one or more processors, the plurality of instructions comprising:
instructions that cause the one or more processors to receive, by a continuous query service, a tactical query from a business intelligence server, the tactical query configured based at least in part on a request from a user in a natural language form, the request identifying an alert to be provided in response to identification of a pattern over time in business event data that predicts a risk metric, the risk metric associated with a key performance indicator of a plurality of key performance indicators identified in the request, the request further configuring a percentage range function for the key performance indicator, and the request further configuring range boundaries and the alert for the percentage range function for the key performance indicator;
instructions that cause the one or more processors to generate, by the continuous query service, a continuous query for at least the key performance indicator configured to query against a stream of the business event data for at least the key performance indicator, the continuous query based at least in part on the tactical query and translated from the natu

Assignees

• Oracle Int Corp

Inventors

• Park Hoyong
• Srinivasan Anand
• Bolsius Roger
• Hsiao Eric
• Toillion Jeffrey
• Shukla Vikram

Classifications

• B29D30/0681 Primary

  Parts of pneumatic tyres; accessories, auxiliary operations · CPC title

• G06F16/2456

  Join operations · CPC title

• G06F16/2455

  Query execution · CPC title

• G06F16/248

  Presentation of query results · CPC title

• G06F16/951

  Indexing; Web crawling techniques · CPC title