CN111988348B - Data acquisition method and car networking control system - Google Patents

Abstract

The embodiment of the present invention discloses a data collection method and a control system for the Internet of Vehicles. The control system for the Internet of Vehicles includes a routing device and a plurality of computing nodes connected to the routing device. Each computing node corresponds to a plurality of data collection gateways, and the routing device It is used to receive the reported data from the Internet of Vehicles equipment and forward it to multiple computing nodes; the data acquisition gateway is used to collect data from the corresponding computing nodes and report it to the Internet of Vehicles control system. The Internet of Vehicles control system also includes: a first judgment module , used to judge whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the multiple data collection gateways corresponding to the first computing node; the collection module is used to use the idle The target data collection gateway collects the data to be collected by the first data collection gateway. The embodiment of the present invention can relieve the backlog of data at the data collection gateway, and improve the efficiency of data processing by the Internet of Vehicles control system.

Description

Data acquisition method and car networking control system

technical field

The invention relates to the field of vehicle networking control, in particular to a data collection method and a vehicle networking control system.

Background technique

With the rapid development of communication technology, IoT devices have been widely used in unmanned vehicles, new energy vehicles and other fields. Through the deployment of IoT devices, technicians can collect vehicle operating information in real time. Achieve intelligent operation, equipment anti-control and other purposes. Considering the operational requirements of IoV devices, current devices and platforms usually use TCP (Transmission Control Protocol, Transmission Control Protocol) as the underlying communication protocol. The TCP protocol can guarantee the reliability of data transmission to a certain extent. However, there are still many problems in terms of deduplication of duplicate data and rapid identification of equipment online. Vehicle networking equipment is installed in operating vehicles across the country, and the network conditions in the vehicle operating areas are not the same. For example, a large number of heavy trucks usually need to carry out long-distance transportation. When the vehicle enters places such as mountains and fields. Due to the poor network conditions, it is difficult to transmit the data collected by the equipment to the cloud in a timely manner. The device data collected at this time is usually stored locally first. When a vehicle enters an area with a better network environment, unbalanced data transmission will occur, and data backlogs will occur, which will cause systemic problems.

That is to say, in the prior art, there will be a backlog of data in the Internet of Vehicles control system, which reduces the efficiency of the system.

Contents of the invention

Embodiments of the present invention provide a data collection method and an Internet of Vehicles control system, which can adjust the configuration of computing resources in the system, avoid data backlogs, and improve the efficiency of data processing by the Internet of Vehicles control system.

In a first aspect, the present application provides a control system for the Internet of Vehicles, the control system for the Internet of Vehicles includes a routing device and a plurality of computing nodes connected to the routing device, each of the computing nodes corresponds to a plurality of data collection gateways, The routing device is used to receive the reported data of the Internet of Vehicles equipment and forward it to the plurality of computing nodes; the data collection gateway is used to collect data from corresponding computing nodes, and the Internet of Vehicles control system further includes:

A first judgment module, configured to judge whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the plurality of data collection gateways corresponding to the first computing node;

The collection module is configured to use an idle target data collection gateway to collect the data to be collected by the first data collection gateway when the first data collection gateway exists.

Further, the acquisition module specifically includes:

An acquisition submodule, configured to acquire the request instruction of the first computing node;

A determining submodule, configured to determine the target data collection gateway according to the request instruction;

The collection sub-module is configured to notify the target data collection gateway to use the target data collection gateway to collect the data to be collected by the first data collection gateway.

Further, the determining submodule is specifically used for:

Obtaining the data flow of multiple computing nodes connected to the routing device according to the request instruction;

determining a computing node with the smallest data flow among the plurality of computing nodes as the target computing node;

An idle second data collection gateway in the target computing node is determined as the target data collection gateway.

Further, the determining submodule is specifically used for:

judging according to the request instruction whether there is an idle third data collection gateway among the plurality of data collection gateways corresponding to the first computing node;

If it exists, determine that the third data collection gateway is the target data collection gateway.

Further, the vehicle networking control system also includes:

The second judging module is used to judge whether the reported data of the Internet of Vehicles device is obtained within a preset time;

A storage module, configured to store first preset information in a preset first data structure if the reported data of the Internet of Vehicles device is not obtained, so that the Internet of Vehicles device can be accessed from the first preset information when going online. Acquiring the first preset information in a data structure.

Further, the first preset information includes an upgrade package and/or a control instruction; the Internet of Vehicles control system further includes a deletion module, and the deletion module is specifically used for:

Acquire the number of times the first preset information is acquired;

judging whether the number of acquisitions reaches a preset number of times;

If yes, delete the first preset information.

Further, the storage module is specifically used for:

When the Internet of Vehicles control system is disconnected from the Internet of Vehicles device, acquiring the will information of the Internet of Vehicles device;

determining the first preset information according to the will information;

The first preset information is stored in the first data structure, so that the IoV device acquires the first preset information from the first data structure when going online.

In a second aspect, the present application provides a data collection method, the data collection method is applied to a control system of the Internet of Vehicles, and the control system of the Internet of Vehicles includes a routing device and a plurality of computing nodes connected to the routing device, each of which The computing nodes correspond to a plurality of data collection gateways respectively, and the data collection method includes:

