Differential processing of data streams based on protocols
摘要
說明書
At block 1305, streaming data is received from each of one or more data sources. Each data source may correspond to, for example, a different institution, device, or piece of equipment. The streaming data may include a continuous data stream and/or intermittent data transmissions sent over an established connection.
At block 1310, a data-agnostic report protocol is identified that applies to the one or more data streams. The report protocol may include one with an applicability condition (e.g., identifying one or more data sources, geographic regions, composite values, metadata values and/or time periods) that is satisfied with respect to each of the one or more data streams. It will be appreciated that, in some instances, whether a report protocol is applicable can be determined on a stream- or source-specific instance. In some instances, an applicability depends on data within individual data elements in a stream (e.g., such that a report protocol may apply to some but not all data elements in a stream).
The report protocol may be data agnostic, such that conditions (e.g., data-extraction conditions) may be evaluated and/or report parameters may be determined irrespective of a structure type (e.g., unstructured, semi-structured or having one of a plurality of structures), formats, standards or protocols corresponding to a data stream. In some instances, such general applicability may be available so long as incoming data complies with an industry standard. Such extended applicability may be facilitated via transformation engines (e.g., transformative integration engines), definitions of schemas, standards or format, and/or data-model structures.
