Disclosure of Invention
The application provides a vehicle data uploading method and a related device thereof, which are used for solving the technical problems that in the prior art, large batch of vehicle data cannot be uploaded, the vehicle data is required to be uploaded in a specified area, the vehicle data is uploaded according to a time sequence, and important data cannot be uploaded in time.
In view of this, the present application provides, in a first aspect, a vehicle data uploading method, applying a cloud, where the method includes:
receiving target information of vehicle data sent by a vehicle end, and generating task information of the vehicle data according to the target information of the vehicle data, wherein the task information of the vehicle data comprises an uploading priority of the vehicle data;
receiving an edge computing device recommendation request sent by the vehicle end, and returning device information of idle edge computing devices to the vehicle end according to the resource load condition of the edge computing devices and request parameters carried by the edge computing device recommendation request; the edge computing device recommends that the request is sent by the vehicle end after copying all the vehicle data to a storage medium; the storage medium is used for connecting the edge computing equipment corresponding to the equipment information; the edge computing device is used for copying all the vehicle data in a new storage medium to the local part and sending a data uploading request to the cloud end when detecting that the new storage medium is accessed;
receiving a data uploading request sent by the edge computing equipment, and returning corresponding task information to the edge computing equipment according to request parameters carried by the data uploading request, so that the edge computing equipment uploads the vehicle data to the cloud end according to the uploading priority of the vehicle data in the task information;
and receiving and storing the vehicle data uploaded by the edge computing equipment.
Optionally, the target information includes a data type, an automatic driving scene, and a data time;
generating the uploading priority of the vehicle data according to the target information of the vehicle data, wherein the uploading priority comprises the following steps:
determining data type parameters, automatic driving scene parameters and time coefficients of the vehicle data according to the data type, the automatic driving scene and the data time of the vehicle data;
and calculating the uploading priority of the vehicle data according to the data type parameters, the automatic driving scene parameters and the time coefficient of the vehicle data.
Optionally, the task information further includes a data processing task, and the data processing task includes a data integrity check task, a data cleaning task, and/or a data compression task.
Optionally, the uploading, by the edge computing device, the vehicle data to the cloud according to the uploading priority of the vehicle data in the task information includes:
the edge computing equipment creates a data uploading task in a data uploading task queue according to the task information;
the edge computing equipment calls a high-priority data uploading task from the data uploading task queue according to the uploading priority of the vehicle data and analyzes task information of the high-priority data uploading task;
when the task information of the high-priority data uploading task comprises the data processing task, the edge computing device performs data processing on the vehicle data corresponding to the high-priority data uploading task according to the data processing task, and uploads the vehicle data after data processing to the cloud.
Optionally, the request parameters carried by the recommendation request of the edge computing device include an identifier and position information of the vehicle end;
the returning of the device information of the idle edge computing device to the vehicle end according to the resource load condition of the edge computing device and the request parameter carried by the recommendation request of the edge computing device comprises:
and returning the equipment information of the idle edge computing equipment closest to the vehicle end according to the resource load condition of the edge computing equipment, the identification of the vehicle end and the position information.
Optionally, the method further includes:
after target information of the vehicle data is received, configuring the data state of the vehicle data to be a first state;
after the data uploading request is received, updating the data state of the vehicle data to be a second state;
after the uploading result data of the vehicle data are received, updating the corresponding data state of the vehicle data into a third state according to the uploading result data, wherein the uploading result data of the vehicle data are sent by the edge computing device after the vehicle data are uploaded, and the uploading result data comprise a vehicle data identifier, an uploading result and device information of the edge computing device.
The second aspect of the present application provides a vehicle data uploading method, including:
after generating vehicle data, the vehicle end sends target information of the vehicle data to a cloud end;
the cloud end generates task information of the vehicle data according to target information of the vehicle data, wherein the task information of the vehicle data comprises uploading priority of the vehicle data;
after the vehicle end copies all the vehicle data to a storage medium, sending an edge computing device recommendation request to the cloud end;
the cloud end returns the equipment information of the idle edge computing equipment to the vehicle end according to the resource load condition of the edge computing equipment and the request parameters carried by the recommendation request of the edge computing equipment, and the storage medium is used for connecting the edge computing equipment corresponding to the equipment information;
when the edge computing device detects that a new storage medium is accessed, all the vehicle data in the storage medium are copied to the local, and a data uploading request is sent to the cloud end;
the cloud end returns corresponding task information to the edge computing equipment according to request parameters carried by the data uploading request;
the edge computing device uploads the vehicle data to the cloud according to the uploading priority of the vehicle data in the task information;
and the cloud end receives and stores the vehicle data uploaded by the edge computing equipment.
A third aspect of the present application provides a cloud, comprising:
the system comprises a target information receiving unit, a task information generating unit and a task information processing unit, wherein the target information receiving unit is used for receiving target information of vehicle data sent by a vehicle end and generating task information of the vehicle data according to the target information of the vehicle data, and the task information of the vehicle data comprises uploading priority of the vehicle data;
the edge computing device recommendation request receiving unit is used for receiving an edge computing device recommendation request sent by the vehicle end and returning the device information of the idle edge computing device to the vehicle end according to the resource load condition of the edge computing device and the request parameters carried by the edge computing device recommendation request; the edge computing device recommends that the request is sent by the vehicle end after copying all the vehicle data to a storage medium; the storage medium is used for connecting the edge computing equipment corresponding to the equipment information; the edge computing device is used for copying all the vehicle data in a new storage medium to the local part when detecting that the new storage medium is accessed, and sending a data uploading request to the cloud end;
the data uploading request receiving unit is used for receiving a data uploading request sent by the edge computing device and returning corresponding task information to the edge computing device according to request parameters carried by the data uploading request, so that the edge computing device uploads the vehicle data to the cloud end according to the uploading priority of the vehicle data in the task information;
and the data storage unit is used for receiving and storing the vehicle data uploaded by the edge computing equipment.
A fourth aspect of the present application provides an electronic device comprising a processor and a memory;
the memory is used for storing program codes and transmitting the program codes to the processor;
the processor is configured to execute any of the vehicle data uploading methods of the first aspect according to instructions in the program code.
A fifth aspect of the present application provides a computer-readable storage medium for storing program code, which when executed by a processor implements the vehicle data uploading method of any one of the first aspects.
According to the technical scheme, the method has the following advantages:
the application provides a vehicle data uploading method, which is applied to a cloud end and comprises the following steps: receiving target information of vehicle data sent by a vehicle end, and generating task information of the vehicle data according to the target information of the vehicle data, wherein the task information of the vehicle data comprises an uploading priority of the vehicle data; receiving an edge computing device recommendation request sent by a vehicle end, and returning device information of idle edge computing devices to the vehicle end according to the resource load condition of the edge computing devices and request parameters carried by the edge computing device recommendation request; the edge computing device recommends that the request is sent after the vehicle end copies all vehicle data to the storage medium; the storage medium is used for connecting the edge computing equipment corresponding to the equipment information; the edge computing device is used for copying all vehicle data in a new storage medium to the local part and sending a data uploading request to the cloud end when detecting that the new storage medium is accessed; receiving a data uploading request sent by the edge computing equipment, and returning corresponding task information to the edge computing equipment according to request parameters carried by the data uploading request, so that the edge computing equipment uploads the vehicle data to a cloud end according to the uploading priority of the vehicle data in the task information; and receiving and storing the vehicle data uploaded by the edge computing device.
In the method, the cloud end calculates the uploading priority of each vehicle data according to the target information of the vehicle data, so that the priority configuration of the vehicle data is realized, the edge computing equipment can upload the vehicle data to the cloud end according to the uploading priority, the cloud end indirectly receives the vehicle data and the stored data according to the priority, and important data can be obtained preferentially; the edge computing equipment can upload large-batch data, the problem that the bandwidth of data uploaded by a vehicle end is limited can be avoided, the problem that the vehicle needs to upload data in a specified area is also avoided, and the technical problems that in the prior art, large-batch vehicle data cannot be uploaded, the vehicle data needs to be uploaded in the specified area by the vehicle, the vehicle data is uploaded according to a time sequence, and important data cannot be uploaded in time are solved.
Detailed Description
The application provides a vehicle data uploading method and a related device thereof, which are used for solving the technical problems that in the prior art, large batch of vehicle data cannot be uploaded, the vehicle data is required to be uploaded in a specified area, the vehicle data is uploaded according to a time sequence, and important data cannot be uploaded in time.
In order to make the technical solutions of the present application better understood, the technical solutions in the embodiments of the present application will be clearly and completely described 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, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present application.
For easy understanding, please refer to fig. 1, an embodiment of the present application provides a vehicle data uploading method, applied to an edge computing device, including:
step 101, receiving target information of vehicle data sent by a vehicle end, and generating task information of the vehicle data according to the target information of the vehicle data, wherein the task information of the vehicle data comprises an uploading priority of the vehicle data.
The vehicle end sends the target information of the vehicle data to the cloud end after generating the vehicle data to be uploaded, the vehicle end can generate one piece of vehicle data every preset time period, and the target information of the vehicle data can be sent to the cloud end every time one piece of vehicle data is generated. The target information may include an identifier of the vehicle end (such as a vehicle end ID), a vehicle data identifier, a data type, an automatic driving scene, data time, a data size of the vehicle data, summary information of the vehicle data (such as MD5), and upload cloud storage, and after receiving the target information of the vehicle data sent by the vehicle end, the cloud generates task information of the vehicle data according to the target information. The task information of the vehicle data comprises information such as uploading priority, vehicle data identification and uploading cloud storage of the vehicle data.
The cloud end can determine the uploading priority of the vehicle data according to the data type, the automatic driving scene and the data time of the vehicle data. Specifically, the cloud end can determine data type parameters, automatic driving scene parameters and time coefficients of the vehicle data according to the data type, the automatic driving scene and the data time of the vehicle data; the uploading priority of the vehicle data is calculated according to the data type parameters, the automatic driving scene parameters and the time coefficient of the vehicle data, and specifically, the uploading priority of the vehicle data can be calculated according to the following formula:
P=[(X+max(Y)+Z)]*T;
in the formula, P is an uploading priority value obtained by calculation, the larger the P value is, the higher the priority is, X is a data type parameter, Y is an automatic driving scene parameter, Z is a constant, and T is a time coefficient.
The data types of the vehicle data comprise accident data, video data, log data, map data and the like, the data type parameters X corresponding to each data type are different, and the data type of the more important data can be set to be a higher parameter, for example, the accident data is set to be a larger parameter so as to have high priority, and therefore the accident data is uploaded preferentially so as to be analyzed more quickly. When map data need to be collected in a new place, the map data can be set with larger parameters to obtain high-priority uploading, so that a high-precision map can be manufactured more quickly.
The automatic driving scene parameter Y is a group of tag parameters of an automatic driving scene, and the tag parameters corresponding to the respective automatic driving scenes have been configured with specific numerical values in advance. Assuming that a drive test task of a certain vehicle includes two scenes, scene 1 and scene 2, the tag parameter corresponding to the configuration scene 1 is 3, the tag parameter corresponding to the configuration scene 2 is 5, and max (y) is max (3,5) is 5. The tag parameter of the dangerous scene can be set to be a large value so as to analyze the dangerous scene more quickly.
The parameter Z is an adjustment coefficient, and the default value may be 0, which may be set by the user. For example, a certain vehicle data is calculated to have a lower priority, and the priority can be adjusted by adjusting the parameter Z because of the need to acquire the vehicle data preferentially due to some specific requirements. The time factor T is a time constant that defaults to a higher priority of data at the most recent time.
The parameters may be set according to parameter sets, and the priority of the parameter sets may be from low to high, a default parameter set (X, Y), a regional parameter set (X, Y) to which the vehicle belongs, and a vehicle parameter set (X, Y), where the parameter of the high priority parameter set overlaps the parameter of the low priority parameter set. It can be understood that, when the vehicle data collected in a certain region is less, or the occurrence of a safety accident is more frequent, a parameter set of the region may be configured with a higher parameter value, so that the parameter set has a higher priority, and the region parameter set to which the vehicle belongs may cover a default parameter set with a low priority; for some special vehicles, such as an autonomous vehicle that has just updated an autonomous driving algorithm, in order to obtain vehicle data for analysis at the time of its route more quickly, a vehicle parameter set of the vehicle may be configured with a higher parameter value to have a higher priority, and the vehicle parameter set of the vehicle may cover a regional parameter set to which a vehicle with a low priority belongs.
Further, after the cloud end receives the target information of the vehicle data, a data index can be established according to the target information, retrieval can be performed subsequently through the identification of the vehicle end, the vehicle data identification, the data type and the like, the vehicle end can also configure the data state of the vehicle data to be a first state, and the first state can be a created state.
102, receiving an edge computing device recommendation request sent by a vehicle end, and returning device information of idle edge computing devices to the vehicle end according to the resource load condition of the edge computing devices and request parameters carried by the edge computing device recommendation request; the edge computing device recommends that the request is sent after the vehicle end copies all vehicle data to the storage medium; the storage medium is used for connecting the edge computing equipment corresponding to the equipment information; the edge computing device is used for copying all vehicle data in the storage medium to the local part and sending a data uploading request to the cloud end when detecting that a new storage medium is accessed.
After copying all vehicle data to be uploaded to a storage medium (such as a mobile hard disk), a vehicle end can send an edge computing device recommendation request to a cloud end, after receiving the edge computing device recommendation request, the cloud end returns device information of idle edge computing devices to the vehicle end according to resource load conditions of the edge computing devices and request parameters carried by the edge computing device recommendation request, and in order to improve data uploading speed, the cloud end can distribute the idle edge computing devices closest to the vehicle end. Specifically, the cloud end can acquire the size of the vehicle data of the vehicle end according to the identification of the vehicle end, then, in combination with the load condition of the edge computing device, the idle edge computing device capable of processing the vehicle data of the vehicle is screened out, then, the idle edge computing device closest to the vehicle end is screened out according to the position information of the vehicle end, then, the device information of the idle edge computing device closest to the vehicle end is returned to the vehicle end, and then, the device information is connected to the edge computing device corresponding to the device information through a storage medium, and the device information can include device identification, position information and the like.
When detecting that a new storage medium is accessed, the edge computing device copies all vehicle data on the storage medium to the local for storage, and can transfer the vehicle data at the vehicle end to the edge computing device without the limitation of network bandwidth. After the edge computing device copies all data in the storage medium to the local storage, the data in the storage medium can be emptied, at the moment, the connection between the storage medium and the edge computing device can be disconnected, the storage medium can be put into operation again or put into a standby storage medium pool, the edge computing device does not need to wait for uploading all the data to the cloud, and therefore the resource utilization rate is improved.
After obtaining the vehicle data, the edge computing device sends a data uploading request to the cloud, where the data uploading request carries request parameters, and the request parameters may include an identifier of a vehicle end, a vehicle data identifier, device information of the edge computing device, and the like.
In the embodiment of the application, the vehicle data of the vehicle end is transferred to the edge computing device through the storage medium, a mobile network and a wired/wireless network are not needed, the limitation of network bandwidth is avoided, and the vehicle is not required to stop in a designated area to transmit the data.
And 103, receiving a data uploading request sent by the edge computing device, and returning corresponding task information to the edge computing device according to a request parameter carried by the data uploading request, so that the edge computing device uploads the vehicle data to a cloud end according to the uploading priority of the vehicle data in the task information.
The cloud end obtains request parameters in the data uploading request after receiving the data uploading request sent by the edge computing device, can search task information of vehicle data corresponding to the vehicle end according to the vehicle end identification and the vehicle data identification in the request parameters, and returns the task information of the vehicle data to the edge computing device, so that the edge computing device obtains uploading priority of each vehicle data according to the task information returned by the cloud end, and then uploads the vehicle data stored locally to the cloud end according to the uploading priority of the vehicle data.
Further, the cloud end can update the data state of the vehicle data to be the second state after receiving the data uploading request. The cloud end can update the data state of the vehicle data corresponding to the vehicle data identification into a second state according to the vehicle data identification and the like in the request parameter carried by the data uploading request, and the second state can be a state to be uploaded.
Further, the task information also comprises a data processing task, and the data processing task comprises a data integrity checking task, a data cleaning task and/or a data compression task. In order to reduce the burden of the cloud, some data processing processes of the vehicle data are put on the edge computing device in the embodiment of the application, and the data processing includes data integrity checking, data cleaning, data compression and other operations. The cloud end can judge whether the vehicle data needs to be compressed according to the data size in the target information after receiving the target information of the vehicle data sent by the vehicle end, and if the data size of the vehicle data is larger than a preset threshold value, a data compression task of the vehicle data is generated; the cloud end can also generate corresponding data cleaning tasks (such as filtering and merging) according to the data types of the vehicle data, and the data cleaning tasks corresponding to the data types can be configured in advance; in order to ensure whether the uploaded vehicle data are complete or not, the cloud terminal can also generate a data integrity check task, in the embodiment of the application, data integrity check is preferably performed through summary information, and therefore when the task information is returned, the cloud terminal returns the summary information of the vehicle data in the received target information to the edge computing device.
Further, the edge computing device uploads the vehicle data to the cloud according to the uploading priority of the vehicle data in the task information, and the method comprises the following steps:
the edge computing equipment creates a data uploading task in a data uploading task queue according to the task information;
the edge computing equipment calls a high-priority data uploading task from the data uploading task queue according to the uploading priority of the vehicle data and analyzes task information of the high-priority data uploading task;
when the task information of the high-priority data uploading task comprises the data processing task, the edge computing device performs data processing on the vehicle data corresponding to the high-priority data uploading task according to the data processing task and uploads the vehicle data after the data processing to the cloud.
After receiving the task information, the edge computing equipment creates a data uploading task in the data uploading task queue, and the edge computing equipment takes out the data uploading task with high priority from the data uploading task queue according to the uploading priority of the vehicle data and analyzes the task information in the data uploading task queue; and if the task information comprises the data processing task, performing data processing on the vehicle data corresponding to the high-priority data uploading task according to the data processing task. If the data processing task of the high-priority data uploading task comprises a data integrity checking task, a data cleaning task and a data compression task, the edge computing device firstly acquires abstract information of locally stored corresponding vehicle data according to the identification of a vehicle end, the identification of the vehicle data and the like in the high-priority data uploading task, and then compares the abstract information of the vehicle data with the abstract information of the vehicle data in the task information returned by the cloud end to check the data integrity; and then, carrying out data cleaning on the vehicle data, carrying out data compression on the processed vehicle data, and uploading the compressed vehicle data to a cloud.
After uploading the current vehicle data with the highest priority to the cloud end, the edge computing device can submit the uploading result data of the vehicle data to the cloud end, and the uploading result data can comprise the vehicle data identification, the uploading result and the device information of the edge computing device. Further, the cloud end can update the data state of the vehicle data to be a third state according to the uploading result data, and the third state can be an uploaded state. After the data state of the vehicle data is updated, the cloud can inform downstream data processing logic, so that the edge computing device takes out a next task with high priority according to the uploading priority to perform data processing and uploading.
The progress and the state of uploading the vehicle data can be monitored in real time through the data state of the vehicle data, the state information of each link of uploading the specific vehicle data to the cloud can be tracked in the whole process, and the purpose of uploading the full-link end-to-end monitoring is achieved.
And 104, receiving and storing the vehicle data uploaded by the edge computing equipment.
And the cloud receiving edge computing equipment stores the vehicle data uploaded according to the uploading priority in sequence.
In the embodiment of the application, the cloud end calculates the uploading priority of each vehicle data according to the target information of the vehicle data, so that the priority configuration of the vehicle data is realized, the edge computing equipment can upload the vehicle data to the cloud end according to the uploading priority, the cloud end indirectly receives the vehicle data and the stored data according to the priority, and important data can be obtained preferentially; the method has the advantages that the large-batch data can be uploaded through the edge computing equipment, the problem that the bandwidth is limited when data are uploaded at a vehicle end can be solved, the problem that the vehicle needs to upload data in a specified area can be solved, and the technical problems that the large-batch vehicle data cannot be uploaded, the vehicle needs to upload the vehicle data in the specified area, the vehicle data is uploaded according to a time sequence, and important data cannot be uploaded in time in the prior art are solved;
furthermore, the progress and the state that this application can real time monitoring vehicle data upload through the data state of vehicle data can track the state information of each link that a concrete vehicle data uploaded to the high in the clouds in the whole journey, realizes uploading the end-to-end control of full link.
The vehicle data uploading method applied to the cloud is provided above, and another embodiment of the vehicle data uploading method provided by the application is provided below.
Referring to fig. 2, a vehicle data uploading method provided in an embodiment of the present application includes:
step 201, after the vehicle end generates the vehicle data, the vehicle end sends target information of the vehicle data to the cloud end.
The vehicle end sends the target information of the vehicle data to the cloud end after generating the vehicle data to be uploaded, the vehicle end can generate one piece of vehicle data every preset time period, and the target information of the vehicle data can be sent to the cloud end every time one piece of vehicle data is generated. The target information may include information such as identification of a vehicle end (e.g., vehicle end ID), vehicle data identification, data type, automatic driving scene, data time, data size of vehicle data, summary information of vehicle data (e.g., MD5), and upload cloud storage.
Step 202, the cloud generates task information of the vehicle data according to the target information of the vehicle data, wherein the task information of the vehicle data comprises uploading priority of the vehicle data.
And after receiving the target information of the vehicle data sent by the vehicle end, the cloud end generates task information of the vehicle data according to the target information. The task information of the vehicle data can include information such as uploading priority, vehicle data identification and uploading cloud storage of the vehicle data.
The cloud end can determine the uploading priority of the vehicle data according to the data type, the automatic driving scene and the data time of the vehicle data. Specifically, the cloud end can determine data type parameters, automatic driving scene parameters and time coefficients of the vehicle data according to the data type, the automatic driving scene and the data time of the vehicle data; the uploading priority of the vehicle data is calculated according to the data type parameters, the automatic driving scene parameters and the time coefficient of the vehicle data, and specifically the uploading priority of the vehicle data can be calculated according to the following formula:
P=[(X+max(Y)+Z)]*T;
in the formula, P is an uploading priority value obtained by calculation, the larger the P value is, the higher the priority is, X is a data type parameter, Y is an automatic driving scene parameter, Z is a constant, and T is a time coefficient.
The data types of the vehicle data comprise accident data, video data, log data, map data and the like, the data type parameters X corresponding to each data type are different, and the data type of the more important data can be set to be a higher parameter, for example, the accident data is set to be a larger parameter so as to have high priority, so that the accident data is preferentially uploaded so as to be analyzed more quickly. When map data need to be collected in a new place, the map data can be set with larger parameters to obtain high-priority uploading, so that a high-precision map can be manufactured more quickly.
The automatic driving scene parameter Y is a group of tag parameters of an automatic driving scene, and the tag parameters corresponding to the respective automatic driving scenes have been configured with specific numerical values in advance. Assuming that a drive test task of a certain vehicle includes two scenes, scene 1 and scene 2, the tag parameter corresponding to the configuration scene 1 is 3, the tag parameter corresponding to the configuration scene 2 is 5, and max (y) is max (3,5) is 5. The tag parameter of the dangerous scene can be set to be a large value so as to analyze the dangerous scene more quickly.
The parameter Z is an adjustment coefficient, and the default value may be 0, which may be set by the user. For example, a certain vehicle data is calculated to have a lower priority, and the priority can be adjusted by adjusting the parameter Z because of the need to acquire the vehicle data preferentially due to some specific requirements. The time coefficient T is a time constant, and defaults to a higher priority of data at the latest time.
The parameters may be set according to parameter sets, and the priority of the parameter sets may be from low to high, a default parameter set (X, Y), a regional parameter set (X, Y) to which the vehicle belongs, and a vehicle parameter set (X, Y), where the parameter of the high priority parameter set overlaps the parameter of the low priority parameter set. It can be understood that, when the vehicle data collected in a certain region is less, or the occurrence of a safety accident is more frequent, a parameter set of the region may be configured with a higher parameter value, so that the parameter set has a higher priority, and the region parameter set to which the vehicle belongs may cover a default parameter set with a low priority; for some special vehicles, such as an autonomous vehicle that has just updated an autonomous driving algorithm, in order to obtain vehicle data for analysis when the vehicle is driving faster, a higher parameter value may be configured for the vehicle parameter set of the vehicle, so that the vehicle parameter set of the vehicle has a higher priority, and the vehicle parameter set of the vehicle may cover the regional parameter set of the vehicle with a lower priority.
Further, after the cloud end receives the target information of the vehicle data, a data index can be established according to the target information, retrieval can be performed subsequently through the identification of the vehicle end, the vehicle data identification, the data type and the like, the vehicle end can also configure the data state of the vehicle data to be a first state, and the first state can be a created state.
And step 203, after copying all the vehicle data to a storage medium, the vehicle side sends a recommendation request of the edge computing device to the cloud.
After copying all vehicle data to be uploaded to a storage medium (such as a mobile hard disk), the vehicle end may send an edge computing device recommendation request to the cloud, where the edge computing device recommendation request carries request parameters, and the request parameters include an identifier and location information of the vehicle end.
And step 204, the cloud returns the device information of the idle edge computing device to the vehicle end according to the resource load condition of the edge computing device and the request parameters carried by the recommendation request of the edge computing device, and the storage medium is used for connecting the edge computing device corresponding to the device information.
And after receiving the edge computing device recommendation request, the cloud returns the device information of the idle edge computing device to the vehicle end according to the resource load condition of the edge computing device and the request parameters carried by the edge computing device recommendation request, and in order to improve the data uploading speed, the cloud can allocate the idle edge computing device closest to the vehicle end. Specifically, the cloud end can acquire the size of the vehicle data of the vehicle end according to the identification of the vehicle end, then, the idle edge computing device capable of processing the vehicle data of the vehicle is screened out by combining with the load condition of the edge computing device, then, the idle edge computing device closest to the vehicle end is screened out according to the position information of the vehicle end, then, the device information of the idle edge computing device closest to the vehicle end is returned to the vehicle end, and then, the device information is connected to the edge computing device corresponding to the device information through a storage medium, and the device information can comprise a device identification, position information and the like.
Step 205, when detecting that a new storage medium is accessed, the edge computing device copies all vehicle data in the storage medium to the local, and sends a data uploading request to the cloud.
When detecting that a new storage medium is accessed, the edge computing device copies all vehicle data on the storage medium to the local for storage, and can transfer the vehicle data at the vehicle end to the edge computing device without the limitation of network bandwidth. After the edge computing device copies all data in the storage medium to the local storage, the data in the storage medium can be emptied, at the moment, the connection between the storage medium and the edge computing device can be disconnected, the storage medium can be put into operation again or put into a standby storage medium pool, the edge computing device does not need to wait for uploading all the data to the cloud, and therefore the resource utilization rate is improved.
After obtaining the vehicle data, the edge computing device sends a data uploading request to the cloud, where the data uploading request carries request parameters, and the request parameters may include an identifier of a vehicle end, a vehicle data identifier, device information of the edge computing device, and the like.
In the embodiment of the application, the vehicle data of the vehicle end is transferred to the edge computing device through the storage medium, a mobile network and a wired/wireless network are not needed, the limitation of network bandwidth is avoided, and the vehicle is not required to stop in a designated area to transmit the data.
And step 206, the cloud returns corresponding task information to the edge computing device according to the request parameters carried by the data uploading request.
The cloud end can search task information of vehicle data corresponding to the vehicle end according to the identification of the vehicle end and the identification of the vehicle data in the request parameters, and returns the task information of the vehicle data to the edge computing device.
Further, the cloud end can update the data state of the vehicle data to be the second state after receiving the data uploading request. The cloud end can update the data state of the vehicle data corresponding to the vehicle data identification into a second state according to the vehicle data identification and the like in the request parameter carried by the data uploading request, and the second state can be a state to be uploaded.
Further, the task information also comprises a data processing task, and the data processing task comprises a data integrity checking task, a data cleaning task and/or a data compression task. In order to reduce the burden of the cloud, in the embodiment of the application, some data processing processes of the vehicle data are put on the edge computing device, and the data processing includes data integrity checking, data cleaning, data compression and other operations. It can be understood that after receiving the target information of the vehicle data sent by the vehicle end, the cloud end can judge whether the vehicle data needs to be compressed according to the data size in the target information, and if the data size of the vehicle data is larger than a preset threshold value, a data compression task of the vehicle data is generated; the cloud end can also generate corresponding data cleaning tasks (such as filtering and merging) according to the data types of the vehicle data, and the data cleaning tasks corresponding to the data types can be configured in advance; in order to ensure whether the uploaded vehicle data are complete or not, the cloud terminal can also generate a data integrity check task, in the embodiment of the application, data integrity check is preferably performed through summary information, and therefore when the task information is returned, the cloud terminal returns the summary information of the vehicle data in the received target information to the edge computing device.
And step 207, uploading the vehicle data to a cloud end by the edge computing equipment according to the uploading priority of the vehicle data in the task information.
And the edge computing equipment uploads the vehicle data to the cloud according to the uploading priority of the vehicle data in the task information. Specifically, the edge computing device creates a data upload task in a data upload task queue according to the task information; the edge computing equipment calls a high-priority data uploading task from the data uploading task queue according to the uploading priority of the vehicle data and analyzes task information of the high-priority data uploading task; when the task information of the high-priority data uploading task comprises the data processing task, the edge computing device performs data processing on the vehicle data corresponding to the high-priority data uploading task according to the data processing task and uploads the vehicle data after the data processing to the cloud.
After receiving the task information, the edge computing equipment creates a data uploading task in the data uploading task queue, and the edge computing equipment takes out the data uploading task with high priority from the data uploading task queue according to the uploading priority of the vehicle data and analyzes the task information in the data uploading task queue; and if the task information comprises the data processing task, performing data processing on the vehicle data corresponding to the high-priority data uploading task according to the data processing task. If the data processing task of the high-priority data uploading task comprises a data integrity checking task, a data cleaning task and a data compression task, the edge computing device firstly acquires abstract information of locally stored corresponding vehicle data according to the identification of a vehicle end, the identification of the vehicle data and the like in the high-priority data uploading task, and then compares the abstract information of the vehicle data with the abstract information of the vehicle data in the task information returned by the cloud end to check the data integrity; and then, carrying out data cleaning on the vehicle data, carrying out data compression on the processed vehicle data, and uploading the compressed vehicle data to a cloud.
After uploading the current vehicle data with the highest priority to the cloud end, the edge computing device can submit the uploading result data of the vehicle data to the cloud end, and the uploading result data can comprise the vehicle data identification, the uploading result and the device information of the edge computing device. Further, the cloud end can update the data state of the vehicle data to be a third state according to the uploading result data, and the third state can be an uploaded state. After the data state of the vehicle data is updated, the cloud end can inform downstream data processing logic, so that the edge computing device takes out the next high-priority task according to the uploading priority to perform data processing and uploading.
The progress and the state of uploading the vehicle data can be monitored in real time through the data state of the vehicle data, the state information of each link of uploading the specific vehicle data to the cloud can be tracked in the whole process, and the purpose of uploading the full-link end-to-end monitoring is achieved.
And step 208, the cloud end receives and stores the vehicle data uploaded by the edge computing device.
And the cloud receiving edge computing equipment stores the vehicle data uploaded according to the uploading priority in sequence.
In the embodiment of the application, the cloud end calculates the uploading priority of each vehicle data according to the target information of the vehicle data, so that the priority configuration of the vehicle data is realized, the edge computing equipment can upload the vehicle data to the cloud end according to the uploading priority, the cloud end indirectly receives the vehicle data and the stored data according to the priority, and important data can be obtained preferentially; the method has the advantages that the mass data can be uploaded through the edge computing device, the problem that the bandwidth is limited when the data are uploaded by a vehicle end can be avoided, the problem that the vehicle needs to upload the data in a specified area is also avoided, and the technical problems that the mass data cannot be uploaded, the vehicle needs to upload the vehicle data in the specified area, the vehicle data is uploaded according to a time sequence, and important data cannot be uploaded in time in the prior art are solved;
further, the progress and the state that this application can real time monitoring vehicle data upload through the data state of vehicle data can the state of every link that a concrete vehicle data uploaded to the high in the clouds in the whole journey track, realizes uploading the end-to-end control of whole link.
Referring to fig. 3, an embodiment of the present application further provides a cloud, including:
the target information receiving unit is used for receiving target information of the vehicle data sent by the vehicle end and generating task information of the vehicle data according to the target information of the vehicle data, wherein the task information of the vehicle data comprises uploading priority of the vehicle data;
the edge computing device recommendation request receiving unit is used for receiving an edge computing device recommendation request sent by the vehicle end and returning the device information of the idle edge computing device to the vehicle end according to the resource load condition of the edge computing device and the request parameters carried by the edge computing device recommendation request; the edge computing device recommends that the request is sent after the vehicle end copies all vehicle data to a storage medium; the storage medium is used for connecting the edge computing equipment corresponding to the equipment information; the edge computing device is used for copying all vehicle data in a new storage medium to the local part when detecting that the new storage medium is accessed, and sending a data uploading request to the cloud end;
the data uploading request receiving unit is used for receiving a data uploading request sent by the edge computing equipment and returning corresponding task information to the edge computing equipment according to request parameters carried by the data uploading request, so that the edge computing equipment uploads the vehicle data to a cloud end according to the uploading priority of the vehicle data in the task information;
and the data storage unit is used for receiving and storing the vehicle data uploaded by the edge computing equipment.
In the embodiment of the application, the cloud end calculates the uploading priority of each vehicle data according to the target information of the vehicle data, so that the priority configuration of the vehicle data is realized, the edge computing equipment can upload the vehicle data to the cloud end according to the uploading priority, the cloud end indirectly receives the vehicle data and the stored data according to the priority, and important data can be obtained preferentially; the edge computing equipment can upload large-batch data, the problem that the bandwidth of data uploaded by a vehicle end is limited can be avoided, the problem that the vehicle needs to upload data in a specified area is also avoided, and the technical problems that in the prior art, large-batch vehicle data cannot be uploaded, the vehicle data needs to be uploaded in the specified area by the vehicle, the vehicle data is uploaded according to a time sequence, and important data cannot be uploaded in time are solved.
The embodiment of the application also provides electronic equipment, which comprises a processor and a memory;
the memory is used for storing the program codes and transmitting the program codes to the processor;
the processor is used for executing the vehicle data uploading method in the embodiment of the application according to the instructions in the program codes.
The embodiment of the application also provides a computer-readable storage medium, which is used for storing program codes, and the program codes are executed by a processor to realize the vehicle data uploading method in the embodiment of the application.
It is clear to those skilled in the art that, for convenience and brevity of description, the specific working processes of the above-described apparatuses and units may refer to the corresponding processes in the foregoing method embodiments, and are not described herein again.
The terms "first," "second," "third," "fourth," and the like in the description of the application and the above-described figures, if any, are used for distinguishing between similar elements and not necessarily for describing a particular sequential or chronological order. It is to be understood that the data so used is interchangeable under appropriate circumstances such that the embodiments of the application described herein are, for example, capable of operation in sequences other than those illustrated or otherwise described herein. Furthermore, the terms "comprises," "comprising," and "having," and any variations thereof, are intended to cover a non-exclusive inclusion, such that a process, method, system, article, or apparatus that comprises a list of steps or elements is not necessarily limited to those steps or elements expressly listed, but may include other steps or elements not expressly listed or inherent to such process, method, article, or apparatus.
It should be understood that, in this application, "at least one" means one or more, "a plurality" means two or more. "and/or" for describing an association relationship of associated objects, indicating that there may be three relationships, e.g., "a and/or B" may indicate: only A, only B and both A and B are present, wherein A and B may be singular or plural. The character "/" generally indicates that the former and latter associated objects are in an "or" relationship. "at least one of the following" or similar expressions refer to any combination of these items, including any combination of the singular or plural items. For example, at least one (one) of a, b, or c, may represent: a, b, c, "a and b", "a and c", "b and c", or "a and b and c", wherein a, b, c may be single or plural.
In the several embodiments provided in the present application, it should be understood that the disclosed apparatus and method may be implemented in other ways. For example, the above-described apparatus embodiments are merely illustrative, and for example, the division of the units is only one logical division, and other divisions may be realized in practice, for example, a plurality of units or components may be combined or integrated into another system, or some features may be omitted, or not executed. In addition, the shown or discussed mutual coupling or direct coupling or communication connection may be an indirect coupling or communication connection through some interfaces, devices or units, and may be in an electrical, mechanical or other form.
The units described as separate parts may or may not be physically separate, and parts displayed as units may or may not be physical units, may be located in one position, or may be distributed on multiple network units. Some or all of the units can be selected according to actual needs to achieve the purpose of the solution of the embodiment.
In addition, functional units in the embodiments of the present application may be integrated into one processing unit, or each unit may exist alone physically, or two or more units are integrated into one unit. The integrated unit may be implemented in the form of hardware, or may also be implemented in the form of a software functional unit.
The integrated unit, if implemented in the form of a software functional unit and sold or used as a stand-alone product, may be stored in a computer readable storage medium. Based on such understanding, the technical solutions of the present application, or portions or all or portions of the technical solutions that contribute to the prior art, may be embodied in the form of a software product, which is stored in a storage medium and includes several instructions for executing all or part of the steps of the methods described in the embodiments of the present application through a computer device (which may be a personal computer, a server, or a network device). And the aforementioned storage medium includes: a U disk, a removable hard disk, a Read-Only Memory (ROM), a Random Access Memory (RAM), a magnetic disk or an optical disk, and other various media capable of storing program codes.
The above embodiments are only used for illustrating the technical solutions of the present application, and not for limiting the same; although the present application has been described in detail with reference to the foregoing embodiments, it should be understood by those of ordinary skill in the art that: the technical solutions described in the foregoing embodiments may still be modified, or some technical features may be equivalently replaced; and such modifications or substitutions do not depart from the spirit and scope of the corresponding technical solutions in the embodiments of the present application.