[go: up one dir, main page]

WO2018233006A1 - 一种基于场景信息的物联网数据智能过滤方法及系统 - Google Patents

一种基于场景信息的物联网数据智能过滤方法及系统 Download PDF

Info

Publication number
WO2018233006A1
WO2018233006A1 PCT/CN2017/099310 CN2017099310W WO2018233006A1 WO 2018233006 A1 WO2018233006 A1 WO 2018233006A1 CN 2017099310 W CN2017099310 W CN 2017099310W WO 2018233006 A1 WO2018233006 A1 WO 2018233006A1
Authority
WO
WIPO (PCT)
Prior art keywords
terminal device
data
aggregation unit
internet
filtering
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Ceased
Application number
PCT/CN2017/099310
Other languages
English (en)
French (fr)
Inventor
杜光东
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Shenzhen Shenglu IoT Communication Technology Co Ltd
Original Assignee
Shenzhen Shenglu IoT Communication Technology Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Shenzhen Shenglu IoT Communication Technology Co Ltd filed Critical Shenzhen Shenglu IoT Communication Technology Co Ltd
Publication of WO2018233006A1 publication Critical patent/WO2018233006A1/zh
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Images

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/50Network services
    • H04L67/56Provisioning of proxy services
    • H04L67/565Conversion or adaptation of application format or content
    • H04L67/5651Reducing the amount or size of exchanged application data
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L12/00Data switching networks
    • H04L12/66Arrangements for connecting between networks having differing types of switching systems, e.g. gateways
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/12Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/50Network services
    • H04L67/52Network services specially adapted for the location of the user terminal
    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02DCLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
    • Y02D30/00Reducing energy consumption in communication networks
    • Y02D30/70Reducing energy consumption in communication networks in wireless communication networks

