# US 2021/0240719 A1 · Data stream analytics at service layer > Agents: this data is available as JSON from the patentgrep API and MCP server — see https://patentgrep.com/llms.txt - Number: US 2021/0240719 A1 - Document ID: US20210240719A1 - Status: Published application - Kind: A1 - Application number: 17/175,100 - Filed: 2021-02-12 - Published: 2021-08-05 - Earliest claimed: 2016-04-25 - Assignees: Convida Wireless, LLC - Applicants: Convida Wireless, LLC - Inventors: Sneha Aman SINGH; Xu LI; Quang LY; Gregory S. STERNBERG; Shamim Akbar RAHMAN; Chonggang WANG - Web page: https://patentgrep.com/patent/US20210240719A1 ## CPC - G06F 16/24568: {Data stream processing; Continuous queries} - G06F 16/00: Information retrieval; Database structures therefor; File system structures therefor - H04L 12/28: characterised by path configuration, e.g. LAN [Local Area Networks] or WAN [Wide Area Networks] (wireless communication networks H04W {; arrangements for dividing the transmission path H04W40/00}) - H04L 12/2823: {Reporting information sensed by appliance or service execution status of appliance services in a home automation network (device-related reporting H04L43/065; arrangements in telecontrol or telemetry systems for selectively calling a substation from a main station, in which substation desired apparatus is selected for applying a control signal thereto or for obtaining measured values therefrom H04Q9/00)} - H04L 43/04: Processing captured monitoring data, e.g. for logfile generation - H04L 43/18: Protocol analysers - H04L 67/12: specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks - H04W 4/70: Services for machine-to-machine communication [M2M] or machine type communication [MTC] - H04W 12/08: Access security - H04L 63/10: {for controlling access to devices or network resources} - H04L 63/1425: {Traffic logging, e.g. anomaly detection} - G06F: ELECTRIC DIGITAL DATA PROCESSING (computer systems based on specific computational models G06N) - H04L: TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION (arrangements common to telegraphic and telephonic communication H04M) - H04W: WIRELESS COMMUNICATION NETWORKS (broadcast communication H04H; communication systems using wireless links for non-selective communication, e.g. wireless extensions H04M1/72) ## Abstract 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. ## Claims ### Claim 1 An apparatus for a service layer 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 each of a plurality of data sources, a plurality of data streams; determining each unique data stream in the received plurality of data streams; filtering each unique data stream, to determine at least one attribute in each unique data stream for use in executing at least one predetermined query; causing execution of the at least one predetermined query on each filtered unique data stream; and sending output of the at least one predetermined query based on at least one predetermined trigger. ### Claim 2 (depends on 1) The apparatus of claim 1, wherein the service layer is provided as a middleware service between network protocol stacks and applications. ### Claim 3 (depends on 2) The apparatus of claim 2, wherein the service layer is a oneM2M service layer. ### Claim 4 (depends on 1) The apparatus of claim 1, wherein the filtering is based on one or more active queries. ### Claim 5 (depends on 4) The apparatus of claim 4, wherein the one or more active queries are received from a client device. ### Claim 6 (depends on 1) The apparatus of claim 1, wherein the apparatus comprises a service layer component. ### Claim 7 (depends on 1) The apparatus of claim 1, wherein at least one data source of the plurality of data sources comprises an Internet of Things (IoT) device. ### Claim 8 (depends on 1) The apparatus of claim 1, wherein each unique data stream is parsed prior to the filtering. ### Claim 9 (depends on 1) The apparatus of claim 1, wherein each unique data stream is preprocessed prior to the filtering to remove redundancy and noise. ### Claim 10 (depends on 1) The apparatus of claim 1, wherein the at least one attribute comprises at least one property in the each unique data stream. ### Claim 11 (depends on 10) The apparatus of claim 10, wherein the at least one property comprises at least one of: a timestamp, a latitude, a longitude, an altitude, and a speed. ### Claim 12 (depends on 1) The apparatus of claim 1, 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 further operations comprising: causing authentication of each of the plurality of data sources prior to the receiving. ### Claim 13 (depends on 1) The apparatus of claim 1, wherein each unique data stream is associated with an identifier. ### Claim 14 (depends on 4) The apparatus of claim 4, wherein each filtered unique data stream is analyzed using a query operator based on the one or more active queries. ### Claim 15 A method for a service layer comprising: receiving, from each of a plurality of data sources, a plurality of data streams; determining each unique data stream in the received plurality of data streams; filtering each unique data stream, to determine at least one attribute in each unique data stream for use in executing at least one predetermined query; causing execution of the at least one predetermined query on each filtered unique data stream; and sending output of the at least one predetermined query based on at least one predetermined trigger. ### Claim 16 (depends on 15) The method of claim 15, wherein the service layer is provided as a middleware service between network protocol stacks and applications. ### Claim 17 (depends on 16) The method of claim 16, wherein the service layer is a oneM2M service layer. ### Claim 18 (depends on 15) The method of claim 15, wherein at least one data source of the plurality of data sources comprises an Internet of Things (IoT) device. ### Claim 19 (depends on 15) The method of claim 15, wherein the at least one attribute comprises at least one property in the each unique data stream, and wherein the at least one property comprises at least one of: a timestamp, a latitude, a longitude, an altitude, and a speed. ### Claim 20 (depends on 15) The method of claim 15, further comprising: causing authentication of each of the plurality of data sources prior to the receiving. ### Claim 21 (depends on 15) The method of claim 15, wherein each unique data stream is associated with an identifier. ### Claim 22 (depends on 15) The method of claim 15, wherein the filtering is based on one or more active queries and wherein the one or more active queries are received from a client device. ### Claim 23 (depends on 22) The method of claim 22, wherein each filtered unique data stream is analyzed using a query operator based on the one or more active queries.