CN115102981A - Data processing method, Internet of things system, electronic device and computer storage medium - Google Patents
Data processing method, Internet of things system, electronic device and computer storage medium Download PDFInfo
- Publication number
- CN115102981A CN115102981A CN202210646720.XA CN202210646720A CN115102981A CN 115102981 A CN115102981 A CN 115102981A CN 202210646720 A CN202210646720 A CN 202210646720A CN 115102981 A CN115102981 A CN 115102981A
- Authority
- CN
- China
- Prior art keywords
- internet
- things
- object model
- equipment
- sub
- 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.)
- Pending
Links
- 238000003672 processing method Methods 0.000 title claims abstract description 12
- 238000006243 chemical reaction Methods 0.000 claims abstract description 88
- 238000000034 method Methods 0.000 claims abstract description 55
- 238000004891 communication Methods 0.000 claims abstract description 54
- 230000002452 interceptive effect Effects 0.000 claims abstract description 37
- 230000003993 interaction Effects 0.000 claims description 16
- 230000009466 transformation Effects 0.000 claims description 6
- 238000004590 computer program Methods 0.000 claims description 5
- 230000001131 transforming effect Effects 0.000 claims 1
- 238000011161 development Methods 0.000 abstract description 7
- 238000012423 maintenance Methods 0.000 abstract description 5
- 238000010586 diagram Methods 0.000 description 9
- 230000008569 process Effects 0.000 description 7
- 230000018109 developmental process Effects 0.000 description 6
- 230000006870 function Effects 0.000 description 5
- 238000012545 processing Methods 0.000 description 4
- 238000012986 modification Methods 0.000 description 3
- 230000004048 modification Effects 0.000 description 3
- 230000006855 networking Effects 0.000 description 3
- 238000001514 detection method Methods 0.000 description 2
- 238000007726 management method Methods 0.000 description 2
- 238000013507 mapping Methods 0.000 description 2
- 230000009471 action Effects 0.000 description 1
- 238000007792 addition Methods 0.000 description 1
- 238000004458 analytical method Methods 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000013499 data model Methods 0.000 description 1
- 238000012217 deletion Methods 0.000 description 1
- 230000037430 deletion Effects 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 230000010354 integration Effects 0.000 description 1
- 238000011022 operating instruction Methods 0.000 description 1
- 238000012805 post-processing Methods 0.000 description 1
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/66—Arrangements for connecting between networks having differing types of switching systems, e.g. gateways
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/08—Protocols for interworking; Protocol conversion
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)
- Computer Security & Cryptography (AREA)
- Telephonic Communication Services (AREA)
Abstract
The application provides a data processing method, an Internet of things system, electronic equipment and a computer storage medium. The data processing method is applied to a gateway of an Internet of things system, the Internet of things system comprises the gateway, an Internet of things platform and Internet of things sub-equipment, the Internet of things sub-equipment is communicated with the Internet of things platform through the gateway, and the gateway is in communication connection with a cloud end, and the method comprises the following steps: acquiring an interactive message of the Internet of things sub-equipment and the Internet of things platform, wherein the interactive message carries an equipment identifier, and a receiver of the interactive message is the Internet of things platform or the Internet of things sub-equipment; if the fact that the object model conversion script matched with the equipment identification does not exist in the gateway is determined, the object model conversion script corresponding to the equipment identification is dynamically obtained from the cloud; and converting the interactive message into a communication message conforming to the using protocol of the receiving party by using the corresponding object model conversion script, and sending the communication message to the receiving party. The method has the advantage that the maintenance and development cost of the Internet of things system is low.
Description
Technical Field
The embodiment of the application relates to the technical field of computers, in particular to a data processing method, an internet of things system, electronic equipment and a computer storage medium.
Background
Generally, the internet of things cloud platform has object models defined by the internet of things cloud platform (an object model is a digital description of a product and defines functions of the product, and a general object model is defined by adopting a json format). When data of the device is transmitted to the internet of things platform, protocols (such as ble, zigbee and the like) used by the device need to be converted into an object model corresponding to the internet of things cloud platform by using the SDK provided by the internet of things platform at the device side. On the contrary, when data are issued to the equipment through the cloud platform of the internet of things, the object model needs to be converted into a protocol used by the equipment through the SDK at the equipment end for post-processing.
The method can only convert preset object models, so that the flexibility is insufficient, different object models and access standards defined by different internet of things platforms are difficult to adapt, equipment needs to maintain multiple sets of different SKUs (Stock Keeping units, minimum sales units), and the cost and the maintenance complexity are high.
Disclosure of Invention
In view of the above, embodiments of the present application provide a data processing scheme to solve at least part of the above problems.
According to a first aspect of embodiments of the present application, a data processing method is provided, where the method is applied to a gateway of an internet of things system, where the internet of things system includes the gateway, an internet of things platform, and an internet of things sub-device, where the internet of things sub-device communicates with the internet of things platform through the gateway, and the gateway is connected to a cloud in a communication manner, and the method includes: acquiring an interactive message of the Internet of things sub-equipment and the Internet of things platform, wherein the interactive message carries an equipment identifier, and a receiver of the interactive message is the Internet of things platform or the Internet of things sub-equipment; if the fact that the object model conversion script matched with the equipment identification does not exist locally is determined, the object model conversion script corresponding to the equipment identification is obtained from the cloud dynamically; and converting the interactive message into a communication message conforming to the using protocol of the receiving party by using the corresponding object model conversion script, and sending the communication message to the receiving party.
According to a second aspect of the embodiments of the present application, there is provided an internet of things system, including an internet of things platform, a gateway and an internet of things sub-device, where the internet of things platform is connected to the internet of things sub-device in a communication manner through the gateway, and the gateway is configured to execute the foregoing method, so as to convert interaction information between the internet of things platform and the internet of things sub-device into a communication message conforming to a protocol of a receiver of the interaction information, and send the communication message to the receiver of the interaction information.
According to a third aspect of embodiments of the present application, there is provided an electronic apparatus, including: the system comprises a processor, a memory, a communication interface and a communication bus, wherein the processor, the memory and the communication interface complete mutual communication through the communication bus; the memory is used for storing at least one executable instruction, and the executable instruction enables the processor to execute the corresponding operation of the method.
According to a fourth aspect of embodiments herein, there is provided a computer storage medium having stored thereon a computer program which, when executed by a processor, implements a method as described above.
According to a fifth aspect of embodiments of the present application, there is provided a computer program product comprising computer instructions for instructing a computing device to perform operations corresponding to the method as described above.
According to the method provided by the embodiment of the application, the object model conversion script of the cloud is dynamically loaded in the gateway, and the object model conversion script is used for completing the conversion between the object model and the internet of things sub-device protocol, so that the situation that the communication between different internet of things sub-devices and internet of things platforms can be adapted is guaranteed, the firmware of the gateway can be prevented from being frequently upgraded, the adaptability is improved, and the maintenance and development cost is reduced.
Drawings
In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, it is obvious that the drawings in the description below are only some embodiments described in the embodiments of the present application, and other drawings can be obtained by those skilled in the art according to these drawings.
Fig. 1 is a schematic structural diagram of an internet of things system according to a first embodiment of the present application;
FIG. 2 is a flowchart illustrating steps of a data processing method according to an embodiment of the present application;
FIG. 3 is a flowchart illustrating sub-steps of step 204 of a data processing method according to a first embodiment of the present application;
FIG. 4 is a schematic flow chart diagram illustrating another data processing method according to a first embodiment of the present application;
FIG. 5 is a flowchart illustrating a further data processing method according to a first embodiment of the present application;
FIG. 6 is a diagram illustrating object model transformation script loading according to a first embodiment of the present application;
FIG. 7 is a schematic structural diagram of an Internet of things system according to a second embodiment of the application;
fig. 8 is a block diagram of a data processing apparatus according to a third embodiment of the present application;
fig. 9 is a schematic structural diagram of an electronic device according to a fifth embodiment of the present application.
Detailed Description
In order to make those skilled in the art better understand the technical solutions in the embodiments of the present application, the technical solutions in the embodiments of the present application will be described clearly and completely below with reference to the drawings in the embodiments of the present application, and it is obvious that the described embodiments are only a part of the embodiments of the present application, but not all the embodiments. All other embodiments obtained by a person of ordinary skill in the art based on the embodiments in the present application shall fall within the scope of the protection of the embodiments in the present application.
The following further describes specific implementations of embodiments of the present application with reference to the drawings of the embodiments of the present application.
Example one
For ease of understanding, before the implementation process of the method of the present application is described in detail, a usage scenario of the method is exemplarily described, but the method of the present application is not limited to the usage scenario, and may also be applied to other suitable scenarios.
Fig. 1 shows a schematic diagram of an internet of things system. The Internet of things system comprises a gateway, an Internet of things platform and an Internet of things sub-device, wherein the Internet of things sub-device is communicated with the Internet of things platform through the gateway.
The Internet of things platform can provide services such as management of the Internet of things sub-equipment, definition of the object model, access and control of the SDK and the like. The object model may be a data model defined for an internet of things sub-device (e.g., a sensor, an in-vehicle device, a building, a factory, a smart lamp, a smart doorbell, etc.) for describing a function of the internet of things sub-device. The object model (usually defined in json format) defines the internet of things sub-equipment from three dimensions of attributes, services and events. An object model can be defined for the internet of things sub-devices of the same device type. In addition, the internet of things platform can be in communication connection with terminal equipment (such as a smart phone, a smart tablet and the like) of a user, so that the user can control the internet of things sub-equipment through the terminal equipment.
The gateway may be a bluetooth gateway, WiFi gateway, or the like. Taking the bluetooth gateway as an example, the bluetooth gateway can be used as an intermediary for connecting the internet of things sub-device with the internet of things platform and operates at the gateway side. The method and the system can realize registration, authentication, connection and the like of the Internet of things sub-equipment on the Internet of things platform. In addition, detection, networking and connection of the Internet of things sub-equipment, mapping and management of the Internet of things sub-equipment and the virtual equipment, execution of an object model conversion script and the like can be realized. The virtual device is a bridge between the Internet of things platform and the Internet of things sub-device, serves as a shadow of the real Internet of things sub-device, shields the difference realized by the bottom layer of the Internet of things sub-device, and provides a uniform access interface upwards.
The Bluetooth gateway comprises a master control and a Mesh controller. The master control can be used for functions of integration, execution engine, network connection, cloud access and the like of the SDK of the Internet of things platform. The Mesh controller is responsible for functions of distribution network connection, node control, upgrading and the like between the Mesh sub-equipment (namely terminal equipment) and the main control.
Besides the gateway, the internet of things platform, and the internet of things sub-device, the internet of things platform may further include a cloud (e.g., an OCC, i.e., a chip development community). The cloud end can provide services such as equipment authentication, object model conversion script compiling and storing, FOTA upgrading and the like.
The existing Internet of things sub-equipment can realize data interaction with an Internet of things platform through a gateway. For example, when the internet of things platform communicates with the connected internet of things sub-device, data sent by the internet of things platform to the internet of things sub-device is represented in the object model format, but not a protocol used by the internet of things sub-device, so that the sent data needs to be processed by converting the data in the object model format into the protocol used by the internet of things sub-device by using the SDK of the internet of things platform.
Similarly, when the internet of things sub-device transmits data to the internet of things platform, the data represented by the protocol (such as ble, zigbee, and the like) used by the internet of things sub-device needs to be converted into data in the object model format corresponding to the internet of things cloud platform through the SDK provided by the internet of things platform, and then transmitted to the internet of things platform. The method can only convert the preset physical model, the SDK is updated if a new physical model needs to be added, and the updating of the SDK needs a firmware upgrading mode, so that service is interrupted when the gateway carries out firmware upgrading, all the Internet of things sub-devices connected with the gateway are unavailable, and the use is greatly influenced.
In order to solve the problem, an embodiment of the present application provides a data processing method, as shown in fig. 2, which includes the following steps:
step S202: and acquiring interactive messages of the Internet of things sub-equipment and the Internet of things platform.
The interactive message may be a control instruction (such as turning on a light, turning off a light, and the like) issued by the internet of things platform to the internet of things sub-device, or may be status information (such as a switch status, a color, brightness, and the like) sent by the internet of things sub-device to the internet of things platform, so that for a certain interactive message, a receiver of the interactive message may be the internet of things platform or the internet of things sub-device.
The interaction message carries a device identifier, which may be a unique certificate (devicename) in a device type (such as a lamp, a sensor, or a doorbell) issued by the internet of things platform for each internet of things sub-device. The Internet of things platform can be connected to a plurality of Internet of things sub-devices under the same device type, and in order to distinguish the Internet of things sub-devices, each Internet of things sub-device has an independent device identifier, and the same device type can correspond to one object model.
If the interactive message is a control instruction issued by the internet of things platform, the interactive message includes content data in addition to the device identifier, and the content data may be an instruction identified by the object model format, for example, if the light is indicated to be turned on, the content data may be '{' powerstate ':1 }'.
If the interactive message is status information sent by the internet of things sub-device, the content data of the interactive message may be a status of the internet of things sub-device represented by binary in addition to the device identifier.
In this embodiment, the gateway integrates a plurality of SDKs and execution engines of the internet of things cloud platform, where the execution engines are configured to execute an object model conversion script, and the object model conversion script is configured to automatically convert an interaction message, for example, convert an interaction message in an object model format into a format of a protocol used by the internet of things sub-device, or convert an interaction message in a protocol format used by the internet of things sub-device into an object model format. The object model transformation script can be stored and configured in the cloud so as to facilitate adding or modifying the object model transformation script without interfering with the operation of the gateway.
When the gateway receives the interactive message, step S204 may be executed to process the interactive message.
Step S204: and if the fact that the object model conversion script matched with the equipment identification does not exist in the gateway is determined, the object model conversion script corresponding to the equipment identification is dynamically obtained from the cloud.
In one example, as shown in fig. 3, step S204 includes the following sub-steps:
substep S2041: and determining the device type of the Internet of things sub-device corresponding to the device identifier.
In this example, the cloud is used to maintain the correspondence between the internet of things child device and the device type, and therefore, the gateway can send the device identifier to the cloud to obtain the device type (such as a lamp, a sensor, and the like) to which the internet of things child device belongs from the cloud, which can reduce the load of the gateway.
Of course, in other examples, the correspondence between the internet of things sub-device and the device type may be maintained locally at the gateway, which is not limited to this.
Substep S2042: and determining whether an object model conversion script corresponding to the equipment type exists locally.
The internet of things sub-devices of the same device type usually correspond to one object model, but because the object model conversion script may be updated (such as modified, added or deleted), the gateway may locally have a situation that the object model conversion script corresponding to the internet of things sub-device does not exist. If so, the interaction information may be converted by using a local object model conversion script, and the conversion process is similar to step S206, so detailed description will be given in the description of step S206 and will not be repeated separately.
Substep S2043: and if the object model conversion script does not exist, acquiring the object model conversion script corresponding to the equipment type from the cloud.
Under the condition that no object model conversion script is needed locally, the gateway can dynamically acquire the needed object model conversion script from the cloud end, and the subsequent object model conversion script is used for converting the interactive message, so that the SDK of the Internet of things platform is not needed for converting the interactive message, and the firmware is not needed to be frequently upgraded. In addition, the method can well adapt to the addition, modification and deletion of the object model conversion script, and the firmware of the gateway does not need to be upgraded even if a new object model is added, so the normal operation of the gateway is not influenced.
Step S206: and converting the interactive message into a communication message conforming to the using protocol of the receiving party by using the corresponding object model conversion script, and sending the communication message to the receiving party.
In this embodiment, the gateway is configured with an execution engine for instructing object model conversion script, which may be an interpreted language engine for translating the program into machine language at runtime. The program in the interpreted language does not need to be compiled before running, and is translated when running, and a special interpreter is responsible for interpreting the program code when each statement is executed. The interpreted language engine may be a JavaScript engine, a Python engine, or another interpreted language engine, which is not limited thereto.
In a possible manner, the converting the interactive message into the communication message conforming to the receiving party usage protocol using the corresponding object model conversion script in step S206 is implemented as: and taking the content data and the equipment identification in the interactive message as parameters, and sending the parameters and the corresponding object model conversion script to the execution engine, so that the execution engine calls back the object model conversion script and converts the parameters into the communication message conforming to the protocol used by the receiver.
The content data may include, for example, a string of characters, instructions to control the internet of things subset, and the like.
And sending the relevant parameters and the object model conversion script to an execution engine, executing the object model conversion script by the execution engine, and converting the parameters into communication messages conforming to a receiving party use protocol by using a set conversion function, so that the communication between the Internet of things platform and the Internet of things sub-equipment is realized. For example, when the internet of things platform issues data, the receiver is the internet of things sub-device, otherwise, when the internet of things sub-device uploads data, the receiver is the internet of things platform.
In the gateway, in order to shield the bottom implementation of the internet of things sub-device, a corresponding virtual device is created for each internet of things sub-device, so that when sending a communication message to the internet of things sub-device, the implementation may be: and sending the notification message to the equipment IOT sub-equipment serving as the receiver through a controller used by virtual equipment corresponding to the IOT sub-equipment serving as the receiver. This increases the flexibility.
The following description of the conversion process, in conjunction with a specific execution engine example, follows:
this example is a JavaScript-based execution engine, whose code is as follows:
through integrated execution engine in the gateway for can be according to information developments such as equipment type from the high in the clouds download thing model conversion script, just can be conveniently compatible different equipment type's thing networking subelement and the communication of thing networking platform, and because the thing model conversion script in the high in the clouds can dynamic loading, the gateway can carry out thing model conversion script automatically through execution engine, consequently need not frequently upgrade the firmware of gateway, when increasing new thing model, only need in the high in the clouds configuration new thing model conversion script can.
Optionally, to increase the adaptability, in an example, as shown in fig. 4, the method may further include step S208 and step S210.
Step S208: it is determined whether the locally existing object model transformation script needs to be updated.
The gateway can request the version information of the object model conversion script from the cloud at intervals, and whether the updating is needed or not is determined by comparing the version information with the version of the local object model conversion script. If the new version exists, determining that the version needs to be updated, and executing step S210; otherwise, no action may be taken.
Step S210: and if so, acquiring a new object model conversion script from the cloud.
By acquiring the new object model conversion script from the cloud, the conversion reliability is guaranteed, the object model is conveniently updated, and the adaptability is improved.
Optionally, referring to fig. 5 and 6, in order to enable the gateway to access the new internet of things sub-device, the method further includes steps S212 to S216.
Step S212: and if the new Internet of things sub-equipment is detected, establishing corresponding virtual equipment for communication for the new Internet of things sub-equipment.
Taking the bluetooth gateway as an example, when the bluetooth gateway detects the Mesh internet of things sub-device through the Mesh controller, the gateway creates a one-to-one mapping relationship between the virtual device and the actual internet of things sub-device.
Step S214: and acquiring an object model conversion script corresponding to the equipment type of the new Internet of things sub-equipment from the cloud.
The gateway can be connected to the cloud for authentication according to information such as keys provided in the Internet of things sub-device. And if the authentication is passed, the gateway acquires the object model conversion script corresponding to the equipment type of the Internet of things sub-equipment from the cloud end through the network and downloads the object model conversion script to the local.
Step S216: and accessing the new Internet of things sub-equipment into the Internet of things platform by using the object model conversion script corresponding to the new Internet of things sub-equipment.
The steps S212 to S216 can be implemented by an yoc (yun on chip) unit in the gateway. YOC, based on a CPU architecture, a chip platform, an operating system, a cloud service and a development suite, the full link from the chip to the cloud is designed efficiently.
And accessing the specified Internet of things platform through the accessed SDK of the Internet of things platform based on the object model conversion script. After the internet of things platform is accessed, if a control instruction (an instruction defined according to the object model) sent by the internet of things platform is received as an interactive message, step S202 to step S206 are executed, so that the corresponding object model conversion script is sent to the execution engine for analysis. After the specific instruction (i.e., the communication message) corresponding to the internet of things sub-device (according to the protocol of the internet of things sub-device, such as the Mesh, the zigbee and the like) is analyzed, the specific instruction is sent to the internet of things sub-device through the actual controller (such as the Mesh controller) used by the virtual device, so that the purpose of controlling is achieved.
Or when the data reported by the internet of things sub-device is used as an interactive message, the data can be converted into an object model instruction corresponding to the internet of things platform by using the object model conversion script through the execution engine, and the object model instruction is sent to the internet of things platform through the integrated sdk.
According to the method, when the gateway needs to be accessed to the Internet of things sub-equipment of other equipment types, only simple modification needs to be carried out on the Internet of things platform, the cloud and the Internet of things sub-equipment, so that the Internet of things sub-equipment and the gateway are decoupled, the effect of unnecessarily not needing to upgrade the gateway is achieved, and finally, the development and maintenance workload is greatly reduced.
Example two
As shown in fig. 7, an internet of things system is provided, which includes an internet of things platform 702, a gateway 704 and an internet of things sub-device 706, wherein the internet of things platform 702 is in communication connection with the internet of things sub-device 706 through the gateway 704, and the gateway 704 is configured to perform the foregoing method, so as to convert interaction information between the internet of things platform 702 and the internet of things sub-device 706 into a communication message conforming to a protocol of a recipient of the interaction information, and send the communication message to the recipient of the interaction information.
The Internet of things system can adapt to interconnection and intercommunication among various different Internet of things platforms and Internet of things sub-equipment, adaptability is improved, and development cost and maintenance workload are reduced under the condition that different object models and access standards are well adapted to be defined.
Optionally, the internet of things system further includes a cloud 708, the cloud 708 is configured to edit and store an object model conversion script, and the gateway 704 is connected to the cloud 708 and dynamically obtains the object model conversion script from the cloud 708. The cloud 708 can implement an object model conversion script for protocols used by different internet of things sub-devices to facilitate use, and the object model conversion script is dynamically loaded and executed based on an interpreted language engine integrated with a gateway to complete conversion between an object model and a device protocol.
The method of the present embodiment may be performed by any suitable electronic device having data processing capabilities, including but not limited to: a server, a mobile terminal (such as a mobile phone, a PAD and the like), a PC and the like.
EXAMPLE III
Referring to fig. 8, a block diagram of a data processing apparatus according to a third embodiment of the present application is shown.
In this embodiment, the apparatus may be configured in a gateway of an internet of things system, where the internet of things system includes the gateway, an internet of things platform, and an internet of things sub-device, the internet of things sub-device communicates with the internet of things platform through the gateway, the gateway is connected to a cloud in a communication manner, and the apparatus includes:
a first obtaining module 802, configured to obtain an interactive message of interaction between the internet of things sub-device and the internet of things platform, where the interactive message carries a device identifier, and a receiver of the interactive message is the internet of things platform or the internet of things sub-device;
a loading module 804, configured to dynamically obtain, from the cloud, an object model conversion script corresponding to the device identifier if it is determined that the object model conversion script matching the device identifier does not exist locally at the gateway;
a conversion module 806, configured to use the corresponding object model conversion script to convert the interactive message into a communication message conforming to the receiving party usage protocol, and send the communication message to the receiving party.
Optionally, the loading module 804 is configured to determine a device type to which the internet of things sub-device corresponding to the device identifier belongs; determining whether an object model conversion script corresponding to the equipment type exists locally; and if the object model conversion script does not exist, acquiring the object model conversion script corresponding to the equipment type from the cloud.
Optionally, an execution engine configured in the gateway is configured to execute the object model conversion script, and the conversion module 806 is configured to use content data and a device identifier in the interactive message as parameters, and send the parameters and the corresponding object model conversion script to the execution engine, so that the execution engine calls back the object model conversion script, and converts the parameters into a communication message that conforms to a receiving party's usage protocol.
Optionally, the gateway is configured with virtual devices corresponding to the connected internet of things sub-devices, and if the receiving party is the internet of things sub-device, the conversion module 806 is configured to send the notification message to the device internet of things sub-device serving as the receiving party through a controller used by the virtual device corresponding to the internet of things sub-device serving as the receiving party.
Optionally, the apparatus further comprises:
the detection module 808 is configured to create a corresponding virtual device for communication for a new internet of things sub-device if the new internet of things sub-device is detected;
a second obtaining module 810, configured to obtain, from the cloud, an object model conversion script corresponding to the device type of the new internet of things sub-device;
an access module 812, configured to access the new internet of things subset to the internet of things platform using the object model conversion script corresponding to the new internet of things subset.
Optionally, the apparatus further comprises:
a determining module 814, configured to determine whether the locally existing object model conversion script needs to be updated;
an updating module 816, configured to obtain a new object model conversion script from the cloud, if necessary.
The apparatus of this embodiment is used to implement the corresponding method in the foregoing method embodiments, and has the beneficial effects of the corresponding method embodiments, which are not described herein again. In addition, the functional implementation of each module in the apparatus of this embodiment can refer to the description of the corresponding part in the foregoing method embodiment, and is not described herein again.
Example four
Referring to fig. 9, a schematic structural diagram of an electronic device according to a fourth embodiment of the present application is shown, and the specific embodiment of the present application does not limit specific implementations of the electronic device.
As shown in fig. 9, the electronic device may include: a processor (processor)902, a communication Interface 904, a memory 906, and a communication bus 908.
Wherein:
the processor 902, communication interface 904, and memory 906 communicate with one another via a communication bus 908.
A communication interface 904 for communicating with other electronic devices or servers.
The processor 902 is configured to execute the program 910, and may specifically perform the relevant steps in the above method embodiments.
In particular, the program 910 may include program code that includes computer operating instructions.
The processor 902 may be a processor CPU, or an Application Specific Integrated Circuit (ASIC), or one or more Integrated circuits configured to implement embodiments of the present application. The intelligent device comprises one or more processors which can be the same type of processor, such as one or more CPUs; or may be different types of processors such as one or more CPUs and one or more ASICs.
A memory 906 for storing a program 910. The memory 906 may include high-speed RAM memory, and may also include non-volatile memory, such as at least one disk memory.
The program 910 may be specifically configured to enable the processor 902 to execute operations corresponding to the foregoing methods.
For specific implementation of each step in the program 910, reference may be made to corresponding steps and corresponding descriptions in units in the foregoing method embodiments, which are not described herein again. It can be clearly understood by those skilled in the art that, for convenience and brevity of description, the specific working processes of the above-described devices and modules may refer to the corresponding process descriptions in the foregoing method embodiments, and are not described herein again.
The embodiment of the present application further provides a computer program product, which includes computer instructions for instructing a computing device to execute an operation corresponding to any one of the methods in the foregoing method embodiments.
Embodiments of the present application also provide a computer storage medium, on which a computer program is stored, and the program, when executed by a processor, implements the method according to any one of the foregoing.
It should be noted that, according to the implementation requirement, each component/step described in the embodiment of the present application may be divided into more components/steps, and two or more components/steps or partial operations of the components/steps may also be combined into a new component/step to achieve the purpose of the embodiment of the present application.
The above-described methods according to embodiments of the present application may be implemented in hardware, firmware, or as software or computer code storable in a recording medium such as a CD ROM, a RAM, a floppy disk, a hard disk, or a magneto-optical disk, or as computer code originally stored in a remote recording medium or a non-transitory machine-readable medium downloaded via a network and to be stored in a local recording medium, so that the methods described herein may be stored in such software processes on a recording medium using a general-purpose computer, a dedicated processor, or programmable or dedicated hardware such as an ASIC or FPGA. It will be appreciated that a computer, processor, microprocessor controller, or programmable hardware includes memory components (e.g., RAM, ROM, flash memory, etc.) that can store or receive software or computer code that, when accessed and executed by a computer, processor, or hardware, implements the methods described herein. Furthermore, when a general-purpose computer accesses code for implementing the methods illustrated herein, execution of the code transforms the general-purpose computer into a special-purpose computer for performing the methods illustrated herein.
Those of ordinary skill in the art will appreciate that the various illustrative elements and method steps described in connection with the embodiments disclosed herein may be implemented as electronic hardware, or combinations of computer software and electronic hardware. Whether such functionality is implemented as hardware or software depends upon the particular application and design constraints imposed on the implementation. Skilled artisans may implement the described functionality in varying ways for each particular application, but such implementation decisions should not be interpreted as causing a departure from the scope of the embodiments of the present application.
The above embodiments are only used for illustrating the embodiments of the present application, and not for limiting the embodiments of the present application, and those skilled in the relevant art can make various changes and modifications without departing from the spirit and scope of the embodiments of the present application, so that all equivalent technical solutions also belong to the scope of the embodiments of the present application, and the scope of the patent protection of the embodiments of the present application should be defined by the claims.
Claims (10)
1. A data processing method is applied to a gateway of an Internet of things system, wherein the Internet of things system comprises the gateway, an Internet of things platform and an Internet of things sub-device, the Internet of things sub-device is communicated with the Internet of things platform through the gateway, the gateway is in communication connection with a cloud end, and the method comprises the following steps:
acquiring an interactive message interacted between the Internet of things sub-equipment and the Internet of things platform, wherein the interactive message carries an equipment identifier, and a receiver of the interactive message is the Internet of things platform or the Internet of things sub-equipment;
if the fact that the object model conversion script matched with the equipment identification does not exist in the gateway is determined, the object model conversion script corresponding to the equipment identification is dynamically obtained from the cloud end;
and converting the interactive message into a communication message conforming to the using protocol of the receiving party by using the corresponding object model conversion script, and sending the communication message to the receiving party.
2. The method of claim 1, wherein if it is determined that no object model conversion script matching the device identifier exists locally, dynamically obtaining an object model conversion script corresponding to the device identifier from the cloud, comprises:
determining the device type of the Internet of things sub-device corresponding to the device identifier;
determining whether an object model conversion script corresponding to the equipment type exists locally;
and if the object model conversion script does not exist, acquiring the object model conversion script corresponding to the equipment type from the cloud.
3. The method of claim 1 or 2, wherein an execution engine is configured in the gateway for executing the object model transformation script, and the transforming the interactive message into a communication message conforming to the receiving party usage protocol using the corresponding object model transformation script comprises:
and taking the content data and the equipment identification in the interactive message as parameters, and sending the parameters and the corresponding object model conversion script to the execution engine, so that the execution engine calls back the object model conversion script and converts the parameters into the communication message conforming to the protocol used by the receiver.
4. The method according to claim 3, wherein the gateway is configured with virtual devices corresponding to connected internet of things sub-devices, and if the receiving party is the internet of things sub-device, the sending the communication message to the receiving party includes:
and sending the notification message to the equipment IOT sub-equipment serving as the receiver through a controller used by virtual equipment corresponding to the IOT sub-equipment serving as the receiver.
5. The method of claim 1, wherein the method further comprises:
if the new Internet of things sub-equipment is detected, corresponding virtual equipment for communication is established for the new Internet of things sub-equipment;
acquiring an object model conversion script corresponding to the equipment type of the new Internet of things sub-equipment from a cloud;
and accessing the new Internet of things sub-equipment into the Internet of things platform by using the object model conversion script corresponding to the new Internet of things sub-equipment.
6. The method of claim 1, wherein the method further comprises:
determining whether a locally existing object model conversion script needs to be updated;
and if so, acquiring a new object model conversion script from the cloud.
7. An internet of things system, comprising an internet of things platform, a gateway and an internet of things sub-device, wherein the internet of things platform is in communication connection with the internet of things sub-device through the gateway, and the gateway is used for executing the method of any one of claims 1-6 so as to convert interaction information between the internet of things platform and the internet of things sub-device into a communication message conforming to a protocol of a receiver of the interaction information and send the communication message to the receiver of the interaction information.
8. The system of claim 7, further comprising a cloud for editing and storing the object model conversion script, wherein the gateway is connected to the cloud and dynamically obtains the object model conversion script from the cloud.
9. An electronic device, comprising: the system comprises a processor, a memory, a communication interface and a communication bus, wherein the processor, the memory and the communication interface complete mutual communication through the communication bus;
the memory is used for storing at least one executable instruction which causes the processor to execute the corresponding operation of the method according to any one of claims 1-6.
10. A computer storage medium having stored thereon a computer program which, when executed by a processor, carries out the method of any one of claims 1 to 6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210646720.XA CN115102981A (en) | 2022-06-09 | 2022-06-09 | Data processing method, Internet of things system, electronic device and computer storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210646720.XA CN115102981A (en) | 2022-06-09 | 2022-06-09 | Data processing method, Internet of things system, electronic device and computer storage medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN115102981A true CN115102981A (en) | 2022-09-23 |
Family
ID=83289835
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202210646720.XA Pending CN115102981A (en) | 2022-06-09 | 2022-06-09 | Data processing method, Internet of things system, electronic device and computer storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN115102981A (en) |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115001772A (en) * | 2022-05-26 | 2022-09-02 | 深圳市恺恩科技有限公司 | Power transmission line Internet of things gateway control method, control system and computer readable storage medium |
| CN115514656A (en) * | 2022-09-30 | 2022-12-23 | 美的集团股份有限公司 | Object model adaptation method and device |
| CN115643316A (en) * | 2022-10-26 | 2023-01-24 | 杭州昊美科技有限公司 | Data processing method and device for Internet of things gateway, gateway equipment and storage medium |
| CN115695214A (en) * | 2022-10-28 | 2023-02-03 | 天翼数字生活科技有限公司 | Heterogeneous network equipment model conversion method, system, equipment and medium |
| CN116300510A (en) * | 2023-05-11 | 2023-06-23 | 深圳开鸿数字产业发展有限公司 | Device control method, edge computing device, and storage medium |
Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20160127514A1 (en) * | 2014-11-03 | 2016-05-05 | General Electric Company | Intelligent gateway with a common data format |
| CN106899594A (en) * | 2017-02-28 | 2017-06-27 | 杭州古北电子科技有限公司 | For the sub- device management method and system of smart home platform |
| US20180218368A1 (en) * | 2017-01-31 | 2018-08-02 | First Data Corporation | Data transformation engine |
| CN108696478A (en) * | 2017-04-06 | 2018-10-23 | 北京算云联科科技有限公司 | A kind of wireless access control system and method based on multiple transport protocols |
| CN109922150A (en) * | 2019-03-07 | 2019-06-21 | 深圳市简智联信息科技有限公司 | Virtual device information processing method, device, gateway of internet of things and Internet of Things communication system |
| FR3099256A1 (en) * | 2019-07-26 | 2021-01-29 | Amadeus Sas | CLOUD GATEWAY |
| CN113067811A (en) * | 2021-03-17 | 2021-07-02 | 北京自如信息科技有限公司 | Protocol conversion method, device, system, electronic equipment and storage medium |
-
2022
- 2022-06-09 CN CN202210646720.XA patent/CN115102981A/en active Pending
Patent Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20160127514A1 (en) * | 2014-11-03 | 2016-05-05 | General Electric Company | Intelligent gateway with a common data format |
| US20180218368A1 (en) * | 2017-01-31 | 2018-08-02 | First Data Corporation | Data transformation engine |
| CN106899594A (en) * | 2017-02-28 | 2017-06-27 | 杭州古北电子科技有限公司 | For the sub- device management method and system of smart home platform |
| CN108696478A (en) * | 2017-04-06 | 2018-10-23 | 北京算云联科科技有限公司 | A kind of wireless access control system and method based on multiple transport protocols |
| CN109922150A (en) * | 2019-03-07 | 2019-06-21 | 深圳市简智联信息科技有限公司 | Virtual device information processing method, device, gateway of internet of things and Internet of Things communication system |
| FR3099256A1 (en) * | 2019-07-26 | 2021-01-29 | Amadeus Sas | CLOUD GATEWAY |
| CN113067811A (en) * | 2021-03-17 | 2021-07-02 | 北京自如信息科技有限公司 | Protocol conversion method, device, system, electronic equipment and storage medium |
Cited By (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115001772A (en) * | 2022-05-26 | 2022-09-02 | 深圳市恺恩科技有限公司 | Power transmission line Internet of things gateway control method, control system and computer readable storage medium |
| CN115001772B (en) * | 2022-05-26 | 2023-03-24 | 深圳市恺恩科技有限公司 | Power transmission line Internet of things gateway control method, control system and computer readable storage medium |
| CN115514656A (en) * | 2022-09-30 | 2022-12-23 | 美的集团股份有限公司 | Object model adaptation method and device |
| CN115514656B (en) * | 2022-09-30 | 2024-03-29 | 美的集团股份有限公司 | Object model adaptation method and device |
| CN115643316A (en) * | 2022-10-26 | 2023-01-24 | 杭州昊美科技有限公司 | Data processing method and device for Internet of things gateway, gateway equipment and storage medium |
| CN115695214A (en) * | 2022-10-28 | 2023-02-03 | 天翼数字生活科技有限公司 | Heterogeneous network equipment model conversion method, system, equipment and medium |
| CN116300510A (en) * | 2023-05-11 | 2023-06-23 | 深圳开鸿数字产业发展有限公司 | Device control method, edge computing device, and storage medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN115102981A (en) | Data processing method, Internet of things system, electronic device and computer storage medium | |
| CN102136933B (en) | Equipment management method, middleware and machine communication platform, equipment and system | |
| CN113168332B (en) | Data processing method and device and mobile terminal | |
| CN111506366B (en) | Plug-in calling method, device, electronic device and storage medium | |
| CN109460250B (en) | Application program generation method and device | |
| CN113535724B (en) | Data processing method, device and computer readable storage medium | |
| CN112612452A (en) | API platform implementation method, device, equipment and storage medium | |
| CN113726762A (en) | Internet of things equipment protocol analysis method based on configuration file | |
| US10554726B1 (en) | Remote device drivers for internet-connectable devices | |
| EP3091435A1 (en) | Resource management method and device for terminal system | |
| CN111159019A (en) | Application program testing method, testing control terminal and testing terminal | |
| US20230214207A1 (en) | Device upgrade control method and apparatus, and computer device and storage medium | |
| CN114301970A (en) | Service calling method and device, electronic equipment and storage medium | |
| US11228502B2 (en) | Aggregation platform, requirement owner, and methods thereof | |
| CN110661850B (en) | Edge calculation method, system, computer equipment and storage medium | |
| CN106648805A (en) | Intelligent device, intelligent system, and method for intelligently installing application | |
| CN112540768B (en) | File processing method, device, server, electronic equipment and storage medium | |
| CN112272202B (en) | Method and system for communication between management software server and system internal components | |
| CN116418791A (en) | Firmware upgrading method, firmware upgrading system, server and storage medium | |
| CN115941818A (en) | A method for analyzing and controlling a hot-loaded industrial control protocol and a system having the same | |
| US20230179480A1 (en) | Method and apparatus for remote customization of function, device, and storage medium | |
| TW201635140A (en) | Method and system for installing application | |
| CN114338393B (en) | Upgrade data transmission method, transparent transmission device, apparatus, communication system and medium | |
| KR102437068B1 (en) | IoT common service provision method and apparatus to support service creation for IoT devices | |
| CN114285911A (en) | Data conversion method and device based on Internet of things, electronic equipment and readable medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20220923 |