Definitions

  • the present invention relates to the field of Internet of Things technologies, and in particular, to a method and system for intelligent filtering of Internet of Things data based on scene information.
  • the Internet of Things is also known as the sensor network in the world. This is another wave of information industry after the computer, Internet and mobile communication networks. Everything in the world, from watches and keys, to cars and buildings, as long as a miniature sensor chip is embedded and made intelligent, this object can "speak automatically.” With the help of wireless network technology, people can "talk” to objects, and objects and objects can also "communicate”. This is the Internet of Things.
  • the aggregation unit can be used to act as a human-machine interface for the Internet of Things, and the aggregation unit can collect a large number of terminal devices (such as hygrometers, smoke detectors, ventilation devices, rain sensors, irrigation valves, etc.). IoT data is analyzed and made to provide people with relevant reports such as warnings and anomalies.
  • the embodiment of the invention discloses an intelligent filtering method and system for the Internet of Things data based on the scene information, which can effectively filter the data of the terminal device not interested in the aggregation unit, so as to reduce the workload of the aggregation unit.
  • the first aspect of the embodiments of the present invention discloses a method for intelligent filtering of an Internet of Things data based on scene information, including:
  • the forwarding node receives the Internet of Things data initiated by the terminal device in its own wireless coverage; wherein the Internet of Things data initiated by each of the terminal devices includes the terminal device identifier, the terminal device type, and the data payload content;
  • the terminal device address corresponding to the terminal device identifier of the terminal device based on the identifier of the terminal device included in the IoT data initiated by the terminal device; and acquiring the weather corresponding to the terminal device address Type information is used as scene information of the location of the terminal device;
  • the forwarding node encapsulates the IoT data initiated by each of the terminal devices and the scenario information of the location of the terminal device into a data element and reports it to the filtering gateway;
  • the filtering gateway determines, from the data elements reported by the forwarding nodes, part of the data elements including the scenario information specified by the aggregation unit; and determining the package from the determined partial data elements.
  • a data element of a terminal device type that is not of interest to the aggregation unit is included as a data element to be processed;
  • the filtering gateway filters the to-be-processed data elements from the data elements reported by the forwarding nodes, and reports the remaining data elements to the aggregation unit for analysis and decision.
  • the forwarding node acquires the weather type information corresponding to the address of the terminal device as the scenario information of the location of the terminal device, including:
  • the forwarding node invokes a real-time weather distribution port in the area where the terminal device address is located, and queries the weather type information corresponding to the terminal device address as the location of the terminal device by using the real-time weather distribution port of the area where the terminal device address is located. Scene information.
  • the method further includes: before the publishing port queries the weather type information corresponding to the terminal device address, as the scene information of the location of the terminal device, the method further includes:
  • the forwarding node detects whether the real-time weather distribution port of the area where the terminal device address is located is bound to the identifier set of the subscribed terminal device that allows the weather type information to be queried; if the real-time weather release port of the area where the terminal device address is located is tied Determining, by the identifier set of the subscribed terminal device, the identifier of the subscribed terminal device that is allowed to be queried, and querying whether the identifier set of the subscribed terminal device includes the terminal device identifier of the terminal device to which the terminal device address belongs, if the contracted The identifier set of the terminal device includes the terminal device identifier of the terminal device to which the terminal device address belongs, and performs the querying the weather type information corresponding to the terminal device address by using the real-time weather release port of the region where the terminal device address is located, as The scene information of the location of the terminal device.
  • the filtering gateway before determining a part of the data element including the scene information specified by the aggregation unit, from the data element reported by each forwarding node, The method also includes:
  • the filtering gateway receives the filtering table delivered by the aggregation unit, where the filtering table includes the scenario information specified by the aggregation unit and the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the aggregation unit;
  • the scenario information specified by the aggregation unit includes the weather type information specified by the aggregation unit.
  • the terminal device that does not need to report the Internet of Things data in the scenario information specified by the aggregation unit Types include humidity-aware terminal devices deployed on farms.
  • the filtering gateway determines, from the determined part of the data elements, a data element that includes a terminal device type that is not interested in the aggregation unit.
  • Data elements to be processed including:
  • the filtering gateway determines, from the determined partial data elements, a data element of a terminal device type that does not need to report the Internet of Things data in the scenario information specified by the aggregation unit, as a data element to be processed;
  • the scenario information specified by the aggregation unit does not need to report the Internet of Things data.
  • the terminal device type is the terminal device type that the aggregation unit is not interested in.
  • a second aspect of the embodiments of the present invention discloses an IoT data intelligent filtering system based on scenario information, including a forwarding node, a filtering gateway, and a convergence unit, where:
  • the forwarding node is configured to receive IoT data initiated by a mass of terminal devices in its own wireless coverage; wherein the Internet of Things data initiated by each of the terminal devices includes a terminal device identifier, a terminal device type, and a data payload content. ;
  • the forwarding node is further configured to acquire, according to the terminal device identifier included in the Internet of Things data initiated by each of the terminal devices, a terminal device address corresponding to the terminal device identifier of the terminal device; and acquire the terminal device
  • the weather type information corresponding to the address is used as the scene information of the location of the terminal device;
  • the forwarding node is further configured to encapsulate the IoT data initiated by each of the terminal devices and the scenario information of the location of the terminal device into a data element and report the data to the filtering gateway;
  • the filtering gateway is configured to determine, from the data elements reported by the forwarding nodes, a partial data element including the scenario information specified by the aggregation unit, and determine, by the determined partial data element, the aggregation unit a data element of a terminal device type that is not of interest as a data element to be processed;
  • the filtering gateway is further configured to filter the to-be-processed data element from the data element reported by each forwarding node, and report the remaining data element to the aggregation unit;
  • the aggregation unit is configured to analyze and determine the remaining data elements reported by the filtering gateway.
  • the manner in which the forwarding node acquires the weather type information corresponding to the address of the terminal device as the scene information of the location of the terminal device is specifically:
  • the forwarding node is configured to invoke a real-time weather distribution port of the area where the terminal device address is located, and query the weather type information corresponding to the terminal device address by using the real-time weather distribution port of the area where the terminal device address is located, as the terminal Scene information of the location of the device.
  • the forwarding node is further configured to query, after the real-time weather distribution port in the area where the terminal device address is located, and the real-time weather distribution port in the area where the terminal device address is located, the weather type information corresponding to the terminal device address, Before the scene information of the location of the terminal device is detected, whether the real-time weather distribution port of the area where the terminal device address is located is bound to the identifier set of the subscribed terminal device that allows the weather type information to be queried; if the terminal device address is located The real-time weather publishing port of the area is bound with the identifier set of the subscribed terminal device that allows the weathered type information to be queried, and whether the terminal set of the terminal device to which the terminal device address belongs is included in the identifier set of the subscribed terminal device.
  • the filtering gateway is further configured to receive, before the part of the data element including the scenario information specified by the aggregation unit, the filtering table sent by the aggregation unit, where the filtering table includes the The scenario information specified by the aggregation unit and the terminal device type that does not need to report the Internet of Things data in the scenario information specified by the aggregation unit; wherein the scenario information specified by the aggregation unit includes weather type information specified by the aggregation unit, When the weather type information specified by the aggregation unit includes rainy days, the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the aggregation unit includes a humidity-sensing terminal device deployed on the farm.
  • the filtering gateway determines, from the determined part of the data elements, a data element that includes a terminal device type that is not of interest to the aggregation unit.
  • the way to process the data element is as follows:
  • the filtering gateway is configured to determine, from the determined part of the data elements, a data element of a terminal device type that does not need to report the Internet of Things data in the scene information specified by the aggregation unit, as the data element to be processed;
  • the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the aggregation unit is the terminal device type that the aggregation unit is not interested in.
  • the embodiment of the invention has the following beneficial effects:
  • the forwarding node may obtain the terminal device address corresponding to the terminal device identifier of the terminal device according to the terminal device identifier included in the IoT data initiated by each terminal device. Further, the forwarding node may further acquire the terminal device. The weather type information corresponding to the address is used as the scene information of the location of the terminal device. On the basis of this, the forwarding node can encapsulate the IoT data initiated by each terminal device and the scene information of the location of the terminal device into a data element and report it to the filtering gateway.
  • the filtering gateway may determine, from the data elements reported by the forwarding nodes, part of the data elements including the scenario information specified by the aggregation unit, and determine, from the determined partial data elements, the data of the terminal device type including the aggregation unit not interested.
  • the element is filtered as a data element to be processed, and the remaining data elements are reported to the aggregation unit for analysis and decision.
  • the scenario information specified by the aggregation unit may be rainy (belonging to a weather type information), and the terminal device type that is not of interest to the aggregation unit during rainy days may be a humidity-sensing terminal device deployed on the farm (such as a hygrometer)
  • the IoT data reported by the humidity-sensing terminal device deployed by the farm is generally of interest and interest to the aggregation unit for the aggregation unit when it is sunny (belonging to another weather type information).
  • the filtering gateway may determine, from the data elements reported by the forwarding nodes, part of the data elements that are included in the rainy day (ie, the scenario information specified by the aggregation unit), and determine the included terminal from the determined partial data elements.
  • the data element of the device type is the humidity-aware terminal device (that is, the terminal device type that the aggregation unit is not interested in) is filtered as the data element to be processed, and the remaining data elements are reported to the aggregation unit for analysis and decision. It can be seen that the embodiment of the present invention is based on The filtering gateway and the scenario information can effectively filter the data of the terminal device that is not interested in the aggregation unit, thereby reducing the workload of the aggregation unit.
  • FIG. 1 is a schematic diagram of an Internet of Things architecture disclosed in an embodiment of the present invention.
  • FIG. 2 is a schematic flowchart of an intelligent filtering method of an Internet of Things data based on scene information according to an embodiment of the present invention
  • FIG. 3 is a schematic flowchart of another method for intelligent filtering of Internet of Things data based on scene information according to an embodiment of the present invention
  • FIG. 4 is a schematic structural diagram of an Internet of Things data intelligent filtering system based on scene information according to an embodiment of the present invention.
  • the embodiment of the invention discloses an intelligent filtering method and system for the Internet of Things data based on the scene information, which can effectively filter the data of the terminal device not interested in the aggregation unit, so as to reduce the workload of the aggregation unit.
  • the details are described below separately.
  • FIG. 1 is a schematic diagram of an Internet of Things architecture disclosed in an embodiment of the present invention.
  • the IoT architecture may include three layers: a terminal device layer, a forwarding node layer, and an aggregation layer according to functions.
  • the terminal device layer may include a mass-scale terminal device, such as a hygrometer, a smoke sensor, a ventilation device, a rain sensor, an irrigation valve, and the like;
  • the forwarding node layer may include a plurality of forwarding nodes, and the forwarding node may include a router and a relay.
  • the forwarding node may use any standard networking protocol, and the forwarding node may implement data parsing between different network standards;
  • the aggregation layer may include a filtering gateway and a convergence unit.
  • the filtering gateway can directly or indirectly communicate with each forwarding node of the forwarding node layer through the Internet; the aggregation unit can perform high-level management on each forwarding node of the forwarding node layer through the filtering gateway, thereby implementing data transmission frequency, network topology, and other Control of networking functions; the aggregation unit can not only analyze the Internet of Things data generated by massive terminal devices And decision-making, you can also send instructions to obtain information or configure terminal device parameters (at this time, the transmission of data points to the terminal device); the aggregation unit can also introduce various services, from big data to social networks, and even from social tools. "To the weather, etc. In the Internet of Things architecture shown in FIG.
  • each forwarding node can provide IoT data receiving and receiving services for a mass of terminal devices within its own wireless coverage, wherein each forwarding node has its own wireless coverage within each terminal device.
  • a wireless communication module can be built in, which enables each forwarding node to communicate wirelessly with each terminal device within its own wireless coverage by wireless network communication.
  • the wireless communication module built into the terminal device can input the upper frequency point 470MHz and the lower frequency point 510MHz during production, so that the wireless communication module can automatically define the communication frequency band as 470MHz ⁇ 510MHz, It complies with the provisions of China's SRRC standard; alternatively, it can input the upper frequency point of 868MHz and the lower frequency point of 908MHz, so that the wireless communication module can automatically define the communication frequency band as 868MHz to 908MHz to comply with the European ETSI standard; or, you can enter The frequency is 918MHz and the lower frequency is 928MHz, so the wireless communication module can automatically define the communication frequency band as 918MHz ⁇ 928MHz to meet the requirements of the US FCC standard.
  • the communication frequency band of the wireless communication module can also be defined as conforming to the Japanese ARIB standard or Canada.
  • the specification of the IC standard is not limited in the embodiment of the present invention.
  • the terminal device can use Frequency Division Multiple Access (FDMA), Frequency-Hopping Spread Spectrum (FHSS), and Dynamic Time Division Multiple Access (Dynamic Time Division Multiple Access). , DTDMA), and backtracking multiplexing (CSMA) are combined to solve the interference problem.
  • FDMA Frequency Division Multiple Access
  • FHSS Frequency-Hopping Spread Spectrum
  • CSMA Dynamic Time Division Multiple Access
  • FIG. 2 is a schematic flowchart of an intelligent filtering method of an Internet of Things data based on scene information according to an embodiment of the present invention.
  • the scenario information-based intelligent filtering method of the Internet of Things data may include the following steps:
  • the forwarding node receives the Internet of Things data initiated by the terminal device in its own wireless coverage area; wherein the Internet of Things data initiated by each terminal device includes the terminal device identifier, the terminal device type, and the data payload content.
  • the terminal device identifier is used to indicate the unique identity of the terminal device
  • the terminal device type is used to indicate the category and model of the terminal device
  • the data payload content is used to indicate the data load reported by the terminal device, such as the humidity of the farm deployment.
  • the IoT data reported by the terminal device includes the data volume content may be the soil volume water content; for example, the IoT data reported by the temperature sensor includes the data load content may be a temperature value; and, for example, the IoT data reported by the rain gauge includes the data.
  • the load content can be rainfall.
  • the forwarding node obtains the terminal device address corresponding to the terminal device identifier of the terminal device based on the identifier of the terminal device included in the IoT data initiated by each terminal device, and obtains the weather type information corresponding to the terminal device address as the Scene information of the location of the terminal device.
  • the forwarding node may store the terminal device identifier of each terminal device in its own wireless coverage range, where the terminal device identifier of each terminal device stored by the forwarding node may also be bound to the terminal device of the terminal device.
  • the address of the terminal device may be the physical coordinate address of the terminal device or the network IP address of the terminal device, which is not limited in the embodiment of the present invention.
  • the manner in which the forwarding node obtains the weather type information corresponding to the terminal device address as the scene information of the location of the terminal device may be:
  • the forwarding node may invoke the real-time weather distribution port of the area where the terminal device address is located, and query the weather type information corresponding to the terminal device address as the scene information of the location of the terminal device by using the real-time weather distribution port of the area where the terminal device address is located. For example, the forwarding node may invoke a real-time weather distribution port in the area where the terminal device address is located, and send a real-time weather distribution port in the area where the terminal device address is located to the weather server corresponding to the real-time weather distribution port, including the address of the terminal device.
  • the weather type information check request, and the weather type information corresponding to the terminal device address returned by the weather server corresponding to the real-time weather release port is used as the scene information of the location of the terminal device.
  • the forwarding node may perform the following steps:
  • the forwarding node may detect whether the real-time weather publishing port of the area where the terminal device address is located is bound with the identifier set of the subscribed terminal device that allows the weather type information to be queried;
  • the real-time weather distribution port of the area where the terminal device address is located is bound with the identifier set of the subscribed terminal device that allows the weathered type information to be queried, whether the identifier set of the subscribed terminal device includes the terminal of the terminal device to which the terminal device address belongs is included.
  • Equipment Identity
  • the real-time weather distribution port of the region where the terminal device address is located is used to query the weather type information corresponding to the terminal device address, as the terminal device. Location information of the location.
  • the above-mentioned steps can be used to obtain the weather type information corresponding to the terminal device address of the contracted terminal device as the scene information of the location of the terminal device, so that the weather type information corresponding to the terminal device address of the unsigned terminal device can be prevented from leaking.
  • the forwarding node encapsulates the IoT data initiated by each terminal device and the scenario information of the location of the terminal device into a data element and reports the data to the filtering gateway.
  • the forwarding node may initiate the terminal device in the above step 203.
  • the networked data is clipped, and the data obtained by the cropping is encapsulated into a data element together with the scene information of the location of the terminal device, and then directly or indirectly reported to the filtering gateway.
  • the filtering gateway determines, from the data elements reported by the forwarding nodes, part of the data elements including the scenario information specified by the aggregation unit.
  • the filtering gateway may determine, from the data elements reported by the forwarding nodes, part of the data elements including the weather type information (which belongs to a scenario information) specified by the aggregation unit.
  • the filtering gateway determines, from the determined partial data elements, a data element including a terminal device type that is not interested in the aggregation unit, as the to-be-processed data element.
  • the filtering gateway may determine, from the determined partial data elements, a data element of a terminal device type that does not need to report the Internet of Things data in the scenario information specified by the aggregation unit, as the data element to be processed;
  • the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the aggregation unit is the terminal device type that the aggregation unit is not interested in.
  • the filtering gateway filters the to-be-processed data element from the data element reported by each forwarding node, and reports the remaining data element to the aggregation unit.
  • the aggregation unit analyzes and determines the remaining data elements reported by the filtering gateway for analysis and decision.
  • the aggregation unit may analyze and determine the remaining data elements reported by the filtering gateway, so as to provide relevant reports such as early warning and abnormality for the people.
  • the forwarding node may obtain the terminal device address corresponding to the terminal device identifier of the terminal device according to the terminal device identifier included in the IoT data initiated by each terminal device. Further, the forwarding node may also obtain the weather type information corresponding to the terminal device address as the scene information of the location of the terminal device; on this basis, the forwarding node may use the Internet of Things data initiated by each terminal device and the location of the terminal device.
  • the scenario information is encapsulated into data elements and reported to the filtering gateway, and the filtering gateway may determine, from the data elements reported by the forwarding nodes, part of the data elements including the scene information specified by the aggregation unit, and determine from the determined partial data elements.
  • a data element including a terminal device type that is not of interest to the aggregation unit is filtered as a data element to be processed, and the remaining data elements are reported to the aggregation unit for analysis and decision.
  • the scenario information specified by the aggregation unit may be rainy (belonging to a weather type information)
  • the terminal device type that is not of interest to the aggregation unit during rainy days may be a humidity-sensing terminal device deployed on the farm (such as a hygrometer)
  • the IoT data reported by the humidity-sensing terminal device deployed by the farm is generally of interest and interest to the aggregation unit for the aggregation unit when it is sunny (belonging to another weather type information).
  • the filtering gateway may determine, from the data elements reported by the forwarding nodes, part of the data elements that are included in the rainy day (ie, the scenario information specified by the aggregation unit), and determine the included terminal from the determined partial data elements.
  • the data element of the device type is the humidity-aware terminal device (that is, the terminal device type that the aggregation unit is not interested in) is filtered as the data element to be processed, and the remaining data elements are reported to the aggregation unit for analysis and decision. It can be seen that the scenario information-based IoT data intelligent filtering method described in FIG. 2 can effectively filter out data of terminal devices that are not of interest to the aggregation unit, thereby reducing the sink. The working load of the unit.
  • FIG. 3 is a schematic flowchart diagram of another method for intelligent filtering of Internet of Things data based on scene information according to an embodiment of the present invention.
  • the scenario information-based intelligent filtering method of the Internet of Things data may include the following steps:
  • the filtering gateway receives the filtering table delivered by the aggregation unit, where the filtering table includes the scenario information specified by the aggregation unit and the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the aggregation unit.
  • the filtering table delivered by the aggregation unit received by the filtering gateway can be as shown in Table 1, namely:
  • the scenario information specified by the aggregation unit may include the weather type information specified by the aggregation unit.
  • the weather type information specified by the aggregation unit is rainy
  • the terminal device that does not need to report the Internet of Things data is specified in the scenario information specified by the aggregation unit.
  • the type may be a humidity-sensing terminal device (such as a hygrometer) deployed on the farm; when the weather type information specified by the aggregation unit is sunny, the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the aggregation unit may be a rain gauge; When the weather type information specified by the aggregation unit is typhoon, the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the aggregation unit may be the PM2.5 detector.
  • a humidity-sensing terminal device such as a hygrometer
  • the forwarding node receives the Internet of Things data initiated by the terminal device in its own wireless coverage area.
  • the IoT data initiated by each terminal device includes the terminal device identifier, the terminal device type, and the data payload content.
  • the forwarding node obtains, according to the identifier of the terminal device included in the IoT data initiated by each terminal device, the terminal device address corresponding to the terminal device identifier of the terminal device; and acquires the The weather type information corresponding to the terminal device address is used as the scene information of the location of the terminal device.
  • the manner in which the forwarding node obtains the weather type information corresponding to the terminal device address as the scene information of the location of the terminal device may be:
  • the forwarding node may invoke the real-time weather distribution port of the area where the terminal device address is located, and query the weather type information corresponding to the terminal device address as the scene information of the location of the terminal device by using the real-time weather distribution port of the area where the terminal device address is located. For example, the forwarding node may invoke a real-time weather distribution port in the area where the terminal device address is located, and send a real-time weather distribution port in the area where the terminal device address is located to the weather server corresponding to the real-time weather distribution port, including the address of the terminal device.
  • the weather type information check request, and the weather type information corresponding to the terminal device address returned by the weather server corresponding to the real-time weather release port is used as the scene information of the location of the terminal device.
  • the forwarding node may perform the following steps:
  • the forwarding node may detect whether the real-time weather publishing port of the area where the terminal device address is located is bound with the identifier set of the subscribed terminal device that allows the weather type information to be queried;
  • the real-time weather distribution port of the area where the terminal device address is located is bound with the identifier set of the subscribed terminal device that allows the weathered type information to be queried, whether the identifier set of the subscribed terminal device includes the terminal of the terminal device to which the terminal device address belongs is included.
  • Equipment Identity
  • the real-time weather distribution port of the region where the terminal device address is located is used to query the weather type information corresponding to the terminal device address, as the terminal device. Location information of the location.
  • the above-mentioned steps can be used to obtain the weather type information corresponding to the terminal device address of the contracted terminal device as the scene information of the location of the terminal device, so that the weather type information corresponding to the terminal device address of the unsigned terminal device can be prevented from leaking.
  • the forwarding node encapsulates the IoT data initiated by each terminal device and the scenario information of the location of the terminal device into a data element and reports it to the filtering gateway.
  • the filtering gateway determines, from the data elements reported by the forwarding nodes, part of the data elements that include the scenario information specified by the aggregation unit.
  • the filtering gateway may determine, from the data elements reported by the forwarding nodes, part of the data elements including the weather type information (which belongs to a scenario information) specified by the aggregation unit.
  • the filtering gateway determines, from the determined part of the data elements, a data element of a terminal device type that does not need to report the Internet of Things data in the scenario information specified by the aggregation unit, as the data element to be processed;
  • the terminal device type that does not need to report the Internet of Things data in the scenario information specified by the aggregation unit is the terminal device type that the aggregation unit is not interested in.
  • the filtering gateway filters the to-be-processed data element from the data element reported by each forwarding node, and reports the remaining data element to the aggregation unit.
  • the aggregation unit analyzes and determines the remaining data elements reported by the filtering gateway for analysis and decision.
  • the scenario information specified by the aggregation unit may be rainy (belonging to a weather type information), and the terminal device type that is not of interest to the aggregation unit during rainy days may be a humidity-sensing terminal device deployed on the farm (such as a hygrometer)
  • the IoT data reported by the humidity-sensing terminal device deployed by the farm is generally of interest and interest to the aggregation unit for the aggregation unit when it is sunny (belonging to another weather type information).
  • the filtering gateway may determine, from the data elements reported by the forwarding nodes, part of the data elements that are included in the rainy day (ie, the scenario information specified by the aggregation unit), and determine the included terminal from the determined partial data elements.
  • the data element of the device type is the humidity-aware terminal device (that is, the terminal device type that the aggregation unit is not interested in) is filtered as the data element to be processed, and the remaining data elements are reported to the aggregation unit for analysis and decision. It can be seen that the scenario information-based IOT data intelligent filtering method described in FIG. 3 can effectively filter the data of the terminal device that is not interested in the aggregation unit, thereby reducing the workload of the aggregation unit.
  • FIG. 4 is a schematic structural diagram of an IoT data intelligent filtering system based on scene information according to an embodiment of the present invention.
  • the scene information-based IoT data intelligent filtering system may include:
  • the forwarding node 401 is configured to receive the Internet of Things data initiated by the terminal device in its own wireless coverage; wherein the Internet of Things data initiated by each terminal device includes the terminal device identifier, the terminal device type, and the data payload content;
  • the forwarding node 401 is further configured to acquire, according to the terminal device identifier included in the Internet of Things data initiated by each terminal device, a terminal device address corresponding to the terminal device identifier of the terminal device; and obtain a weather type corresponding to the terminal device address Information as scene information of the location of the terminal device;
  • the forwarding node 401 is further configured to encapsulate the IoT data initiated by each terminal device and the scene information of the location of the terminal device into a data element and report to the filtering gateway 402;
  • the filtering gateway 402 is configured to determine, from the data elements reported by the forwarding nodes, that the convergence is included a partial data element of the scene information specified by the unit; and determining, from the determined partial data element, a data element including a terminal device type that the aggregation unit 403 is not interested as the data element to be processed;
  • the filtering gateway 402 is further configured to filter the data element to be processed from the data element reported by each forwarding node, and report the remaining data element to the aggregation unit 403;
  • the aggregation unit 403 is configured to analyze and determine the remaining data elements reported by the filtering gateway 402, so as to provide relevant reports such as early warnings and abnormalities.
  • the forwarding node 401 obtains the weather type information corresponding to the terminal device address as the scene information of the location of the terminal device. Specifically, it can be:
  • the forwarding node 401 is configured to invoke the real-time weather distribution port of the area where the terminal device address is located, and query the weather type information corresponding to the terminal device address by using the real-time weather distribution port of the area where the terminal device address is located, as the scene information of the location of the terminal device. .
  • the forwarding node 401 is further configured to query, after the real-time weather distribution port in the area where the terminal device address is located, and the real-time weather distribution port in the area where the terminal device address is located, the weather corresponding to the terminal device address.
  • the type information as the scene information of the location of the terminal device, first detects whether the real-time weather distribution port of the area where the terminal device address is located is bound with the identifier set of the subscribed terminal device that allows the weather type information to be queried; if the terminal device address The real-time weather distribution port of the area is bound with the identifier set of the subscribed terminal device that allows the weather type information to be queried, and whether the identifier set of the subscribed terminal device includes the terminal device identifier of the terminal device to which the terminal device address belongs, if The identifier set of the terminal device includes the terminal device identifier of the terminal device to which the terminal device address belongs, and the weather type information corresponding to the terminal device address is used to query the weather type information of the terminal device address in the region where the terminal device address is located. Scene information terminal device location.
  • the weather type information corresponding to the terminal device address of the contracted terminal device can be obtained as the scene information of the location of the terminal device, so that the weather type information corresponding to the terminal device address of the unsigned terminal device can be prevented from leaking.
  • the filtering gateway 402 is further configured to receive, before the partial data element including the scenario information specified by the aggregation unit, the filtering table sent by the aggregation unit, where the filtering table includes the aggregation unit 403, The scenario information and the terminal device type that does not need to report the Internet of Things data in the scenario information specified by the aggregation unit 403; wherein the scenario information specified by the aggregation unit 403 includes weather type information specified by the aggregation unit 403, and the weather type specified by the aggregation unit 403 When the information includes rainy days, there is no need to report the number of Internet of Things under the scenario information specified by the aggregation unit 403.
  • the terminal device type includes a humidity-sensing terminal device deployed by the farm; when the weather type information specified by the aggregation unit 403 includes a sunny day, the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the convergence unit 403 includes a rain gauge; The weather type information specified by the aggregation unit 403 includes the typhoon time, and the terminal device type that does not need to report the Internet of Things data under the scenario information specified by the aggregation unit 403 includes the PM2.5 detector.
  • the filtering gateway 402 determines, from the determined partial data elements, a terminal device type that includes the aggregation unit 403 not interested.
  • the data element as the data element to be processed is specifically as follows:
  • the filtering gateway 402 is configured to determine, from the determined partial data elements, a data element of a terminal device type that does not need to report the Internet of Things data, which is to be reported in the scenario information specified by the aggregation unit 403, as the data element to be processed; wherein, in the aggregation unit 403
  • the terminal device type that does not need to report the Internet of Things data under the specified scenario information is the terminal device type that the aggregation unit 403 is not interested in.
  • the scenario information specified by the aggregation unit may be rainy weather (belonging to a weather type information), and the terminal device type that is not concerned by the aggregation unit during rainy days and is not interested may be the humidity awareness of the farm deployment.
  • the terminal device (such as a hygrometer), because the IoT data reported by the humidity-sensing terminal device deployed on the farm is generally focused and interested by the aggregation unit for the aggregation unit when it is sunny (belonging to another weather type information). .
  • the filtering gateway may determine, from the data elements reported by the forwarding nodes, part of the data elements that are included in the rainy day (ie, the scenario information specified by the aggregation unit), and determine the included terminal from the determined partial data elements.
  • the data element of the device type is the humidity-aware terminal device (that is, the terminal device type that the aggregation unit is not interested in) is filtered as the data element to be processed, and the remaining data elements are reported to the aggregation unit for analysis and decision. It can be seen that, in the implementation of the system shown in FIG. 4, the embodiment of the present invention can effectively filter data of terminal devices that are not of interest to the aggregation unit, thereby reducing the workload of the aggregation unit.
  • ROM Read-Only Memory
  • RAM Random Access Memory
  • PROM Programmable Read-Only Memory
  • EPROM Erasable Programmable Read Only Memory
  • OTPROM One-Time Programmable Read-Only Memory
  • EEPROM Electronically-Erasable Programmable Read-Only Memory
  • CD-ROM Compact Disc Read-Only Memory

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Health & Medical Sciences (AREA)
  • Computing Systems (AREA)
  • General Health & Medical Sciences (AREA)
  • Medical Informatics (AREA)
  • Information Transfer Between Computers (AREA)
  • Mobile Radio Communication Systems (AREA)

