Dynamic asset monitoring and management using a continuous event processing platform

摘要

The disclosed architecture leverages realtime continuous event processing (CEP) to address using a general input interface framework to import a dynamic set of event types (e.g., assets), and using a declarative, expressive query model to implement monitoring and management tasks on an asset level. This is in contrast to looking separately at single values from static databases and/or realtime streams as is common conventionally. The architecture uses the CEP data model to model assets as realtime event types. Thus, queries can be formulated per asset and not just per single stream. The architecture uses the query capabilities of CEP to formulate asset management and monitoring tasks as standing, declarative queries, and uses the input interface of a CEP platform to correlate data from different data sources with different dynamic properties.

主权项

1. A realtime event processing system, comprising:
an access component configured to access heterogeneous data sources of event data that corresponds to assets represented by a composite of related static event data and realtime event data; a synchronization component configured to time synchronize the realtime event data and static event data of the assets, as obtained from the heterogeneous data sources; a realtime merge component configured to merge the synchronized realtime event data and static event data into a realtime event stream through one or more operators, to define the synchronized realtime event data and static event data into assets queriable as a single event type for continuous event processing to return multiple related asset items; and a microprocessor that executes computer-executable instructions associated with at least one of the access component, the synchronization component, or the merge component.