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 circuitry configured to:
receive, from a first client entity, a first request for creating a data stream query resource in the ROA via RESTful methods;
authorize, based on the first request, the first client entity by referring to one or more access control policies;
create, based on authorizing the first client entity, the data stream query resource having a plurality of attributes, the data stream query resource comprising one or more data stream IDs;
send, based on the first request and to the first client entity, a query response;
receive, from a second client entity, a second request to access the data stream query resource;
authorize, based on the second request, the second client entity to access the data stream query resource by referring to one or more access control policies;
generate, based on authorizing the second client entity, a query output from the data stream query resource based on one or more query parameters; and
send, to the second client entity, the query output.
2 . The apparatus of claim 1 , wherein the service 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 data stream query resource further comprises a query output format and a query switch for enabling/disabling.
5 . The apparatus of claim 1 , wherein the one or more query parameters further indicate output format.
6 . The apparatus of claim 1 , wherein the one or more query parameters further indicate maximum error tolerance.
7 . The apparatus of claim 1 , wherein the apparatus comprises a service layer component.
8 . The apparatus of claim 1 , wherein the first client entity comprises an Internet of Things (IoT) device.
9 . The apparatus of claim 1 , wherein the first client entity and the second client entity are different.
10 . The apparatus of claim 1 , wherein the second request to access the data stream query resource comprises raw data, and wherein the circuitry is configured to generate the query output based on the raw data.
11 . 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, based on the first request, the first client entity by referring to one or more access control policies;
creating, based on authorizing the first client entity, the data stream query resource having a plurality of attributes, the data stream query resource comprising one or more data stream IDs;
sending, based on the first request and to the first client entity, a query response;
receiving, from a second client entity, a second request to access the data stream query resource;
authorizing, based on the second request, the second client entity to access the data stream query resource by referring to one or more access control policies;
generating, based on authorizing the second client entity, a query output from the data stream query resource based on one or more query parameters; and
sending, to the second client entity, the query output.
12 . The method of claim 11 , wherein the service is provided as a middleware service between network protocol stacks and applications.
13 . The method of claim 12 , wherein the service is a oneM2M service layer.
14 . The method of claim 11 , wherein the first client entity comprises an Internet of Things (IoT) device.
15 . The method of claim 11 , wherein the data stream query resource further comprises a query output format and a query switch for enabling/disabling.
16 . The method of claim 11 , wherein the one or more query parameters further indicate output format.
17 . The method of claim 11 , wherein the one or more query parameters further indicate maximum error tolerance.
18 . The method of claim 11 , wherein the first client entity and the second client entity are different.
19 . The method of claim 11 , wherein the second request to access the data stream query resource comprises raw data, and wherein the method comprises generating the query output based on the raw data.