Abstract

一种基于场景信息的物联网数据智能过滤方法及系统,包括:转发节点根据每一终端设备发起的物联网数据包括的终端设备标识,获取终端设备标识对应的终端设备地址,获取终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息;将每一终端设备发起的物联网数据和该终端设备所在地的场景信息封装成数据元上报给过滤网关;过滤网关从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元,以及从该部分数据元中确定出包括汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元进行过滤,并将剩余的数据元上报给汇聚单元进行分析和决策。有效过滤汇聚单元不感兴趣的终端设备的数据,降低汇聚单元的工作负荷。

Description

一种基于场景信息的物联网数据智能过滤方法及系统 技术领域
本发明涉及物联网技术领域,尤其涉及一种基于场景信息的物联网数据智能过滤方法及系统。
背景技术
物联网在国际上又称为传感网,这是继计算机、互联网与移动通讯网之后的又一次信息产业浪潮。世界上的万事万物,小到手表、钥匙,大到汽车、楼房,只要嵌入一个微型感应芯片,把它变得智能化,这个物体就可以“自动开口说话”。再借助无线网络技术,人们就可以和物体“对话”,物体和物体之间也能“交流”,这就是物联网。在物联网的架构中,可以利用汇聚单元来充当物联网的人机接口,而且汇聚单元可以收集海量的终端设备(如湿度计、烟感器、通风设备、雨量传感器、灌溉阀等)上报的物联网数据进行分析和决策,从而可以为人们提供预警、异常等相关报告。
在实践中发现,随着海量终端设备的规模不断壮大,汇聚单元收集海量规模的终端设备上报的物联网数据势必加剧汇聚单元的工作负荷,因此,如何降低汇聚单元的工作负荷一直是业界研究的热点。
发明内容
本发明实施例公开了一种基于场景信息的物联网数据智能过滤方法及系统,可以有效过滤汇聚单元不感兴趣的终端设备的数据,以降低汇聚单元的工作负荷。
本发明实施例第一方面公开一种基于场景信息的物联网数据智能过滤方法,包括:
转发节点接收其自身无线覆盖范围内的海量的终端设备发起的物联网数据;其中,每一所述终端设备发起的物联网数据包括终端设备标识、终端设备类型以及数据负载内容;
所述转发节点以每一所述终端设备发起的物联网数据包括的终端设备标识为依据,获取所述终端设备的终端设备标识对应的终端设备地址;以及,获取所述终端设备地址对应的天气类型信息作为所述终端设备所在地的场景信息;
所述转发节点将每一所述终端设备发起的物联网数据和所述终端设备所在地的场景信息一起封装成数据元上报给过滤网关;
所述过滤网关从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元;以及,从确定出的所述部分数据元中确定出包 括所述汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元;
所述过滤网关从各个转发节点上报的数据元中过滤上述待处理数据元,并将剩余的数据元上报给汇聚单元进行分析和决策。
作为一种可选的实施方式,在本发明实施例第一方面中,所述转发节点获取所述终端设备地址对应的天气类型信息作为所述终端设备所在地的场景信息,包括:
所述转发节点调用所述终端设备地址所在区域的实时天气发布端口,并通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息。
作为一种可选的实施方式,在本发明实施例第一方面中,所述转发节点调用所述终端设备地址所在区域的实时天气发布端口之后,以及通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息之前,所述方法还包括:
所述转发节点检测所述终端设备地址所在区域的实时天气发布端口是否绑定有允许被查询天气类型信息的已签约终端设备的标识集合;如果所述终端设备地址所在区域的实时天气发布端口绑定有允许被查询天气类型信息的所述已签约终端设备的标识集合,查询所述已签约终端设备的标识集合中是否包括所述终端设备地址所属终端设备的终端设备标识,如果所述已签约终端设备的标识集合中包括所述终端设备地址所属终端设备的终端设备标识,执行所述的通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息。
作为一种可选的实施方式,在本发明实施例第一方面中,所述过滤网关从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元之前,所述方法还包括:
所述过滤网关接收汇聚单元下发的过滤表,所述过滤表包括所述汇聚单元指定的场景信息以及在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型;其中,所述汇聚单元指定的场景信息包括所述汇聚单元指定的天气类型信息,当所述汇聚单元指定的天气类型信息包括雨天时,在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型包括农场部署的湿度感知终端设备。
作为一种可选的实施方式,在本发明实施例第一方面中,所述过滤网关从确定出的所述部分数据元中确定出包括所述汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元,包括:
所述过滤网关从确定出的所述部分数据元中确定出包括在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型的数据元,作为待处理数据元;其中,在所述汇聚单元指定的场景信息下无需上报物联网数据的 终端设备类型即为所述汇聚单元不感兴趣的终端设备类型。
本发明实施例第二方面公开一种基于场景信息的物联网数据智能过滤系统,包括转发节点、过滤网关以及汇聚单元,其中:
所述转发节点,用于接收其自身无线覆盖范围内的海量的终端设备发起的物联网数据;其中,每一所述终端设备发起的物联网数据包括终端设备标识、终端设备类型以及数据负载内容;
所述转发节点,还用于以每一所述终端设备发起的物联网数据包括的终端设备标识为依据,获取所述终端设备的终端设备标识对应的终端设备地址;以及,获取所述终端设备地址对应的天气类型信息作为所述终端设备所在地的场景信息;
所述转发节点,还用于将每一所述终端设备发起的物联网数据和所述终端设备所在地的场景信息一起封装成数据元上报给过所述滤网关;
所述过滤网关,用于从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元;以及,从确定出的所述部分数据元中确定出包括所述汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元;
所述过滤网关,还用于从各个转发节点上报的数据元中过滤上述待处理数据元,并将剩余的数据元上报给所述汇聚单元;
所述汇聚单元,用于对所述过滤网关上报的所述剩余数据元进行分析和决策。
作为一种可选的实施方式,在本发明实施例第二方面中,所述转发节点获取所述终端设备地址对应的天气类型信息作为所述终端设备所在地的场景信息的方式具体为:
所述转发节点用于调用所述终端设备地址所在区域的实时天气发布端口,并通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息。
作为一种可选的实施方式,在本发明实施例第二方面中:
所述转发节点,还用于在调用所述终端设备地址所在区域的实时天气发布端口之后,以及通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息之前,检测所述终端设备地址所在区域的实时天气发布端口是否绑定有允许被查询天气类型信息的已签约终端设备的标识集合;如果所述终端设备地址所在区域的实时天气发布端口绑定有允许被查询天气类型信息的所述已签约终端设备的标识集合,查询所述已签约终端设备的标识集合中是否包括所述终端设备地址所属终端设备的终端设备标识,如果所述已签约终端设备的标识集合中包括所述终端设备地址所属终端设备的终端设备标识,执行所述 的通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息。
作为一种可选的实施方式,在本发明实施例第二方面中:
所述过滤网关,还用于在从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元之前,接收汇聚单元下发的过滤表,所述过滤表包括所述汇聚单元指定的场景信息以及在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型;其中,所述汇聚单元指定的场景信息包括所述汇聚单元指定的天气类型信息,当所述汇聚单元指定的天气类型信息包括雨天时,在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型包括农场部署的湿度感知终端设备。
作为一种可选的实施方式,在本发明实施例第二方面中,所述过滤网关从确定出的所述部分数据元中确定出包括所述汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元的方式具体为:
所述过滤网关用于从确定出的所述部分数据元中确定出包括在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型的数据元,作为待处理数据元;其中,在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型即为所述汇聚单元不感兴趣的终端设备类型。
与现有技术相比,本发明实施例具有以下有益效果:
本发明实施例中,转发节点可以根据每一终端设备发起的物联网数据包括的终端设备标识,获取该终端设备的终端设备标识对应的终端设备地址;进一步地,转发节点还可以获取该终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息;在此基础上,转发节点可以将每一终端设备发起的物联网数据和该终端设备所在地的场景信息一起封装成数据元上报给过滤网关,而过滤网关可以从各个转发节点上报的数据元中确定出包括汇聚单元指定的场景信息的部分数据元,以及从确定出的部分数据元中确定出包括汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元进行过滤,并将剩余的数据元上报给汇聚单元进行分析和决策。举例来说,汇聚单元指定的场景信息可以为雨天(属于一种天气类型信息),而在雨天时汇聚单元不关注、不感兴趣的终端设备类型可以是农场部署的湿度感知终端设备(如湿度计),因为农场部署的湿度感知终端设备上报的物联网数据对于汇聚单元来说,一般是在晴天(属于另一种天气类型信息)时才被汇聚单元关注和感兴趣的。所以,过滤网关可以从各个转发节点上报的数据元中确定出包括的场景信息为雨天(即汇聚单元指定的场景信息)的部分数据元,以及从确定出的部分数据元中确定出包括的终端设备类型为湿度感知终端设备(即汇聚单元不感兴趣的终端设备类型)的数据元作为待处理数据元进行过滤,并将剩余的数据元上报给汇聚单元进行分析和决策。可见,本发明实施例基于过 滤网关和场景信息可以有效的过滤掉汇聚单元不感兴趣的终端设备的数据,从而可以降低汇聚单元的工作负荷。
附图说明
为了更清楚地说明本发明实施例中的技术方案,下面将对实施例中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。
图1是本发明实施例公开的一种物联网架构的示意图;
图2是本发明实施例公开的一种基于场景信息的物联网数据智能过滤方法的流程示意图;
图3是本发明实施例公开的另一种基于场景信息的物联网数据智能过滤方法的流程示意图;
图4是本发明实施例公开的一种基于场景信息的物联网数据智能过滤系统的结构示意图。
具体实施方式
下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。
本发明实施例公开了一种基于场景信息的物联网数据智能过滤方法及系统,可以有效过滤汇聚单元不感兴趣的终端设备的数据,以降低汇聚单元的工作负荷。以下分别进行详细说明。
为了更好地理解本发明实施例,下面先对本发明实施例公开的一种物联网架构进行介绍。请参阅图1,图1是本发明实施例公开的一种物联网架构的示意图。如图1所示,该物联网架构按照功能划分可以包括终端设备层、转发节点层以及汇聚层三个层。其中,终端设备层可以包括海量规模的终端设备,例如湿度计、烟感器、通风设备、雨量传感器、灌溉阀等等;转发节点层可以包括大量的转发节点,转发节点可以包括路由器、中继器、接入点等设备,本发明实施例不作限定;转发节点可以使用任何标准的组网协议,而且转发节点可以在不同的网络制式之间实现数据解析;汇聚层可以包括过滤网关和汇聚单元,其中,过滤网关可以通过互联网与转发节点层的各个转发节点直接或简介通讯连接;汇聚单元可以通过过滤网关对转发节点层的各个转发节点进行高层管理,从而实现数据传输频率、网络拓扑以及其他组网功能的控制;汇聚单元不仅可以对海量终端设备产生的物联网数据进行分析 和决策,还可以通过发指令去获取信息或者配置终端设备参数(此时数据的传输指向终端设备);汇聚单元还可以引入各种业务,从大数据到社交网络、甚至从社交工具“点赞”到天气分享等。在图1所示的物联网架构中,每一个转发节点可以为其自身无线覆盖范围内的海量终端设备提供物联网数据收发服务,其中,每一转发节点自身无线覆盖范围内的每一个终端设备可以内置有无线通讯模块,这使得每一转发节点可以通过无线网络通讯方式与自身无线覆盖范围内的每一个终端设备进行无线通讯。在图1所示的物联网架构中,终端设备内置的无线通讯模块在生产时,可以输入上频点470MHz,下频点510MHz,这样无线通讯模块可以自动将通讯频段定义为470MHz~510MHz,以符合中国SRRC标准的规定;或者,也可以输入上频点868MHz,下频点908MHz,这样无线通讯模块可以自动将通讯频段定义为868MHz~908MHz,以符合欧洲ETSI标准的规定;或者,可以输入上频点918MHz,下频点928MHz,这样无线通讯模块可以自动将通讯频段定义为918MHz~928MHz,以符合美国FCC标准的规定;或者,无线通讯模块的通讯频段也可以定义为符合日本ARIB标准或加拿大IC标准的规定,本发明实施例不作限定。在图1所示的物联网架构中,终端设备可以采用频分复用(Frequency Division Multiple Access,FDMA)、跳频(Frequency-Hopping Spread Spectrum,FHSS)、动态时分复用(Dynamic Time Division Multiple Access,DTDMA)、退避复用(CSMA)相结合的方法来解决干扰问题。
实施例一
在图1所描述的物联网架构的基础上,本发明实施例公开了一种基于场景信息的物联网数据智能过滤方法。请参阅图2,图2是本发明实施例公开的一种基于场景信息的物联网数据智能过滤方法的流程示意图。如图2所示,该基于场景信息的物联网数据智能过滤方法可以包括以下步骤:
201、转发节点接收其自身无线覆盖范围内的海量的终端设备发起的物联网数据;其中,每一终端设备发起的物联网数据包括终端设备标识、终端设备类型以及数据负载内容。
本发明实施例中,终端设备标识用于表示终端设备的唯一身份,而终端设备类型用于表示终端设备的类别和型号,数据负载内容用于表示终端设备上报的数据负载,例如农场部署的湿度感知终端设备上报的物联网数据包括数据负载内容可以是土壤容积含水量;又例如,温度传感器上报的物联网数据包括数据负载内容可以是温度值;又例如,雨量计上报的物联网数据包括数据负载内容可以是降雨量。
202、转发节点以每一终端设备发起的物联网数据包括的终端设备标识为依据,获取该终端设备的终端设备标识对应的终端设备地址;以及,获取该终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息。
本发明实施例中,转发节点可以存储其自身无线覆盖范围内的每一终端设备的终端设备标识,其中,转发节点存储的每一终端设备的终端设备标识还可以绑定该终端设备的终端设备地址;其中,终端设备地址可以是终端设备的物理坐标地址,也可以是终端设备的网络IP地址,本发明实施例不作限定。
作为一种可选的实施方式,上述步骤202中,转发节点获取该终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息的方式可以为:
转发节点可以调用该终端设备地址所在区域的实时天气发布端口,并通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息。例如来说,转发节点可以调用该终端设备地址所在区域的实时天气发布端口,并通过该终端设备地址所在区域的实时天气发布端口向该实时天气发布端口对应的天气服务器发送包括该终端设备地址的天气类型信息查收请求,以及接收该实时天气发布端口对应的天气服务器返回的该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息。
作为一种优选的实施方式,转发节点调用该终端设备地址所在区域的实时天气发布端口之后,以及通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息之前,转发节点还可以先执行以下步骤:
转发节点可以检测该终端设备地址所在区域的实时天气发布端口是否绑定有允许被查询天气类型信息的已签约终端设备的标识集合;
如果该终端设备地址所在区域的实时天气发布端口绑定有允许被查询天气类型信息的已签约终端设备的标识集合,查询已签约终端设备的标识集合中是否包括该终端设备地址所属终端设备的终端设备标识;
如果已签约终端设备的标识集合中包括该终端设备地址所属终端设备的终端设备标识,才执行通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为终端设备所在地的场景信息。
其中,实施上述步骤可以获取已签约终端设备的终端设备地址对应的天气类型信息作为终端设备所在地的场景信息,从而可以防止未签约终端设备的终端设备地址对应的天气类型信息发生泄露。
203、转发节点将每一终端设备发起的物联网数据和该终端设备所在地的场景信息一起封装成数据元上报给过滤网关。
在图1所示的物联网架构中,由于终端设备发起的物联网数据的信号量小,且独立的物联网数据的信号是非致命的,因此上述步骤203中转发节点可以对终端设备发起的物联网数据进行裁剪,并将裁剪得到的数据与该终端设备所在地的场景信息一起封装成数据元后直接或者间接上报给过滤网关。
204、过滤网关从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元。
本发明实施例中,过滤网关可以从各个转发节点上报的数据元中,确定出包括汇聚单元指定的天气类型信息(属于一种场景信息)的部分数据元。
205、过滤网关从确定出的部分数据元中确定出包括汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元。
本发明实施例中,过滤网关可以从确定出的部分数据元中确定出包括在汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型的数据元,作为待处理数据元;其中,在汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型即为汇聚单元不感兴趣的终端设备类型。
206、过滤网关从各个转发节点上报的数据元中过滤上述待处理数据元,并将剩余的数据元上报给汇聚单元。
207、汇聚单元对过滤网关上报的剩余数据元进行分析和决策进行分析和决策。
本发明实施例中,汇聚单元可以对过滤网关上报的剩余数据元进行分析和决策,从而可以为人们提供预警、异常等相关报告。
在图2所描述的基于场景信息的物联网数据智能过滤方法中,转发节点可以根据每一终端设备发起的物联网数据包括的终端设备标识,获取该终端设备的终端设备标识对应的终端设备地址;进一步地,转发节点还可以获取该终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息;在此基础上,转发节点可以将每一终端设备发起的物联网数据和该终端设备所在地的场景信息一起封装成数据元上报给过滤网关,而过滤网关可以从各个转发节点上报的数据元中确定出包括汇聚单元指定的场景信息的部分数据元,以及从确定出的部分数据元中确定出包括汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元进行过滤,并将剩余的数据元上报给汇聚单元进行分析和决策。举例来说,汇聚单元指定的场景信息可以为雨天(属于一种天气类型信息),而在雨天时汇聚单元不关注、不感兴趣的终端设备类型可以是农场部署的湿度感知终端设备(如湿度计),因为农场部署的湿度感知终端设备上报的物联网数据对于汇聚单元来说,一般是在晴天(属于另一种天气类型信息)时才被汇聚单元关注和感兴趣的。所以,过滤网关可以从各个转发节点上报的数据元中确定出包括的场景信息为雨天(即汇聚单元指定的场景信息)的部分数据元,以及从确定出的部分数据元中确定出包括的终端设备类型为湿度感知终端设备(即汇聚单元不感兴趣的终端设备类型)的数据元作为待处理数据元进行过滤,并将剩余的数据元上报给汇聚单元进行分析和决策。可见,图2所描述的基于场景信息的物联网数据智能过滤方法可以有效的过滤掉汇聚单元不感兴趣的终端设备的数据,从而可以降低汇 聚单元的工作负荷。
实施例二
在图1所描述的物联网架构的基础上,本发明实施例公开了一种基于场景信息的物联网数据智能过滤方法。请参阅图3,图3是本发明实施例公开的另一种基于场景信息的物联网数据智能过滤方法的流程示意图。如图3所示,该基于场景信息的物联网数据智能过滤方法可以包括以下步骤:
301、过滤网关接收汇聚单元下发的过滤表,该过滤表包括汇聚单元指定的场景信息以及在汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型。
举例来说,过滤网关接收到的汇聚单元下发的过滤表可以如表1所示,即:
表1过滤表
Figure PCTCN2017099310-appb-000001
如表1所示,汇聚单元指定的场景信息可以包括汇聚单元指定的天气类型信息,当汇聚单元指定的天气类型信息为雨天时,在汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型可以为农场部署的湿度感知终端设备(如湿度计);当汇聚单元指定的天气类型信息为晴天时,在汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型可以为雨量计;当汇聚单元指定的天气类型信息为台风天时,在汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型可以为PM2.5检测仪。
302、转发节点接收其自身无线覆盖范围内的海量的终端设备发起的物联网数据;其中,每一终端设备发起的物联网数据包括终端设备标识、终端设备类型以及数据负载内容。
303、转发节点以每一终端设备发起的物联网数据包括的终端设备标识为依据,获取该终端设备的终端设备标识对应的终端设备地址;以及,获取该 终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息。
作为一种可选的实施方式,上述步骤303中,转发节点获取该终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息的方式可以为:
转发节点可以调用该终端设备地址所在区域的实时天气发布端口,并通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息。例如来说,转发节点可以调用该终端设备地址所在区域的实时天气发布端口,并通过该终端设备地址所在区域的实时天气发布端口向该实时天气发布端口对应的天气服务器发送包括该终端设备地址的天气类型信息查收请求,以及接收该实时天气发布端口对应的天气服务器返回的该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息。
作为一种优选的实施方式,转发节点调用该终端设备地址所在区域的实时天气发布端口之后,以及通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息之前,转发节点还可以先执行以下步骤:
转发节点可以检测该终端设备地址所在区域的实时天气发布端口是否绑定有允许被查询天气类型信息的已签约终端设备的标识集合;
如果该终端设备地址所在区域的实时天气发布端口绑定有允许被查询天气类型信息的已签约终端设备的标识集合,查询已签约终端设备的标识集合中是否包括该终端设备地址所属终端设备的终端设备标识;
如果已签约终端设备的标识集合中包括该终端设备地址所属终端设备的终端设备标识,才执行通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为终端设备所在地的场景信息。
其中,实施上述步骤可以获取已签约终端设备的终端设备地址对应的天气类型信息作为终端设备所在地的场景信息,从而可以防止未签约终端设备的终端设备地址对应的天气类型信息发生泄露。
304、转发节点将每一终端设备发起的物联网数据和该终端设备所在地的场景信息一起封装成数据元上报给过滤网关。
305、过滤网关从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元。
本发明实施例中,过滤网关可以从各个转发节点上报的数据元中,确定出包括汇聚单元指定的天气类型信息(属于一种场景信息)的部分数据元。
306、过滤网关从确定出的部分数据元中确定出包括在汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型的数据元,作为待处理数据元; 其中,在汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型即为汇聚单元不感兴趣的终端设备类型。
307、过滤网关从各个转发节点上报的数据元中过滤上述待处理数据元,并将剩余的数据元上报给汇聚单元。
308、汇聚单元对过滤网关上报的剩余数据元进行分析和决策进行分析和决策。
举例来说,汇聚单元指定的场景信息可以为雨天(属于一种天气类型信息),而在雨天时汇聚单元不关注、不感兴趣的终端设备类型可以是农场部署的湿度感知终端设备(如湿度计),因为农场部署的湿度感知终端设备上报的物联网数据对于汇聚单元来说,一般是在晴天(属于另一种天气类型信息)时才被汇聚单元关注和感兴趣的。所以,过滤网关可以从各个转发节点上报的数据元中确定出包括的场景信息为雨天(即汇聚单元指定的场景信息)的部分数据元,以及从确定出的部分数据元中确定出包括的终端设备类型为湿度感知终端设备(即汇聚单元不感兴趣的终端设备类型)的数据元作为待处理数据元进行过滤,并将剩余的数据元上报给汇聚单元进行分析和决策。可见,图3所描述的基于场景信息的物联网数据智能过滤方法可以有效的过滤掉汇聚单元不感兴趣的终端设备的数据,从而可以降低汇聚单元的工作负荷。
实施例三
在图1所描述的物联网架构的基础上,本发明实施例公开了一种基于场景信息的物联网数据智能过滤系统。请参阅图4,图4是本发明实施例公开的一种基于场景信息的物联网数据智能过滤系统的结构示意图。如图4所示,该基于场景信息的物联网数据智能过滤系统可以包括:
转发节点401、过滤网关402以及汇聚单元403,其中:
转发节点401,用于接收其自身无线覆盖范围内的海量的终端设备发起的物联网数据;其中,每一终端设备发起的物联网数据包括终端设备标识、终端设备类型以及数据负载内容;
转发节点401,还用于以每一终端设备发起的物联网数据包括的终端设备标识为依据,获取该终端设备的终端设备标识对应的终端设备地址;以及,获取该终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息;
转发节点401,还用于将每一终端设备发起的物联网数据和该终端设备所在地的场景信息一起封装成数据元上报给过滤网关402;
过滤网关402,用于从各个转发节点上报的数据元中,确定出包括汇聚 单元指定的场景信息的部分数据元;以及,从确定出的部分数据元中确定出包括汇聚单元403不感兴趣的终端设备类型的数据元作为待处理数据元;
过滤网关402,还用于从各个转发节点上报的数据元中过滤上述待处理数据元,并将剩余的数据元上报给汇聚单元403;
汇聚单元403,用于对过滤网关402上报的剩余数据元进行分析和决策,从而可以为人们提供预警、异常等相关报告。
作为一种可选的实施方式,在图4所示的基于场景信息的物联网数据智能过滤系统中,转发节点401获取该终端设备地址对应的天气类型信息作为该终端设备所在地的场景信息的方式具体可以为:
转发节点401用于调用该终端设备地址所在区域的实时天气发布端口,并通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息。
作为一种优选的实施方式,转发节点401还用于在调用该终端设备地址所在区域的实时天气发布端口之后,以及通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息之前,先检测该终端设备地址所在区域的实时天气发布端口是否绑定有允许被查询天气类型信息的已签约终端设备的标识集合;如果该终端设备地址所在区域的实时天气发布端口绑定有允许被查询天气类型信息的已签约终端设备的标识集合,查询已签约终端设备的标识集合中是否包括该终端设备地址所属终端设备的终端设备标识,如果已签约终端设备的标识集合中包括该终端设备地址所属终端设备的终端设备标识,才通过该终端设备地址所在区域的实时天气发布端口查询该终端设备地址对应的天气类型信息,作为该终端设备所在地的场景信息。
本发明实施例中,可以获取已签约终端设备的终端设备地址对应的天气类型信息作为终端设备所在地的场景信息,从而可以防止未签约终端设备的终端设备地址对应的天气类型信息发生泄露。
作为一种可选的实施方式,在图4所示的基于场景信息的物联网数据智能过滤系统中:
过滤网关402,还用于在从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元之前,接收汇聚单元下发的过滤表,该过滤表包括汇聚单元403指定的场景信息以及在汇聚单元403指定的场景信息下无需上报物联网数据的终端设备类型;其中,汇聚单元403指定的场景信息包括汇聚单元403指定的天气类型信息,当汇聚单元403指定的天气类型信息包括雨天时,在汇聚单元403指定的场景信息下无需上报物联网数 据的终端设备类型包括农场部署的湿度感知终端设备;当汇聚单元403指定的天气类型信息包括晴天时,在汇聚单元403指定的场景信息下无需上报物联网数据的终端设备类型包括雨量计;当汇聚单元403指定的天气类型信息包括台风天时,在汇聚单元403指定的场景信息下无需上报物联网数据的终端设备类型包括PM2.5检测仪。
作为一种可选的实施方式,在图4所示的基于场景信息的物联网数据智能过滤系统中,过滤网关402从确定出的部分数据元中确定出包括汇聚单元403不感兴趣的终端设备类型的数据元作为待处理数据元的方式具体为:
过滤网关402用于从确定出的部分数据元中确定出包括在汇聚单元403指定的场景信息下无需上报物联网数据的终端设备类型的数据元,作为待处理数据元;其中,在汇聚单元403指定的场景信息下无需上报物联网数据的终端设备类型即为汇聚单元403不感兴趣的终端设备类型。
本发明实施例中,举例来说,汇聚单元指定的场景信息可以为雨天(属于一种天气类型信息),而在雨天时汇聚单元不关注、不感兴趣的终端设备类型可以是农场部署的湿度感知终端设备(如湿度计),因为农场部署的湿度感知终端设备上报的物联网数据对于汇聚单元来说,一般是在晴天(属于另一种天气类型信息)时才被汇聚单元关注和感兴趣的。所以,过滤网关可以从各个转发节点上报的数据元中确定出包括的场景信息为雨天(即汇聚单元指定的场景信息)的部分数据元,以及从确定出的部分数据元中确定出包括的终端设备类型为湿度感知终端设备(即汇聚单元不感兴趣的终端设备类型)的数据元作为待处理数据元进行过滤,并将剩余的数据元上报给汇聚单元进行分析和决策。可见,实施图4所示的系统,本发明实施例可以有效的过滤掉汇聚单元不感兴趣的终端设备的数据,从而可以降低汇聚单元的工作负荷。
本领域普通技术人员可以理解上述实施例的各种方法中的全部或部分步骤是可以通过程序来指令相关的硬件来完成,该程序可以存储于一计算机可读存储介质中,存储介质包括只读存储器(Read-Only Memory,ROM)、随机存储器(Random Access Memory,RAM)、可编程只读存储器(Programmable Read-only Memory,PROM)、可擦除可编程只读存储器(Erasable Programmable Read Only Memory,EPROM)、一次可编程只读存储器(One-time Programmable Read-Only Memory,OTPROM)、电子抹除式可复写只读存储器(Electrically-Erasable Programmable Read-Only Memory,EEPROM)、只读光盘(Compact Disc Read-Only Memory,CD-ROM)或其他光盘存储器、磁盘存储器、磁带存储器、或者能够用于携带或存储数据的 计算机可读的任何其他介质。
以上对本发明实施例公开的一种基于场景信息的物联网数据智能过滤方法及系统进行了详细介绍,本文中应用了具体个例对本发明的原理及实施方式进行了阐述,以上实施例的说明只是用于帮助理解本发明的方法及其核心思想;同时,对于本领域的一般技术人员,依据本发明的思想,在具体实施方式及应用范围上均会有改变之处,综上所述,本说明书内容不应理解为对本发明的限制。

