Method and system that streams real-time, processed data from remote processor-controlled appliances

Patent metadata

Field	Value
Publication number	US-9961025-B2
Application number	US-201313868269-A
Country	US
Kind code	B2
Filing date	Apr 23, 2013
Priority date	Apr 30, 2012
Publication date	May 1, 2018
Grant date	May 1, 2018

Abstract

The current document is directed to systems and methods that stream real-time, processed data from remote processor-controlled user appliances, including personal computers, tablets, mobile phones, and laptops, to application programs for display, analysis, and other purposes and to other data-consuming devices and systems. In one implementation, a real-time processed-data streaming system includes instrumentation within remote, processor-controlled user devices, data collection at geographically distributed data-collection centers, consolidation of event messages generated by the geographically distributed data-collection centers within consolidation systems, processing of the consolidated event messages within one or more processing centers, and streaming of processed data, in the form of various types of processed-data-containing messages, to consumers of the data, including application programs that render the data for display on electronic display devices.

First claim

The invention claimed is:

1. A system for generating data streams representing characteristic of user interactions, the system comprising:
a data-collection system, comprising one or more first processors and one or more first memories, the one or more first memories containing first instructions which when executed on the one or more first processors, cause the one or more first processors to perform first actions including:
receiving, by the data-collection system, a set of event messages from one or more user devices, each event message of the set of event messages including a uniform resource locator (URL) and having been generated at least in part by execution of instrumentation by the one or more user devices, the instrumentation including a monitoring script having been inserted into a code underlying an operation of an application comprising one of a webpage, software application or control program, wherein execution of the instrumentation is configured to:
detect a current time associated with a current instance of user interaction with an application;
detect a previous time associated with a previous instance of user interaction with the application;
determine that a difference between the current time and the previous time exceeds a threshold;
upon determining that the difference between the current time and the previous time exceeds a threshold sending an interrupt to an operating system of the one or more user devices to trigger execution of the monitoring script, the monitoring script configured to record data representing the current instances of user interaction;
encode the data representing the current instance of user interaction into a URL, the data including one or more interaction key/value pairs, each interaction key/value pair of the one or more interaction key/value pairs including an interaction value representing a characteristic of the current instances of user interaction; and
request that a browser retrieve a remote resource specified by the URL via transmitting the URL;

generating, by the data-collection system, a set of events by, for each event message of the set of event messages:
extracting one or more interaction key/value pairs from the URL;
defining an event of the set of events to include the one or more interaction key/value pairs; and
encoding each event of the set of events in a binary object notation, the binary object notation is configured to serialize each event of the set of events prior to transmission;

transmitting the set of events to a consolidation system;

the consolidation system, comprising one or more second processors and one or more second memories, the one or more second memories containing second instructions which when executed on the one or more second processors, cause the one or more second processors to perform second actions including:
receiving, by the consolidation system, the set of events encoded in the binary object notation;
buffering, by the consolidation system, the set of events at a temporary storage for up to a specified duration of time;
detecting, by the consolidation system, a request for event data;
in response to the request, transmitting, by the consolidation system, the set of events to a processing center;

a processing center, comprising one or more third processors and one or more third memories, the one or more third memories containing third instructions which when executed on the one or more third processors, cause the one or more third processors to perform third actions including:
generating, by the processing center, a set of enriched events by, for each event of the set of events:
identifying, by the processing center, a new value based on a calculation or extraction using the event; and
defining, by the processing center, an enriched event of the set of enriched events to include at least one of one or more interaction key/value pairs in the event and the new value;

performing, by the processing center, for each enriched event in the set of enriched events, a query-based filtering of the enriched events such that each value of the one or more interaction values and the new value included in a resultant filtered event corresponds to one or more event constraints associated with a client; and
transmitting, by the processing center, the filtered events in a data stream to a data consumer.

2. The system for generating data streams representing characteristics of user interactions of claim 1 , wherein the data-collection system includes a plurality of independent devices, each device of the plurality of independent devices include at least one processor of the one or more first processors and at least one memory of the one or more first memories, the at least one memory containing the first instructions which when executed on the at least one processor, cause the at least one processor to perform the first actions.

3. The system for generating data streams representing characteristics of user interactions of claim 1 , wherein, for each enriched event in the set of enriched events, a delay variable indicates a first time at which corresponding data was encoded by the data-collection system and a second time at which the enriched event was transmitted in the data stream to the data consumer, and wherein an average of the delay variables across the set of enriched events is less than 2.0 seconds.

4. The system for generating data streams representing characteristics of user interactions of claim 1 , wherein for each enriched event in the set of enriched events, a delay variable indicates a first time at which corresponding data was encoded by the data-collection system and a second time at which the enriched event was transmitted in the data stream to the data consumer, and wherein an average of the delay variables across the set of enriched events is less than 1.0 seconds.

5. The system for generating data streams representing characteristics of user interactions of claim 1 , wherein, for each interaction key/value pair of the one or more interaction key/value pairs encoded into the URL, the interaction key/value pair includes:
a key composed of a symbol string having one or more symbols; and
a value composed of a symbol string having one or more symbols.

6. The system for generating data streams representing characteristics of user interactions of claim 1 , wherein each event message of the set of event messages includes unstructured data including corresponding one or more interaction key/value pairs, and wherein the generating the set of enriched events includes applying a schema-based encoding.

7. The system for generating data streams representing characteristics of user interactions of claim 1 , wherein the code underlying the operation of a webpage or software application into which the monitoring script is inserted includes one or more of:
executable application-program instructions that encode an application program; and
one or more HTML files.

8. The system for generating data streams representing characteristics of user interactions of claim 1 , wherein the data-collection system receives the set of event messages from the one or more use devices via the Internet.

9. The system for generating data streams representing characteristics of user interactions of claim 1 , wherein each event message of the set of event messages includes:
a meta object that includes one or more meta key/value pairs; and
a data object that includes one or more interaction key/value pairs, each interaction key/value pair of the one or more interaction key/value pairs including an interaction value representing a characteristic of a user interaction.

10. The system for generating data streams representing characte

Assignees

• Oracle America Inc

Inventors

• Butler Eric
• Psaltis Andrew
• Mcnamara Sean

Classifications

• G06Q30/0201

  Market modelling; Market analysis; Collecting market data · CPC title

• H04L12/1859 Primary

  adapted to provide push services, e.g. data channels · CPC title

• H04L67/2885

  Hierarchically arranged intermediate devices, e.g. for hierarchical caching · CPC title

• H04L51/04 Primary

  Real-time or near real-time messaging, e.g. instant messaging [IM] · CPC title

• H04L67/2838

  Electricity · mapped topic