receiving the reported data of the IoV device through the routing device, and forwarding it to the plurality of computing nodes;

collecting data from corresponding computing nodes through the data collection gateway;

Judging whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the plurality of data collection gateways corresponding to the first computing node;

If it exists, use an idle target data collection gateway to collect the data to be collected by the first data collection gateway.

Further, said using an idle target data collection gateway to collect the data to be collected by the first data collection gateway includes:

Obtain a request instruction of the first computing node;

determining the target data collection gateway according to the request instruction;

Notifying the target data collection gateway to use the target data collection gateway to collect the data to be collected by the first data collection gateway.

Further, the determining the target data collection gateway according to the request instruction includes:

Obtaining the data flow of multiple computing nodes connected to the routing device according to the request instruction;

determining a computing node with the smallest data flow among the plurality of computing nodes as the target computing node;

An idle second data collection gateway in the target computing node is determined as the target data collection gateway.

Further, the determining the target data collection gateway according to the request instruction includes:

judging according to the request instruction whether there is an idle third data collection gateway among the plurality of data collection gateways corresponding to the first computing node;

If it exists, determine that the third data collection gateway is the target data collection gateway.

Further, the data collection method also includes:

Judging whether the reported data of the Internet of Vehicles device is obtained within the preset time;

If the reported data of the IoV device is not obtained, storing the first preset information in a preset first data structure, so that the IOV device obtains it from the first data structure when going online The first preset information.

Further, the first preset information includes an upgrade package and/or a control instruction; the method further includes:

Acquire the number of times the first preset information is acquired;

judging whether the number of acquisitions reaches a preset number of times;

If yes, delete the first preset information.

Further, the storing the first preset information in a preset first data structure, so that the Internet of Vehicles device obtains the first preset information from the first data structure when going online, includes :

When the Internet of Vehicles control system is disconnected from the Internet of Vehicles device, acquiring the will information of the Internet of Vehicles device;

determining the first preset information according to the will information;

The first preset information is stored in the first data structure, so that the IoV device acquires the first preset information from the first data structure when going online.

Further, the data collection method also includes:

If the reported data of the Internet of Vehicles device is obtained, it is judged whether the reported data of the Internet of Vehicles device satisfies a preset condition;

If so, the second preset information is sent to the preset second data structure, so that the IoV device acquires the second preset information immediately.

In a third aspect, the present invention also provides a server, and the server includes:

one or more processors;

storage; and

One or more application programs, wherein the one or more application programs are stored in the memory and configured to be executed by the processor to implement the data collection method according to any one of the second aspect.

In the fourth aspect, the present invention also provides a storage medium, wherein a plurality of instructions are stored in the storage medium, and the instructions are suitable for being loaded by a processor to execute the data collection method described in any one of the second aspect. A step of.

An embodiment of the present invention provides a data collection method and a control system for the Internet of Vehicles. The control system for the Internet of Vehicles includes a routing device and a plurality of computing nodes connected to the routing device. Each computing node corresponds to a plurality of data collection gateways. The routing device uses It is used to receive the reported data from the Internet of Vehicles equipment and forward it to multiple computing nodes; the data collection gateway is used to collect data from the corresponding computing nodes and report it to the Internet of Vehicles control system. The Internet of Vehicles control system also includes: a first judgment module, It is used to judge whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the multiple data collection gateways corresponding to the first computing node; the collection module is used to use an idle target when there is a first data collection gateway The data collection gateway collects the data to be collected by the first data collection gateway. In the embodiment of the present invention, it is found that among the data collection gateways corresponding to the first computing node, there is a first data collection gateway whose data collection speed is greater than the data reporting speed, and the idle target collection gateway other than the first data collection gateway is used in time to collect the second data collection gateway. The data to be collected by a data collection gateway relieves the data backlog at the first data collection gateway and improves the data processing efficiency of the Internet of Vehicles control system.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present invention, the drawings that need to be used in the description of the embodiments will be briefly introduced below. Obviously, the drawings in the following description are only some embodiments of the present invention. For those skilled in the art, other drawings can also be obtained based on these drawings without any creative effort.

FIG. 1 is a schematic structural diagram of an embodiment of the interaction between the Internet of Vehicles control system and the Internet of Vehicles device provided by the embodiment of the present invention;

Fig. 2 is a schematic flow chart of an embodiment of the data acquisition method provided by the embodiment of the present invention;

Fig. 3 is a schematic flow chart of an embodiment of step 204 in the embodiment shown in Fig. 2;

Fig. 4 is a schematic flowchart of another embodiment of the data collection method provided by the embodiment of the present invention based on the embodiment shown in Fig. 2;

FIG. 5 is a schematic structural diagram of an embodiment of a vehicle networking control system provided by an embodiment of the present invention;

Fig. 6 is a schematic structural diagram of an embodiment of a server provided by an embodiment of the present invention.

specific embodiment

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some, not all, embodiments of the present invention. Based on the embodiments of the present invention, all other embodiments obtained by those skilled in the art without creative efforts fall within the protection scope of the present invention.