Claims (10)

  1. 一种基于场景信息的物联网数据智能过滤方法,其特征在于,包括:
    转发节点接收其自身无线覆盖范围内的海量的终端设备发起的物联网数据;其中,每一所述终端设备发起的物联网数据包括终端设备标识、终端设备类型以及数据负载内容;
    所述转发节点以每一所述终端设备发起的物联网数据包括的终端设备标识为依据,获取所述终端设备的终端设备标识对应的终端设备地址;以及,获取所述终端设备地址对应的天气类型信息作为所述终端设备所在地的场景信息;
    所述转发节点将每一所述终端设备发起的物联网数据和所述终端设备所在地的场景信息一起封装成数据元上报给过滤网关;
    所述过滤网关从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元;以及,从确定出的所述部分数据元中确定出包括所述汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元;
    所述过滤网关从各个转发节点上报的数据元中过滤上述待处理数据元,并将剩余的数据元上报给汇聚单元进行分析和决策。
  2. 根据权利要求1所述的物联网数据智能过滤方法,其特征在于,所述转发节点获取所述终端设备地址对应的天气类型信息作为所述终端设备所在地的场景信息,包括:
    所述转发节点调用所述终端设备地址所在区域的实时天气发布端口,并通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息。
  3. 根据权利要求2所述的物联网数据智能过滤方法,其特征在于,所述转发节点调用所述终端设备地址所在区域的实时天气发布端口之后,以及通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息之前,所述方法还包括:
    所述转发节点检测所述终端设备地址所在区域的实时天气发布端口是否绑定有允许被查询天气类型信息的已签约终端设备的标识集合;如果所述终端设备地址所在区域的实时天气发布端口绑定有允许被查询天气类型信息的所述已签约终端设备的标识集合,查询所述已签约终端设备的标识集合中是否包括所述终端设备地址所属终端设备的终端设备标识,如果所述已签约终端设备的标识集合中包括所述终端设备地址所属终端设备的终端设备标识,执行所述的通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息。
  4. 根据权利要求1、2或3所述的物联网数据智能过滤方法,其特征在于,所述过滤网关从各个转发节点上报的数据元中,确定出包括汇聚单元指 定的场景信息的部分数据元之前,所述方法还包括:
    所述过滤网关接收汇聚单元下发的过滤表,所述过滤表包括所述汇聚单元指定的场景信息以及在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型;其中,所述汇聚单元指定的场景信息包括所述汇聚单元指定的天气类型信息,当所述汇聚单元指定的天气类型信息包括雨天时,在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型包括农场部署的湿度感知终端设备。
  5. 根据权利要求4所述的物联网数据智能过滤方法,其特征在于,所述过滤网关从确定出的所述部分数据元中确定出包括所述汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元,包括:
    所述过滤网关从确定出的所述部分数据元中确定出包括在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型的数据元,作为待处理数据元;其中,在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型即为所述汇聚单元不感兴趣的终端设备类型。
  6. 一种基于场景信息的物联网数据智能过滤系统,其特征在于,包括转发节点、过滤网关以及汇聚单元,其中:
    所述转发节点,用于接收其自身无线覆盖范围内的海量的终端设备发起的物联网数据;其中,每一所述终端设备发起的物联网数据包括终端设备标识、终端设备类型以及数据负载内容;
    所述转发节点,还用于以每一所述终端设备发起的物联网数据包括的终端设备标识为依据,获取所述终端设备的终端设备标识对应的终端设备地址;以及,获取所述终端设备地址对应的天气类型信息作为所述终端设备所在地的场景信息;
    所述转发节点,还用于将每一所述终端设备发起的物联网数据和所述终端设备所在地的场景信息一起封装成数据元上报给过所述滤网关;
    所述过滤网关,用于从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元;以及,从确定出的所述部分数据元中确定出包括所述汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元;
    所述过滤网关,还用于从各个转发节点上报的数据元中过滤上述待处理数据元,并将剩余的数据元上报给所述汇聚单元;
    所述汇聚单元,用于对所述过滤网关上报的所述剩余数据元进行分析和决策。
  7. 根据权利要求6所述的物联网数据智能过滤系统,其特征在于,所述转发节点获取所述终端设备地址对应的天气类型信息作为所述终端设备所在地的场景信息的方式具体为:
    所述转发节点用于调用所述终端设备地址所在区域的实时天气发布端口,并通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息。
  8. 根据权利要求7所述的物联网数据智能过滤系统,其特征在于:
    所述转发节点,还用于在调用所述终端设备地址所在区域的实时天气发布端口之后,以及通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息之前,检测所述终端设备地址所在区域的实时天气发布端口是否绑定有允许被查询天气类型信息的已签约终端设备的标识集合;如果所述终端设备地址所在区域的实时天气发布端口绑定有允许被查询天气类型信息的所述已签约终端设备的标识集合,查询所述已签约终端设备的标识集合中是否包括所述终端设备地址所属终端设备的终端设备标识,如果所述已签约终端设备的标识集合中包括所述终端设备地址所属终端设备的终端设备标识,执行所述的通过所述终端设备地址所在区域的实时天气发布端口查询所述终端设备地址对应的天气类型信息,作为所述终端设备所在地的场景信息。
  9. 根据权利要求6、7或8所述的物联网数据智能过滤系统,其特征在于:
    所述过滤网关,还用于在从各个转发节点上报的数据元中,确定出包括汇聚单元指定的场景信息的部分数据元之前,接收汇聚单元下发的过滤表,所述过滤表包括所述汇聚单元指定的场景信息以及在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型;其中,所述汇聚单元指定的场景信息包括所述汇聚单元指定的天气类型信息,当所述汇聚单元指定的天气类型信息包括雨天时,在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型包括农场部署的湿度感知终端设备。
  10. 根据权利要求9所述的物联网数据智能过滤系统,其特征在于,所述过滤网关从确定出的所述部分数据元中确定出包括所述汇聚单元不感兴趣的终端设备类型的数据元作为待处理数据元的方式具体为:
    所述过滤网关用于从确定出的所述部分数据元中确定出包括在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型的数据元,作为待处理数据元;其中,在所述汇聚单元指定的场景信息下无需上报物联网数据的终端设备类型即为所述汇聚单元不感兴趣的终端设备类型。
