Edge intelligence platform, and internet of things sensor streams system
First Claim
1. A method comprising:
- receiving a sensor data stream from a first physical sensor over a first network connection type at a data ingestion agent of an edge platform system;
from the data ingestion agent delivering the ingested stream data to a data bus of the edge platform system;
enriching the ingested stream data in real time through a data enrichment component of the edge platform system by performing an enrichment action on the ingested stream data, wherein the enrichment action comprises one or more of decoding the ingested stream data, supplementing the ingested stream data with metadata, and normalizing the ingested stream data;
making the enriched ingested stream data available on the data bus;
processing the enriched ingested stream data at an analytics engine of the edge platform system that is subscribing to data from the data bus, wherein the processing comprises applying to the enriched ingested stream data in real time a first function specified by selected analytic expressions of an expression language and generating in real time a stream of data comprising intelligence information, wherein the first function comprises at least one of a transform, pattern detection, dynamic calibration, signal processing, math expression, data compaction, data analytic, data aggregation, rule application, alert, and service invocation;
publishing the intelligence information on the data bus, wherein the publishing comprises storing the intelligence information on the edge platform system in a rolling time-series database indexed by time for use by applications executable on the edge platform system; and
determining based on the intelligence information whether to take selected action in the local network on a hardware device being monitored by the first physical sensor and whether to transmit at least a portion of the intelligence information to the remote network for additional processing, wherein the selected action comprises sending an alert to an operator on making a corrective action on a hardware device being monitored by the first physical sensor.
3 Assignments
0 Petitions
Accused Products
Abstract
A method for enabling intelligence at the edge. Features include: triggering by sensor data in a software layer hosted on either a gateway device or an embedded system. Software layer is connected to a local-area network. A repository of services, applications, and data processing engines is made accessible by the software layer. Matching the sensor data with semantic descriptions of occurrence of specific conditions through an expression language made available by the software layer. Automatic discovery of pattern events by continuously executing expressions. Intelligently composing services and applications across the gateway device and embedded systems across the network managed by the software layer for chaining applications and analytics expressions. Optimizing the layout of the applications and analytics based on resource availability. Monitoring the health of the software layer. Storing of raw sensor data or results of expressions in a local time-series database or cloud storage. Services and components can be containerized to ensure smooth running in any gateway environment.
76 Citations
33 Claims
-
1. A method comprising:
-
receiving a sensor data stream from a first physical sensor over a first network connection type at a data ingestion agent of an edge platform system; from the data ingestion agent delivering the ingested stream data to a data bus of the edge platform system; enriching the ingested stream data in real time through a data enrichment component of the edge platform system by performing an enrichment action on the ingested stream data, wherein the enrichment action comprises one or more of decoding the ingested stream data, supplementing the ingested stream data with metadata, and normalizing the ingested stream data; making the enriched ingested stream data available on the data bus; processing the enriched ingested stream data at an analytics engine of the edge platform system that is subscribing to data from the data bus, wherein the processing comprises applying to the enriched ingested stream data in real time a first function specified by selected analytic expressions of an expression language and generating in real time a stream of data comprising intelligence information, wherein the first function comprises at least one of a transform, pattern detection, dynamic calibration, signal processing, math expression, data compaction, data analytic, data aggregation, rule application, alert, and service invocation; publishing the intelligence information on the data bus, wherein the publishing comprises storing the intelligence information on the edge platform system in a rolling time-series database indexed by time for use by applications executable on the edge platform system; and determining based on the intelligence information whether to take selected action in the local network on a hardware device being monitored by the first physical sensor and whether to transmit at least a portion of the intelligence information to the remote network for additional processing, wherein the selected action comprises sending an alert to an operator on making a corrective action on a hardware device being monitored by the first physical sensor. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 18, 19)
-
-
13. A method for improving the processing of sensor data in a distributed network including a local network with a plurality of network devices and a plurality of physical sensors and a remote network comprising:
-
receiving a first data stream from a first physical sensor in the local network over a first network connection type at a data ingestion agent of an edge platform system connected to the local network between the first physical sensor and the remote network; from the data ingestion agent delivering the ingested first data stream to a data bus of the edge platform system; enriching the ingested first data stream in real time through a data enrichment component of the edge platform system and making the enriched ingested first data stream available on the data bus; processing the enriched ingested first data stream in real time at an analytics engine of the edge platform system that is subscribing to data from the data bus without first transmitting the first data stream to the remote network, wherein the processing comprises executing analytic expressions provided in an expression language to generate intelligence information from the enriched ingested first data stream; making the intelligence information available on the data bus; and determining based on the intelligence information whether to transmit at least a portion of the intelligence information to the remote network for additional processing and whether to take selected action in the local network with respect to an operation in the local network monitored by the first physical sensor without awaiting additional processing of the intelligence data at the remote network, wherein the selected action comprises at least one of generating an alert and altering the operation. - View Dependent Claims (14, 15, 16, 17, 20, 21)
-
-
22. A method for improving the processing of sensor data in a distributed network including a local network with a plurality of network devices and a plurality of physical sensors each generating a data stream on a topic, and a remote network comprising:
-
receiving a first data stream from a first physical sensor in the local network over a first network connection type at a data ingestion agent of an edge platform system connected to the local network between the first physical sensor and the remote network; from the data ingestion agent delivering the ingested first data stream to a data bus of the edge platform system; enriching the ingested first data stream in real time through a data enrichment component of the edge platform system and making the enriched ingested first data stream and information identifying the topic of the first data stream available on the data bus; storing on the edge platform system a plurality of sets of analytic expressions provided in an expression language, wherein each set of analytic expressions defines a function that may be carried out on the enriched ingested first data stream from the data bus; processing the enriched ingested stream data in real time at an analytics engine of the edge platform system that is subscribing to data from the data bus without first transmitting the stream data to the remote network, wherein the processing comprises automatically selecting based on the topic of the first data stream a first set of analytic expressions defining a first function from the plurality of sets of analytic expressions and executing the selected set of analytic expressions to generate intelligence information from the enriched ingested first data stream; making the intelligence information available on the data bus; and determining based on the intelligence information whether to transmit at least a portion of the intelligence information to the remote network for additional processing and whether to take selected action in the local network with respect to an operation in the local network monitored by the first physical sensor and involving a network device without awaiting additional processing of the intelligence data at the remote network, wherein the selected action comprises at least one of generating an alert and altering the operation. - View Dependent Claims (23, 24, 25, 26, 27, 28, 29, 30)
-
-
31. A method comprising:
- receiving a first stream data from a first physical sensor over a first network connection type at a data ingestion agent of an edge platform system;
from the data ingestion agent, delivering ingested first stream data to a data bus of the edge platform system;
enriching the ingested data in real time through a data enrichment component of the edge platform system and making the ingested data available on the data bus, wherein the enrichment action comprises one or more of decoding the ingested stream data, supplementing the ingested data with metadata, and normalizing the ingested stream data;
providing an analytics engine of the edge platform system, coupled to the data bus, wherein the analytics engine processes code provided in an expression language;
using the expression language, creating a first virtual sensor having a first input and a first output, wherein the first input is coupled to an output of the first physical sensor and the first output is a first function of the first input, and the first function is specified in the expression language, the first input of the first virtual sensor receives the first stream data from the first physical sensor, and the first output of the first virtual sensor outputs second stream data that comprises the first stream data operated on according to the first function, and the first function comprises at least one of a transform, pattern detection, dynamic calibration, signal processing, math expression, data compaction, data analytic, data aggregation, rule application, alert, and service invocation, and without having passed through and enriched by the data enrichment component, the second stream data is made available on the data bus; and
processing the ingested stream data from the first stream data of the first physical sensor and the second stream data of the first virtual sensor at the analytics engine that is subscribing to data from the data bus wherein the processing comprises executing analytic expressions provided in the expression language to generate intelligence information from the ingested stream data and second stream data; and
publishing the intelligence information from the ingested stream data of the first physical sensor and second stream data of the first virtual sensor on the data bus. - View Dependent Claims (32, 33)
- receiving a first stream data from a first physical sensor over a first network connection type at a data ingestion agent of an edge platform system;
Specification