In describing the present invention, it should be understood that the terms "center", "longitudinal", "transverse", "length", "width", "thickness", "upper", "lower", "front", " The orientation or positional relationship indicated by "rear", "left", "right", "vertical", "horizontal", "top", "bottom", "inner", "outer", etc. is based on the orientation shown in the drawings Or positional relationship is only for the convenience of describing the present invention and simplifying the description, but does not indicate or imply that the device or element referred to must have a specific orientation, be constructed and operated in a specific orientation, and therefore should not be construed as limiting the present invention. In addition, the terms "first" and "second" are used for descriptive purposes only, and cannot be interpreted as indicating or implying relative importance or implicitly specifying the quantity of indicated technical features. Thus, features defined as "first" and "second" may explicitly or implicitly include one or more features. In the description of the present invention, "plurality" means two or more, unless otherwise specifically defined.

In the present invention, the word "exemplary" is used to mean "serving as an example, illustration or illustration". Any embodiment described herein as "exemplary" is not necessarily to be construed as preferred or advantageous over other embodiments. The following description is given to enable any person skilled in the art to make and use the invention. In the following description, details are set forth for purposes of explanation. It should be understood that one of ordinary skill in the art would recognize that the present invention may be practiced without the use of these specific details. In other instances, well-known structures and procedures are not described in detail to avoid obscuring the description of the present invention with unnecessary detail. Thus, the present invention is not intended to be limited to the embodiments shown but is to be accorded the widest scope consistent with the principles and features disclosed herein.

Embodiments of the present invention provide a data collection method, device, system, and storage medium. Each will be described in detail below.

Please refer to FIG. 1. FIG. 1 is a schematic structural diagram of an embodiment of an IoV control system and an IOV device provided by an embodiment of the present invention. The IOV control system is used to exchange data with the IOV device. The vehicle networking control system may be located in a server, and the server may be a single server or a server cluster, such as a message queue telemetry transport (Message Queuing Telemetry Transport, MQTT) server cluster.

The Internet of Vehicles device is a vehicle-mounted terminal installed on the vehicle. The Internet of Vehicles device is mainly a device that integrates some components such as sensing equipment, radar, GPS equipment, video recording, and image capture. Different Internet of Vehicles devices mainly have different components and types. That's all. The collection of data is mainly through the collection of components in the Internet of Vehicles equipment. Each component has its own mechanism, and there will be corresponding controllers, electronic circuits, etc. in it to realize signal amplification and conversion from analog signals to digital signals. The final digital signal is the collected data; GPS equipment can collect the longitude, latitude, altitude and other information of the current location; the image capture of the camera equipment can take pictures, and the photos are the data it collects, which can be reported in a specific format and code. Generally, the Internet of Vehicles device can be connected to at least one of GPS devices, smoke alarms, intelligent anti-collision devices, fatigue detection devices, tire pressure monitoring devices, and camera devices, preferably more than one.

Among them, the GPS device is configured to collect the location data of the vehicle; the smoke alarm is configured to collect the smoke alarm data of the vehicle; the intelligent anti-collision device is configured to collect the intelligent anti-collision alarm data of the vehicle; Fatigue detection data; tire pressure monitoring equipment is configured to collect tire pressure monitoring data of vehicles; camera equipment is configured to collect relevant data on the vehicle body and its surroundings to realize location data, smoke alarm data, intelligent anti-collision alarm data, fatigue Collection of at least one item of detection data, tire pressure monitoring data, body and surrounding data. By creating different MQTT topics for the data, such as: location data, traffic violation data, ADAS protocol data, picture capture and video data, etc., the collected data of different topics reported by the vehicle terminal is formed. The collected data reported by the Internet of Vehicles device is reported according to the agreed MQTT protocol and format, such as: json format, binary format, etc. After the Internet of Vehicles control system reads the data from the subject, it must convert the real data according to the agreement and format. The data is parsed out and stored for subsequent data analysis and use.

When the network condition is good, the Internet of Vehicles device will report the collected data to the corresponding topic of the Internet of Vehicles control system (such as MQTT server cluster) in real time, and cache the collected data in the Internet of Vehicles when the network is disconnected or the network condition is not good. Locally on the device, the collected data to be reported by the Internet of Vehicles device is cached locally on the Internet of Vehicles device, which can be cached locally, and then pushed to the corresponding topic of the Internet of Vehicles control system in batches when the Internet of Vehicles or the network situation improves. The system receives and stores collected data of different topics reported by the Internet of Vehicles devices.

In the embodiment of the present invention, as shown in FIG. 1 , the Internet of Vehicles control system includes a routing device 11 and a plurality of computing nodes 12 connected to the routing device 11 . The routing device 11 is used to receive the data reported by the IoV device 14 and forward it to multiple computing nodes 12 . Each computing node 12 corresponds to a plurality of data collection gateways 13 , and each data collection gateway 13 collects data from the corresponding computing node 12 . The Internet of Vehicles device 14 can collect temperature data, location data, humidity data, transmitter data, etc. of the vehicle through sensors and send them to the routing device 11 , or receive data sent by the routing device 11 . The number of computing nodes 12 connected to the routing device 11 and the number of data collection gateways 13 connected to the computing nodes 12 are set according to specific conditions, which is not limited in the present invention.

