METHOD AND APPARATUS FOR PROCESSING ACTIVE DATA FOR INTERNET OF THINGS DEVICE, AND STORAGE MEDIUM

WIPO Patent Application WO/2023/109806

A1

A method and apparatus for processing active data for an Internet of things device, and a storage medium. The method comprises: obtaining a device reporting message, and pushing the device reporting message to a distributed message queue, the device reporting message comprising a message type (S100); constructing, on the basis of a stream computing service, a data stream of the device reporting message in the message queue (S110); cleaning the data stream according to the message type to obtain a data stream only comprising device active data (S120); processing device active data in a cache according to the data stream (S130); processing device active data in Hbase according to the device active data in the cache (S140); and performing batch processing on the device active data in the HBase on the basis of a batch processing service to obtain active basic statistical data and storing same into a database (S150). In the method, high concurrency requirements generated by mass device data are satisfied by means of a stream processing service; the cache is introduced as a buffer, thereby reducing data interaction with HBase, and improving data processing performance.

JIA SHUIQIN (CN)
ZHU MING (CN)
REN YONGQIANG (CN)
DING XIA (CN)
WANG SHIJIE (CN)

PCT/CN2022/138668

June 22, 2023

December 13, 2022

Click for automatic bibliography generation  

E SURFING IOT CO LTD (CN)

G06F16/215; G06F9/54; G06F16/2453; G06F16/2455

CN114385378A	2022-04-22
CN109800129A	2019-05-24
CN109753531A	2019-05-14
CN110704484A	2020-01-17
CN106873945A	2017-06-20
US20170075693A1	2017-03-16
US20190303487A1	2019-10-03

JIAQUAN IP LAW (CN)

View/Download PDF      PDF Help

Previous Patent: OPTICAL FIBER AMPLIFIER AND METHOD FOR AMPLIFYING OPTICAL SIGNAL

Next Patent: REFRIGERATION UNIT AND REFRIGERATION APPARATUS PROVIDED WITH SAME