Data stream analytics at service layer
A modular and distributed architecture for data stream processing and analysis is described to incorporate data stream analytics capabilities, called Data Stream Analytics Service (DSAS) in the IoT/M2M service layer. Each service layer node hosting DSAS can be split into two independent modules, Stream Forwarder and Stream Analytics Engine. Stream Forwarder is a light weight processing modules that can be responsible for data preprocessing and routing. Stream Analytics Engine is responsible for performing actual analytics on the data stream. Separating the two functionalities enables the service layer nodes to efficiently distribute stream analytics tasks across multiple nodes.
1. An apparatus for a service supporting service capabilities in a Resource-Oriented Architecture (ROA) through a set of Application Programming Interfaces (APIs), the apparatus comprising a processor, a memory and communication circuitry, the apparatus further comprising computer-executable instructions stored in the memory of the apparatus which, when executed by the processor of the apparatus, cause the apparatus to perform operations comprising:
receiving, from a first client entity, a first request for creating a data stream query resource in the ROA via RESTful methods;
authorizing the first client entity based on the first request by referring to one or more access control policies;
creating the data stream query resource having a plurality of attributes, the data stream query resource comprising one or more data stream IDs and query time window;
assigning a query ID to the created data stream query resource;
sending, to the first client entity, a query response upon assigning the query ID;
receiving, from a second client entity, a second request for providing data stream analytics, wherein the second request comprises one or more query parameters comprising one or more parameters indicating a window length;
authorizing the second client entity for accessing the data stream query resource based on the second request by referring to one or more access control policies;
generating a query output from the data stream query resource based on the query parameters;
sending, to the second client entity, the query output.
2. The apparatus of claim 1 , wherein the service layer is provided as a middleware service between network protocol stacks and applications.
3. The apparatus of claim 2 , wherein the service is a oneM2M service layer.
4. The apparatus of claim 1 , wherein the apparatus comprises a service layer component.
5. The apparatus of claim 1 , wherein the first client entity comprises an Internet of Things (IoT) device.
6. The apparatus of claim 1 , wherein the data stream query resource further comprises a query output format and a query switch for enabling/disabling.
7. The apparatus of claim 1 , wherein the query parameters further indicate output format.
8. The apparatus of claim 7 , wherein the query parameters further indicate maximum error tolerance.
9. A method for a service supporting service capabilities in a Resource-Oriented Architecture (ROA) through a set of Application Programming Interfaces (APIs), the method comprising:
receiving, from a first client entity, a first request for creating a data stream query resource in the ROA via RESTful methods;
authorizing the first client entity based on the first request by referring to one or more access control policies;
creating the data stream query resource having a plurality of attributes, the data stream query resource comprising one or more data stream IDs and query time window;
assigning a query ID to the created data stream query resource;
sending, to the first client entity, a query response upon assigning the query ID;
receiving, from a second client entity, a second request for providing data stream analytics, wherein the second request comprises one or more query parameters comprising one or more parameters indicating a window length;
authorizing the second client entity for accessing the data stream query resource based on the second request by referring to one or more access control policies;
generating a query output from the data stream query resource based on the query parameters;
sending, to the second client entity, the query output.
10. The method of claim 9 , wherein the service layer is provided as a middleware service between network protocol stacks and applications.
11. The method of claim 10 , wherein the service is a oneM2M service layer.
12. The method of claim 9 , wherein the first client entity comprises an Internet of Things (IoT) device.
13. The method of claim 9 , wherein the data stream query resource further comprises a query output format and a query switch for enabling/disabling.
14. The method of claim 9 , wherein the query parameters further indicate output format.
15. The method of claim 14 , wherein the query parameters further indicate maximum error tolerance.