In a specific embodiment, the Internet of Vehicles device 14 collects data such as temperature data, location data, and humidity data of the vehicle, and sends them to the routing device 11 . The routing device 11 sends data of different topics to multiple computing nodes 12 according to preset forwarding rules, and counts the forwarded data. Preferably, the routing device 11 forwards the same data only once. Multiple data collection gateways 13 connected to computing nodes 12 collect data from corresponding computing nodes 12 respectively. Since each piece of data of the Internet of Vehicles device is forwarded through the routing device 11, and the forwarded data is counted, it can be guaranteed that each piece of data is only consumed once. The present invention is not limited thereto. The routing device 11 can be an independent device such as a router or a routing server. It can be understood that, in other embodiments of the present invention, the routing device 11, the computing node 12 and the data collection gateway 13 can also be integrated into one collection device, that is, the routing device 11 may also be a module in the collection device, such as a routing layer, etc., which is not limited here.

Referring to FIG. 2 , FIG. 2 is a schematic flowchart of an embodiment of a data collection method provided by an embodiment of the present invention. It should be noted that, in the embodiment of the present invention, the main body that executes the data collection method is the Internet of Vehicles control system, and the Internet of Vehicles control system is located in the server. The specific process of the data collection method can be as follows:

201. Receive the data reported by the IoV device through the routing device, and forward the data to the multiple computing nodes.

202. Collect data from corresponding computing nodes through the data collection gateway.

203. Determine whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the plurality of data collection gateways corresponding to the first computing node. If yes, perform step 204. If not, do not process.

In a specific embodiment, the Internet of Vehicles control system can separately obtain the data collection speed and data reporting speed of multiple data collection gateways 13 corresponding to each computing node. According to the data collection speed and data reporting speed of the data collection gateway 13, the IoV control system can determine whether there is a first data collection gateway whose data collection speed is faster than the data reporting speed.

Since the data collection speed of the data collection gateway is greater than the data reporting speed, the collected data cannot be reported in time, and data backlogs are prone to occur. The Internet of Vehicles control system can simultaneously judge the data collection speed and data reporting speed of each data collection gateway corresponding to multiple computing nodes, and can also execute computing nodes sequentially or according to a preset strategy. In this embodiment of the present invention, Not limited.

Similarly, for a certain computing node, the Internet of Vehicles control system can also simultaneously execute and judge the data collection speed and data reporting speed of the corresponding multiple data collection gateways, and can also execute sequentially according to the data collection gateway, or according to the preset strategy Execute, which is not limited in this embodiment of the present invention.

Preferably, the Internet of Vehicles control system can sequentially judge whether there is a first data collection gateway whose data collection speed is faster than the data reporting speed among the multiple data collection gateways corresponding to each computing node according to a preset frequency. The preset frequency can be set according to specific conditions. By monitoring each data collection gateway, the first data collection gateway with data backlog can be found in time, and then the data backlog can be dealt with in a timely manner through subsequent strategies.

204. Use an idle target data collection gateway to collect the data to be collected by the first data collection gateway.

In the embodiment of the present invention, it is found that among the data collection gateways corresponding to the first computing node, there is a first data collection gateway whose data collection speed is greater than the data reporting speed, and the idle target collection gateway other than the first data collection gateway is used in time to collect the second data collection gateway. The data to be collected by a data collection gateway relieves the data backlog at the first data collection gateway and improves the data processing efficiency of the Internet of Vehicles control system.

In the embodiment of the present invention, if the IoV control system determines that among the multiple data collection gateways corresponding to the first computing node, there is a first data collection gateway whose data collection speed is greater than the data reporting speed. Indicates that a data backlog may occur at the first data collection gateway. At this point, in one embodiment of the present invention, as shown in FIG. 3 , the collection of the data to be collected by the first data collection gateway using an idle target data collection gateway may include:

301. Acquire a request instruction of the first computing node.

In the embodiment of the present invention, if the data collection speed of a certain data collection gateway corresponding to the first computing node is greater than the data reporting speed, the first computing node is triggered to send the request instruction. That is, the request command is sent by the computing node when it judges that the data collection speed of the first data collection gateway is greater than the data reporting speed, and the first data collection gateway is a data collection gateway corresponding to the computing node

302. Determine the target data collection gateway according to the request instruction.

In the embodiment of the present invention, in step 302, the determination of the target data collection gateway according to the request instruction can be implemented in multiple ways, specifically as follows:

(1) Mobilize the currently idle data collection gateway in the first computing node to collect the data to be collected by the first data collection gateway.

In a specific implementation manner, the determining the target data collection gateway according to the request instruction may include: judging according to the request instruction whether among the plurality of data collection gateways corresponding to the first computing node There is an idle third data collection gateway; if there is, it is determined that the third data collection gateway is the target data collection gateway.

In the embodiment of the present invention, if the Internet of Vehicles control system determines that there is an idle target data collection gateway among the multiple data collection gateways corresponding to the first computing node. The idle third data collection gateway corresponding to the first computing node can be notified directly to collect the data to be collected by the first data collection gateway without requesting the IoV control system to allocate resources of other computing nodes. That is, the computing node uses the target data collection gateway connected to itself to collect the data to be collected by the first data collection gateway. Since the third data acquisition gateway is directly connected to the first computing node, the response speed of the control system of the Internet of Vehicles can be improved, and the data backlog can be eliminated more quickly.