PCT/CN2017/099310 2017-06-21 2017-08-28 一种基于场景信息的物联网数据智能过滤方法及系统 Ceased WO2018233006A1 (zh)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201710473268.0A CN107332887B (zh) 2017-06-21 2017-06-21 一种基于场景信息的物联网数据智能过滤方法及系统
CN201710473268.0 2017-06-21

Publications (1)

Publication Number Publication Date
WO2018233006A1 true WO2018233006A1 (zh) 2018-12-27

Family

ID=60195052

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2017/099310 Ceased WO2018233006A1 (zh) 2017-06-21 2017-08-28 一种基于场景信息的物联网数据智能过滤方法及系统

Country Status (2)

Country Link
CN (1) CN107332887B (zh)
WO (1) WO2018233006A1 (zh)

Families Citing this family (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN109151763A (zh) * 2018-10-22 2019-01-04 珠海格力电器股份有限公司 数据无线传输方法、无线传输装置及空调系统
CN116017344A (zh) * 2023-01-05 2023-04-25 深圳艾灵网络有限公司 物联网终端的数据处理方法、装置、电子设备及存储介质
CN115879160B (zh) * 2023-02-08 2023-05-26 杭州海康威视数字技术股份有限公司 基于语义感知的可定制隐私保护方法、系统、装置及设备

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN102685675A (zh) * 2012-06-06 2012-09-19 北京六所新华科电子技术有限公司 基于物联网终端以及门户微博的文化信息推送服务系统
CN103377252A (zh) * 2012-04-28 2013-10-30 国际商业机器公司 在物联网中进行数据过滤的方法和装置
CN103795617A (zh) * 2014-01-16 2014-05-14 南京联舜科技有限公司 一种协议自适应物联网网关系统
US20150019342A1 (en) * 2013-07-09 2015-01-15 Qualcomm Incorporated Real-time context aware recommendation engine based on a user internet of things environment

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103377252A (zh) * 2012-04-28 2013-10-30 国际商业机器公司 在物联网中进行数据过滤的方法和装置
CN102685675A (zh) * 2012-06-06 2012-09-19 北京六所新华科电子技术有限公司 基于物联网终端以及门户微博的文化信息推送服务系统
US20150019342A1 (en) * 2013-07-09 2015-01-15 Qualcomm Incorporated Real-time context aware recommendation engine based on a user internet of things environment
CN103795617A (zh) * 2014-01-16 2014-05-14 南京联舜科技有限公司 一种协议自适应物联网网关系统

Also Published As

Publication number Publication date
CN107332887B (zh) 2019-11-19
CN107332887A (zh) 2017-11-07

Similar Documents

Publication Publication Date Title
WO2018232970A1 (zh) 一种应用于物联网的终端设备状态检测方法及系统
CN107197034B (zh) 一种边缘路由节点及其上报频率调整方法
CN110856185B (zh) 一种物联网无线信号调整方法及系统
WO2018233030A1 (zh) 一种基于传输时长的物联网数据上报控制方法及转发节点
WO2018233009A1 (zh) 一种基于设备类型和地理位置进行数据去重的方法及设备
CN107395677B (zh) 一种基于终端设备优先级的数据上报控制方法及系统
CN107197033B (zh) 一种基于物联网的数据封装方法及系统
WO2018233006A1 (zh) 一种基于场景信息的物联网数据智能过滤方法及系统
CN111049749B (zh) 一种终端设备的物联网数据上报频率的控制及系统
WO2018233036A1 (zh) 一种物联网数据的上报控制方法及设备
CN107197468B (zh) 一种物联网信号强度的检测方法及系统
CN107465719B (zh) 一种应用于物联网的数据处理方法及系统
CN107453940A (zh) 一种基于接入节点的物联网终端设备检测方法及系统
CN107317854B (zh) 基于控制表的终端设备上报频率调节方法及路由节点
CN110855775B (zh) 一种基于过滤网关的终端设备工作状态检测方法及系统
CN107197442B (zh) 一种物联网数据的上报控制方法及系统
CN107249172B (zh) 一种基于终端设备数量的数据封装控制方法及系统
WO2018233028A1 (zh) 一种物联网数据上报控制方法及系统
WO2018232962A1 (zh) 一种物联网接入节点网络覆盖范围的调整方法及系统
WO2018232958A1 (zh) 一种基于转发节点的终端设备自动升级方法及转发节点
CN107465566B (zh) 一种物联网数据的过滤控制方法及路由节点
CN107360097A (zh) 一种结合汇聚单元信息的物联网路由表更新方法及系统
WO2018233021A1 (zh) 一种控制物联网中数据封装的方法及系统
WO2018233007A1 (zh) 基于转发节点和过滤网关的双重数据过滤方法及系统
WO2018233019A1 (zh) 一种基于终端设备位置的数据上报控制方法及系统

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 17915167

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE

32PN Ep: public notification in the ep bulletin as address of the adressee cannot be established

Free format text: NOTING OF LOSS OF RIGHTS PURSUANT TO RULE 112(1) EPC (EPO FORM 1205 DATED 15.05.2020)

122 Ep: pct application non-entry in european phase

Ref document number: 17915167

Country of ref document: EP

Kind code of ref document: A1