SYSTEMS AND METHODS FOR MESSAGING AND PROCESSING HIGH VOLUME DATA OVER NETWORKS

摘要

Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for providing partial views of event streams over a network. A subscription manager receives subscription data from a client device. A messaging interface module receives an event stream comprising event messages. A normalizer converts the received event stream to a table of entries. The entries correspond to respective event messages. A view processor selects a portion of the converted first event stream based at least on the entries of the selected portion of the event stream matching the subscription data. The view processor provides the selected portion of the converted event stream for transmission as session data to the subscriber.

主权项

1. A system comprising:
a subscription manager module configured to receive subscription data from a client device, the subscription data comprising an event stream identifier to identify an event stream and at least one attribute to select events from the event stream; a messaging interface module configured to receive a first event stream comprising event messages, the first event stream matching the event stream identifier; a normalizer module configured to convert the received first event stream to a table of entries, the entries corresponding to respective event messages; and a view processor engine configured to select a portion of the converted first event stream based at least on the entries of the selected portion of the event stream matching the at least on attribute, the view processor engine being configured to provide the selected portion of the converted event stream for transmission as session data to the client device.