(2) mobilize idle data collection gateways in other computing nodes to collect data to be collected by the first data collection gateway.

In a specific implementation manner, the determining the target data collection gateway according to the request instruction may include: obtaining the data flow of multiple computing nodes connected to the routing device according to the request instruction; The computing node with the smallest data flow among the plurality of computing nodes is determined as the target computing node; and an idle second data collection gateway among the target computing nodes is determined as the target data collection gateway. Wherein, the target computing node may be the first computing node, or may not be the first computing node. In general, due to method (1), it is preferably other computing nodes other than the first computing node, that is, preferably, the target computing node The node is different from the first computing node.

In addition, in other embodiments of the present invention, the manner of acquiring the data traffic of multiple computing nodes 12 connected to the routing device 11 may also determine the target computing node according to other strategies, which is not limited in the present invention.

In the embodiment of the present invention, when there is a first data collection gateway with a backlog of data, other idle data collection gateways are mobilized to collect the data to be collected by the first data collection gateway, thereby avoiding data backlog and improving system efficiency.

It should be noted that, in the embodiment of the present invention, the idle data collection gateway referred to may be a data collection gateway whose amount of data to be processed is lower than a preset value, and the preset value may be 1M, 2M, 5M, etc., the present invention This is not limited in the embodiments. In other embodiments of the present invention, the idle data collection gateway may also be a data collection gateway whose difference between the data collection speed and the data reporting speed is higher than the preset speed, which is set according to specific circumstances, and the present invention does not limit this.

303. Notify the target data collection gateway to use the target data collection gateway to collect the data to be collected by the first data collection gateway.

In the embodiment of the present invention, if the IoV control system determines that there is no idle data collection gateway among the multiple data collection gateways corresponding to the first computing node. It is necessary for the Internet of Vehicles control system to allocate resources of other computing nodes. Specifically, the first computing node 12 sends a request instruction through the routing device 11, and the Internet of Vehicles control system receives the request instruction, so that the Internet of Vehicles control system determines an idle target data collection gateway according to the request instruction, and notifies the target data collection gateway The gateway is configured to collect the data to be collected by the first data collection gateway. That is, using the idle resources of the target computing node can avoid the data backlog of the corresponding computing node caused by the data backlog of a single data collection gateway, and improve the resource utilization rate of the IoV control system. In addition, sending a notification to the target computing node through the routing device can ensure that the data is only sent to one node, thereby realizing the data sharing function.

Referring to FIG. 4, FIG. 4 is a schematic flowchart of another embodiment of the data collection method provided by the embodiment of the present invention. In the embodiment of the present invention, the main body that executes the data collection method is the Internet of Vehicles control system. The specific process of the data collection method can be as follows:

401. Determine whether the data reported by the IoV device is obtained within a preset time.

In this embodiment, if the reported data of the IoV device is not obtained within the preset time, it can be determined that the IOV device is offline; if the reported data of the IOV device is obtained within the preset time, it can be determined that the IOV device The device is in the online state, and the preset time may be preset, such as 1 minute or 1 hour, etc., which is not limited here.

In the embodiment of the present invention, the IoV control system can monitor the data collection gateway to determine whether the data reported by the IoV device is obtained.

In the embodiment of the present invention, if the IoV control system does not obtain the reported data of the IoV device, then execute step 402; if the reported data of the IOV device is obtained, then execute step 403. That is, according to whether the Internet of Vehicles device is online, the Internet of Vehicles device is processed differently, and the data is distributed and transmitted through classified management, which can avoid data backlog.

402. If the reported data of the IoV device is not obtained, store the first preset information in a preset first data structure, so that the IoV device can read from the first data structure when going online to obtain the first preset information.

In the embodiment of the present invention, if the IoV control system does not obtain the reported data of the IOV device, it indicates that the IOV device is offline. If the first preset information is sent to the IOV device at this time (the first preset information is Instructions or upgrade packages for offline IoV devices) may cause data loss or data backlog. The IoV control system stores the first preset information in a preset first data structure, so that the IOV device obtains the first preset information from the first data structure when going online. That is, if it is determined that the IoV device is offline, the first preset information is stored in the first data structure, which can avoid loss of the first preset information or data backlog, and reduce the load of the IOV control system.

In a specific embodiment, if the Internet of Vehicles control system does not obtain the reported data of the Internet of Vehicles device, it indicates that the Internet of Vehicles device is offline, and the Internet of Vehicles control system obtains the will information of the Internet of Vehicles device. Specifically, when the Internet of Vehicles control system is disconnected from the Internet of Vehicles device, it acquires the will information of the Internet of Vehicles device.

After the Internet of Vehicles control system obtains the will information of the Internet of Vehicles equipment, the Internet of Vehicles control system determines the first preset information according to the last words information; the Internet of Vehicles control system stores the first preset information in the first data structure, so that the Internet of Vehicles control The system obtains the first preset information when going online. That is to say, through the will information, the IoV control system can not only quickly detect the offline IoV devices, but also release corresponding information on the offline IoV devices according to the setting rules in the will information.

In a preferred embodiment, if the Internet of Vehicles control system does not obtain the reported data of the Internet of Vehicles device, it judges whether there is will information in the Internet of Vehicles control system, and if it exists, then obtains the last word information of the Internet of Vehicles device; if not , then a prompt message is issued to prompt the user to publish the first preset message. That is, if there is last word information, the first preset information is obtained according to the last word information, and if there is no last word information, the user is prompted to publish the first preset information.

Further, the first preset information includes upgrade packages and/or control instructions, and the preset first data structure is an online queue. A queue is a special linear table, which is special in that it only allows deletion operations at the front end of the table, and insert operations at the back end of the table. Like a stack, a queue is a linear table with limited operations. The end of the insertion operation is called the tail of the queue, and the end of the deletion operation is called the head of the queue. When there are no elements in the queue, it is called an empty queue. The data elements of a queue are also called queue elements. Inserting a queue element into the queue is called enqueuing, and removing a queue element from the queue is called dequeuing. Because the queue only allows insertion at one end and deletion at the other end, only the elements that enter the queue first can be deleted from the queue first, so the queue is also called a first-in-first-out linear list. Elements in the online queue are removed after being fetched a preset number of times.

After the Internet of Vehicles control system sends the first preset information to the online queue, the Internet of Vehicles control system obtains the number of times the first preset information is acquired; the Internet of Vehicles control system judges whether the number of acquisitions reaches the preset number of times; if so, delete The first preset information. Wherein, the preset number of times can be 1 time, 2 times, 3 times or more times, which is set according to specific conditions. By counting the number of acquisitions of the first preset information and deleting it after the first preset information is acquired the preset number of times, on the one hand, the first preset information can be downloaded multiple times, preventing the Internet of Vehicles device from going offline When the first preset information cannot be obtained when going online again; on the other hand, after the multi-vehicle networking device finishes downloading the upgrade package or executes the control command, the online queue is cleaned up in time, the upgrade channel is closed, etc., reducing the load on the system.

403. Determine whether the data reported by the IoV device meets a preset condition.

In the embodiment of the present invention, if the IOV control system obtains the reported data of the IOV device, it indicates that the IOV device is online, and determines whether the reported data of the IOV device satisfies a preset condition. If the data reported by the Internet of Vehicles device meets the preset condition, execute 404; if the data reported by the Internet of Vehicles device does not meet the preset condition, end or return. The preset conditions are set according to specific situations. For example, the preset conditions are that the temperature in the reported data is lower than the preset temperature, the humidity in the reported data is lower than or higher than the preset humidity, etc., which are not limited in the present invention. That is, the IoV control system monitors in real time the data reported by IOV devices.

404. Store the second preset information in a preset second data structure, so that the IoV device acquires the second preset information immediately.

In the embodiment of the present invention, if the reported data of the IoV device satisfies the preset condition, the second preset information is stored in the preset second data structure, so that the IOV device can obtain the second preset information (second The preset information is a control instruction for the online IoV device). Preferably, the preset second data structure is an instant queue, and the second preset information in the instant queue is deleted or transferred after being acquired once. Wherein, the second preset information is determined according to the reported data, and may be an upgrade package, a control instruction, and the like. That is to say, real-time monitoring and real-time feedback of the IOV equipment through the real-time queue can detect abnormal conditions of the vehicle and deal with them in time, improving the efficiency of the IOV control system and avoiding data backlogs.

The embodiment of the present invention also provides a car networking control system, as shown in Figure 5, which is a schematic structural diagram of an embodiment of the car networking control system in the embodiment of the present invention, the car networking control system includes the In addition to the routing device 11, multiple computing nodes 12, and multiple data collection gateways 13, the vehicle networking control system 500 also includes:

The first judgment module 501 is configured to judge whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the plurality of data collection gateways corresponding to the first computing node;

The collection module 502 is configured to use an idle target data collection gateway to collect the data to be collected by the first data collection gateway when the first data collection gateway exists.

Further, the acquisition module 502 specifically includes:

An acquisition submodule, configured to acquire the request instruction of the first computing node;

A determining submodule, configured to determine the target data collection gateway according to the request instruction;

The collection sub-module is configured to notify the target data collection gateway to use the target data collection gateway to collect the data to be collected by the first data collection gateway.

Further, the determining submodule is specifically used for:

Obtaining the data flow of multiple computing nodes connected to the routing device according to the request instruction;

determining a computing node with the smallest data flow among the plurality of computing nodes as the target computing node;

An idle second data collection gateway in the target computing node is determined as the target data collection gateway.

Further, the determining submodule is specifically used for:

judging according to the request instruction whether there is an idle third data collection gateway among the plurality of data collection gateways corresponding to the first computing node;

If it exists, determine that the third data collection gateway is the target data collection gateway.

Further, the vehicle networking control system also includes:

The second judging module is used to judge whether the reported data of the Internet of Vehicles device is obtained within a preset time;

A storage module, configured to store first preset information in a preset first data structure if the reported data of the Internet of Vehicles device is not obtained, so that the Internet of Vehicles device can be accessed from the first preset information when going online. Acquiring the first preset information in a data structure.

Further, the first preset information includes an upgrade package and/or a control instruction; the Internet of Vehicles control system further includes a deletion module, and the deletion module is specifically used for:

Acquire the number of times the first preset information is acquired;

judging whether the number of acquisitions reaches a preset number of times;

If yes, delete the first preset information.

Further, the storage module is specifically used for:

When the Internet of Vehicles control system is disconnected from the Internet of Vehicles device, acquiring the will information of the Internet of Vehicles device;

determining the first preset information according to the will information;

The first preset information is stored in the first data structure, so that the IoV device acquires the first preset information from the first data structure when going online.

In the embodiment of the present invention, the Internet of Vehicles control system includes a routing device and multiple computing nodes connected to the routing device. Each computing node corresponds to a plurality of data collection gateways. The routing device is used to receive the data reported by the Internet of Vehicles equipment and forward it to Multiple computing nodes; the data collection gateway is used to collect data from corresponding computing nodes and report to the IoV control system. The IOV control system also includes: a first judging module for judging multiple data corresponding to the first computing node In the collection gateway, whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed; the collection module is used to collect the first data collection gateway to be collected by the idle target data collection gateway when there is a first data collection gateway data. In the embodiment of the present invention, it is found that among the data collection gateways corresponding to the first computing node, there is a first data collection gateway whose data collection speed is greater than the data reporting speed, and the idle target collection gateway other than the first data collection gateway is used in time to collect the second data collection gateway. The data to be collected by a data collection gateway relieves the data backlog at the first data collection gateway and improves the data processing efficiency of the Internet of Vehicles control system.

The embodiment of the present invention also provides a server, and the server includes:

one or more processors;

storage; and

One or more application programs, wherein the one or more application programs are stored in the memory and are configured to be executed by the processor in the steps in any one of the above embodiments of the data collection method.

As shown in Figure 6, Figure 6 is a schematic structural diagram of an embodiment of the server provided by the embodiment of the present invention, which shows a schematic structural diagram of the server involved in the embodiment of the present invention, specifically:

The server may include a processor 601 of one or more processing cores, a memory 602 of one or more computer-readable storage media, a power supply 603, an input unit 604 and other components. Those skilled in the art can understand that the server structure shown in FIG. 6 is not limited to the server, and may include more or less components than shown in the figure, or combine some components, or arrange different components. in:

The processor 601 is the control center of the server, and uses various interfaces and lines to connect various parts of the entire server, by running or executing software programs and/or modules stored in the memory 602, and calling data stored in the memory 602, Execute various functions of the server and process data to monitor the server as a whole. Optionally, the processor 601 may include one or more processing cores; preferably, the processor 601 may integrate an application processor and a modem processor, wherein the application processor mainly processes operating systems, user interfaces, and application programs, etc. , the modem processor mainly handles wireless communications. It can be understood that the foregoing modem processor may not be integrated into the processor 601 .

The memory 602 can be used to store software programs and modules, and the processor 601 executes various functional applications and data processing by running the software programs and modules stored in the memory 602 . The memory 602 can mainly include a program storage area and a data storage area, wherein the program storage area can store an operating system, at least one application program required by a function (such as a sound playback function, an image playback function, etc.); The data created by the use of the server, etc. In addition, the memory 602 may include a high-speed random access memory, and may also include a non-volatile memory, such as at least one magnetic disk storage device, flash memory device, or other volatile solid-state storage devices. Correspondingly, the memory 602 may further include a memory controller to provide the processor 601 with access to the memory 602 .

The server also includes a power supply 603 for supplying power to various components. Preferably, the power supply 603 can be logically connected to the processor 601 through the power management system, so that functions such as charging, discharging, and power consumption management can be realized through the power management system. The power supply 603 may also include one or more DC or AC power supplies, recharging systems, power failure detection circuits, power converters or inverters, power status indicators and other arbitrary components.

The server can also include an input unit 604, which can be used to receive input numbers or character information, and generate keyboard, mouse, joystick, optical or trackball signal input related to user settings and function control.

Although not shown, the server may also include a display unit, etc., which will not be repeated here. Specifically, in the embodiment of the present invention, the server stores an Internet of Vehicles control system, the Internet of Vehicles control system includes a routing device and a plurality of computing nodes connected to the routing device, and each of the computing nodes corresponds to multiple A data acquisition gateway, the processor 601 in the server will load the executable file corresponding to the process of one or more application programs into the memory 602 according to the following instructions, and run and store in the memory 602 by the processor 601 The application program, so as to realize various functions, as follows:

receiving the reported data of the IoV device through the routing device, and forwarding it to the plurality of computing nodes;

collecting data from corresponding computing nodes through the data collection gateway;

Judging whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the plurality of data collection gateways corresponding to the first computing node;

If it exists, use an idle target data collection gateway to collect the data to be collected by the first data collection gateway.

Those of ordinary skill in the art can understand that all or part of the steps in the various methods of the above embodiments can be completed by instructions, or by instructions controlling related hardware, and the instructions can be stored in a computer-readable storage medium, and is loaded and executed by the processor.

To this end, an embodiment of the present invention provides a storage medium, and the storage medium may include: a read only memory (ROM, Read Only Memory), a random access memory (RAM, Random Access Memory), a magnetic disk or an optical disk, and the like. A plurality of instructions are stored in the storage medium, and the instructions can be loaded by a processor to execute the steps in any data collection method provided by the embodiments of the present invention. For example, the command can perform the following steps:

receiving the reported data of the IoV device through the routing device, and forwarding it to the plurality of computing nodes;

collecting data from corresponding computing nodes through the data collection gateway;

Judging whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the plurality of data collection gateways corresponding to the first computing node;

If it exists, use an idle target data collection gateway to collect the data to be collected by the first data collection gateway.

In the above-mentioned embodiments, the descriptions of each embodiment have their own emphases. For the part that is not described in detail in a certain embodiment, refer to the detailed description of other embodiments above, and will not be repeated here.

During specific implementation, each of the above units or structures can be implemented as an independent entity, or can be combined arbitrarily as the same or several entities. For the specific implementation of each of the above units or structures, please refer to the previous method embodiments, here No longer.

A data acquisition method and a vehicle networking control system provided by the embodiments of the present invention have been introduced in detail above. In this paper, specific examples have been used to illustrate the principles and embodiments of the present invention. The descriptions of the above embodiments are only used to help Understand the method of the present invention and its core idea; at the same time, for those skilled in the art, according to the idea of the present invention, there will be changes in the specific embodiments and application scope. In summary, the content of this specification should not be understood as Limitations on the Invention.

Claims (5)

1. A control system for the Internet of Vehicles, characterized in that the control system for the Internet of Vehicles includes a routing device and a plurality of computing nodes connected to the routing device, each of the computing nodes corresponds to a plurality of data acquisition gateways, so The routing device is used to receive the reported data of the Internet of Vehicles equipment and forward it to the plurality of computing nodes; the data collection gateway is used to collect data from the corresponding computing nodes, and the Internet of Vehicles control system also includes: The first judging module is used to sequentially judge whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the plurality of data collection gateways corresponding to each first computing node according to a preset frequency; A collection module, configured to use an idle target data collection gateway to collect the data to be collected by the first data collection gateway when the first data collection gateway exists, and the collection module specifically includes: An acquisition submodule, configured to acquire the request instruction of the first computing node; The determining submodule is configured to determine the target data collection gateway according to the request instruction; wherein, the determining submodule is specifically used to: obtain the data flow of multiple computing nodes connected to the routing device according to the request instruction ; determining the computing node with the smallest data flow among the plurality of computing nodes as the target computing node; determining an idle second data collection gateway among the target computing nodes as the target data collection gateway; or, According to the request instruction, it is judged whether there is an idle third data collection gateway among the plurality of data collection gateways corresponding to the first computing node; if there is, determining that the third data collection gateway is the target data collection gateway; The collection sub-module is configured to notify the target data collection gateway to use the target data collection gateway to collect the data to be collected by the first data collection gateway. 2. The Internet of Vehicles control system according to claim 1, wherein the Internet of Vehicles control system further comprises: The second judging module is used to judge whether the reported data of the Internet of Vehicles device is obtained within a preset time; A storage module, configured to store first preset information in a preset first data structure if the reported data of the Internet of Vehicles device is not obtained, so that the Internet of Vehicles device can be accessed from the first preset information when going online. Acquiring the first preset information in a data structure. 3. The Internet of Vehicles control system according to claim 2, wherein the first preset information includes an upgrade package and/or a control instruction; the Internet of Vehicles control system further includes a deletion module, and the deletion module specifically Used for: Acquire the number of times the first preset information is acquired; judging whether the number of acquisitions reaches a preset number of times; If yes, delete the first preset information. 4. The vehicle networking control system according to claim 2 or 3, wherein the storage module is specifically used for: When the Internet of Vehicles control system is disconnected from the Internet of Vehicles device, acquiring the will information of the Internet of Vehicles device; determining the first preset information according to the will information; The first preset information is stored in the first data structure, so that the IoV device acquires the first preset information from the first data structure when going online. 5. A data acquisition method, characterized in that the data acquisition method is applied to a control system of the Internet of Vehicles, the control system of the Internet of Vehicles includes a routing device and a plurality of computing nodes connected to the routing device, each of the Computing nodes respectively correspond to multiple data collection gateways, and the data collection method includes: receiving the reported data of the IoV device through the routing device, and forwarding it to the plurality of computing nodes; collecting data from corresponding computing nodes through the data collection gateway; According to the preset frequency, sequentially judge whether there is a first data collection gateway whose data collection speed is greater than the data reporting speed among the plurality of data collection gateways corresponding to each first computing node; If it exists, using an idle target data collection gateway to collect the data to be collected by the first data collection gateway; said using the idle target data collection gateway to collect the data to be collected by the first data collection gateway includes: Obtain a request instruction of the first computing node; determining the target data collection gateway according to the request instruction; Notifying the target data collection gateway to use the target data collection gateway to collect the data to be collected by the first data collection gateway; The determining the target data collection gateway according to the request instruction includes: Obtaining the data flow of multiple computing nodes connected to the routing device according to the request instruction; determining a computing node with the smallest data flow among the plurality of computing nodes as the target computing node; An idle second data collection gateway in the target computing node is determined as the target data collection gateway.

Images