[go: up one dir, main page]

CN116800611A - A vehicle status data processing system and method - Google Patents

A vehicle status data processing system and method Download PDF

Info

Publication number
CN116800611A
CN116800611A CN202310722411.0A CN202310722411A CN116800611A CN 116800611 A CN116800611 A CN 116800611A CN 202310722411 A CN202310722411 A CN 202310722411A CN 116800611 A CN116800611 A CN 116800611A
Authority
CN
China
Prior art keywords
data
vehicle
real
processor
status data
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN202310722411.0A
Other languages
Chinese (zh)
Inventor
陆起阳
唐如意
叶松林
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Chongqing Selis Phoenix Intelligent Innovation Technology Co ltd
Original Assignee
Chengdu Seres Technology Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Chengdu Seres Technology Co Ltd filed Critical Chengdu Seres Technology Co Ltd
Priority to CN202310722411.0A priority Critical patent/CN116800611A/en
Publication of CN116800611A publication Critical patent/CN116800611A/en
Pending legal-status Critical Current

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/08Configuration management of networks or network elements
    • H04L41/0803Configuration setting
    • H04L41/0823Configuration setting characterised by the purposes of a change of settings, e.g. optimising configuration for enhancing reliability
    • GPHYSICS
    • G07CHECKING-DEVICES
    • G07CTIME OR ATTENDANCE REGISTERS; REGISTERING OR INDICATING THE WORKING OF MACHINES; GENERATING RANDOM NUMBERS; VOTING OR LOTTERY APPARATUS; ARRANGEMENTS, SYSTEMS OR APPARATUS FOR CHECKING NOT PROVIDED FOR ELSEWHERE
    • G07C5/00Registering or indicating the working of vehicles
    • G07C5/008Registering or indicating the working of vehicles communicating information to a remotely located station
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/12Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks

Landscapes

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

Abstract

The application relates to the technical field of data processing, and provides a vehicle state data processing system and method. The system comprises a service platform and an analysis platform, wherein the service platform comprises a service processor and a data buffer, and the analysis platform comprises a data processor and a database. The service processor is used for receiving the real-time state data of the vehicle, preprocessing the real-time state data of the vehicle and then sending the data to the data processor; the data processor is used for analyzing and processing the real-time state data of the vehicle and sending an analysis result and the real-time state data of the vehicle to the database for storage; the service processor is also used for reading target cache data from the database and caching the target cache data into the data cache, receiving a service request, and reading corresponding target request data from the data cache and returning according to the service request. The application can respectively configure the two processors according to different requirements, thereby realizing more efficient data processing, rapidly responding to service requests and improving user experience.

Description

Vehicle state data processing system and method
Technical Field
The present application relates to the field of data processing technologies, and in particular, to a vehicle state data processing system and method.
Background
The vehicle can generate a large amount of data in the running process, and the vehicle networking cloud platform can collect the real-time state data of the vehicle for analysis and calculation and provide valuable information for vehicle owners and factories. However, when the vehicle access amount of the internet of vehicles cloud platform is more at present, the real-time state data of the vehicle is frequently reported, the data processing capability requirement of the cloud platform is higher, the load of the cloud server is likely to be increased, meanwhile, the problem of response delay is brought about due to high concurrency of requests, and the user experience is poor.
Therefore, how to provide a solution to the above technical problem is a problem that needs to be solved by those skilled in the art.
Disclosure of Invention
In view of the above, the embodiments of the present application provide a vehicle state data processing system and method, so as to solve the problems of slow data processing and delayed response of a cloud platform in the prior art.
In a first aspect of an embodiment of the present application, a vehicle state data processing system is provided, including a service platform and an analysis platform, where the service platform includes a service processor and a data buffer, and the analysis platform includes a data processor and a database, and where:
the service processor is used for receiving the real-time state data of the vehicle, preprocessing the real-time state data of the vehicle and then sending the data to the data processor;
the data processor is used for analyzing and processing the real-time state data of the vehicle and sending an analysis result and the real-time state data of the vehicle to the database for storage;
the service processor is also used for reading target cache data from the database and caching the target cache data into the data cache;
the service processor is also used for receiving the service request, reading the corresponding target request data from the data buffer according to the service request and returning.
In a second aspect of the embodiments of the present application, there is provided a vehicle state data processing method applied to a service processor of a vehicle state data processing system as described above, the method comprising:
receiving real-time state data of the vehicle, preprocessing the real-time state data of the vehicle, and then sending the data to a data processor so that the data processor can analyze and process the real-time state data of the vehicle, and sending an analysis result and the real-time state data of the vehicle to a database for storage;
reading target cache data from a database and caching the target cache data into a data cache;
and receiving a service request, reading corresponding target request data from the data buffer according to the service request, and returning.
In a third aspect of embodiments of the present application, there is provided another vehicle state data processing method applied to a data processor of a vehicle state data processing system as described above, the method comprising:
receiving real-time state data of the vehicle sent by a service processor;
and analyzing and processing the real-time state data of the vehicle, and sending the analysis result and the real-time state data of the vehicle to a database for storage.
Compared with the prior art, the embodiment of the application has the beneficial effects that: according to the embodiment of the application, the service platform and the analysis platform are arranged, the data service processing task and the data analysis task are decoupled and distributed to the two processors, the service processor can respond to more data service requests and data uploading which are concurrent, the data processor can concentrate on data analysis processing of large data volume, the two processors are respectively configured according to different requirements, the processors are not affected each other, and the processors can work efficiently, so that more efficient data processing is realized, the service requests are responded quickly, and the user experience is improved.
Drawings
In order to more clearly illustrate the technical solutions of the embodiments of the present application, the drawings used in the embodiments or the description of the prior art will be briefly described below, and it is obvious that the drawings in the following description are only some embodiments of the present application, and other drawings may be obtained according to these drawings without inventive effort for a person skilled in the art.
Fig. 1 is a schematic view of an application scenario according to an embodiment of the present application;
FIG. 2 is a block diagram of a vehicle status data processing system according to an embodiment of the present application;
FIG. 3 is a flow chart of a vehicle status data processing method according to an embodiment of the present application;
FIG. 4 is a flowchart of another vehicle status data processing method according to an embodiment of the present application; fig. 5 is a schematic structural diagram of an electronic device according to an embodiment of the present application.
Detailed Description
In the following description, for purposes of explanation and not limitation, specific details are set forth such as the particular system architecture, techniques, etc., in order to provide a thorough understanding of the embodiments of the present application. It will be apparent, however, to one skilled in the art that the present application may be practiced in other embodiments that depart from these specific details. In other instances, detailed descriptions of well-known systems, devices, circuits, and methods are omitted so as not to obscure the description of the present application with unnecessary detail.
A vehicle state data processing system and method according to an embodiment of the present application will be described in detail with reference to the accompanying drawings.
Fig. 1 is a schematic view of an application scenario according to an embodiment of the present application. The application scenario may include a vehicle controller 100, a first terminal device 101, a second terminal device 102, a third terminal device 103, a vehicle status data processing system 104, and a network 105.
The vehicle controller 100 may be hardware or software. When the vehicle controller 100 is hardware, it may be an electronic device located in the vehicle that controls and data collection for various components of the current vehicle. When the vehicle controller 100 is software, it may be installed in the electronic apparatus as described above. The vehicle controller 100 may be implemented as a plurality of software or software modules, or as a single software or software module, as embodiments of the application are not limited in this regard. Further, various applications may be installed on the vehicle controller 100, such as a data processing application, an instant messaging tool, social platform software, a search class application, a shopping class application, and the like.
The first terminal device 101 may be hardware or software. When the first terminal device 101 is hardware, it may be a variety of electronic devices having a display screen and supporting communication with the vehicle state data processing system 104, including but not limited to smartphones, tablets, laptop and desktop computers, and the like; when the first terminal apparatus 101 is software, it may be installed in the electronic apparatus as described above. The first terminal device 101 may be implemented as a plurality of software or software modules, or may be implemented as a single software or software module, which is not limited in this regard by the embodiment of the present application. Further, various applications, such as a data processing application, an instant messaging tool, social platform software, a search class application, a shopping class application, and the like, may be installed on the first terminal device 101.
The second terminal device 102 may be hardware or software. When the second terminal device 102 is hardware, it may be a variety of electronic devices having a display screen and supporting communication with the vehicle state data processing system 104, including but not limited to smartphones, tablets, laptop and desktop computers, and the like; when the second terminal device 102 is software, it may be installed in the electronic device as described above. The second terminal device 102 may be implemented as a plurality of software or software modules, or may be implemented as a single software or software module, as the embodiments of the present application are not limited in this respect. Further, various applications may be installed on the second terminal device 102, such as a data processing application, an instant messaging tool, social platform software, a search class application, a shopping class application, and the like.
The third terminal device 103 may be hardware or software. When the third terminal device 103 is hardware, it may be a variety of electronic devices having a display screen and supporting communication with the vehicle state data processing system 104, including but not limited to smartphones, tablets, laptop and desktop computers, and the like; when the third terminal device 103 is software, it may be installed in the electronic device as described above. The third terminal device 103 may be implemented as a plurality of software or software modules, or may be implemented as a single software or software module, which is not limited in this regard by the embodiment of the present application. Further, various applications, such as a data processing application, an instant messaging tool, social platform software, a search class application, a shopping class application, and the like, may be installed on the third terminal device 103.
The vehicle state data processing system 104 may be hardware or software. When the vehicle state data processing system 104 is hardware, it may be various electronic devices that provide various services to the first terminal device 101, the second terminal device 102, and the third terminal device 103. When the vehicle state data processing system 104 is software, it may be a plurality of software or software modules that provide various services to the first terminal device 101, the second terminal device 102, and the third terminal device 103, or may be a single software or software module that provides various services to the first terminal device 101, the second terminal device 102, and the third terminal device 103, which the embodiment of the application is not limited to.
The network 105 may be a wired network using coaxial cable, twisted pair and optical fiber connection, or may be a wireless network that can implement interconnection of various communication devices without wiring, for example, bluetooth (Bluetooth), near field communication (Near Field Communication, NFC), infrared (Infrared), etc., which are not limited by the embodiment of the present application.
It should be noted that the specific types, numbers and combinations of the first terminal device 101, the second terminal device 102, the third terminal device 103, the vehicle state data processing system 104 and the network 105 may be adjusted according to the actual requirements of the application scenario, which is not limited in the embodiment of the present application.
The vehicle controller 100 may establish communication with the vehicle state data processing system 104 via the network 105 to upload vehicle real-time state data to the vehicle state data processing system 104. The user can establish a communication connection with the vehicle state data processing system 104 via the network 105 through the first terminal device 101, the second terminal device 102, and the third terminal device 103 to receive or transmit information or the like.
It should be noted that the specific types, numbers and combinations of the first terminal device 101, the second terminal device 102, the third terminal device 103, the vehicle state data processing system and the network 105 may be adjusted according to the actual requirements of the application scenario, which is not limited in the embodiment of the present application.
Fig. 2 is a structural diagram of a vehicle state data processing system according to an embodiment of the present application. As shown in fig. 2, the vehicle state data processing system includes a service platform 201 and an analysis platform 202, the service platform 201 includes a service processor 2011 and a data buffer 2012, and the analysis platform 202 includes a data processor 2021 and a database 2022, wherein:
the service processor 2011 is configured to receive the real-time status data of the vehicle, pre-process the real-time status data of the vehicle, and send the pre-processed real-time status data to the data processor 2021;
the data processor 2021 is configured to perform analysis processing on the real-time status data of the vehicle, and send the analysis result and the real-time status data of the vehicle to the database 2022 for storage;
the service processor 2011 is further configured to read the target cache data from the database 2022 and cache the target cache data to the data cache 2012;
the service processor 2011 is further configured to receive a service request, and read corresponding target request data from the data buffer 2012 according to the service request and return the target request data.
It will be appreciated that the service platform 201 and the analysis platform 202 are respectively responsible for different processing contents, where the service platform 201 is responsible for front-end service contents, such as receiving real-time status data of a vehicle and responding to a service request, the analysis platform 202 is responsible for back-end analysis and deep processing of data, task actions in the specific service platform 201 are all executed by the service processor 2011, a part of response data related to the service request is cached by the data cache 2012, task actions in the similar analysis platform 202 are all executed by the data processor 2021, all data are uniformly stored in the database 2022, and the content of the database 2022 is finer into the data cache 2012 according to requirements.
Wherein the real-time status data of the vehicle received by the service processor is transmitted to the service processor by the vehicle controller through a TBOX (telecommunications Box) and a network. The real-time state data of the vehicle comprise state data, such as state data of a brake system, state data of a cabin and the like, received by the vehicle controller and returned by the control unit, and particularly comprise vehicle door and window states, temperature in the vehicle, tire pressure and the like, and the type of the real-time state data of the vehicle to be received and analyzed can be selected according to actual requirements. For reasons of more types of real-time state data of the vehicle, more data quantity of the real-time state data of the vehicle caused by more vehicle controllers communicated with the service processor and the like, in order to ensure that the real-time state data of the vehicle is not lost and stably uploaded to the service processor, different types of real-time state data of the vehicle generally correspond to different preset frequencies, a TBOX reads preset frequencies set in an MQTT (Message Queuing Telemetry Transport, message queue telemetry transport protocol) protocol, and sends corresponding vehicle state data to the service processor at the preset frequencies. The traffic processor is therefore particularly adapted to: and receiving vehicle state data transmitted at different preset frequencies, wherein the preset frequencies are set in the MQTT protocol. To reduce the complexity, two preset frequencies, namely a first frequency of low frequency and a second frequency of high frequency, may be set, the vehicle state data with a slower rate of change is sent at the first frequency, and the vehicle state data with a faster rate of change is sent at the second frequency.
The process of the further service processor 2011 receiving the real-time status data of the vehicle, preprocessing the real-time status data of the vehicle, and sending the preprocessed real-time status data of the vehicle to the data processor 2021 includes: the vehicle real-time status data is received and preprocessed, and then sent to the data processor 2021 through the message middleware. The message middleware is also called a message queue, which means that an efficient and reliable message transmission mechanism is used for data communication between platforms, and currently, the main stream message middleware comprises ActiveMQ, rabbitMQ, rocketMQ, kafka, zeroMQ and the like.
Further, in this embodiment, the real-time status data of the vehicle received by the service processor 2011 is packaged data, and because the service processor 2011 does not need to perform actual processing on the received real-time status data of the vehicle, in order to avoid load and delay caused by data processing, the service processor 2011 does not unpack the packaged data, only checks the time and type of the protocol header, and mainly checks whether the time is out of date and the type corresponds to the status data, i.e. pre-processes the time and type of the protocol header including checking the real-time status data of the vehicle; if the packed data passes the verification, it is sent to the data processor 2021, and accordingly, the process of sending the pre-processed real-time status data of the vehicle to the data processor 2021 through the message middleware includes: the verified vehicle real-time status data is sent to the data processor 2021 by the message middleware.
It will be appreciated that when the vehicle real-time status data is sent through the message middleware, different types of vehicle real-time status data can be distributed to different TOPIC TOPICs of the message middleware according to the type of the protocol header. The process of sending the verified vehicle real-time status data to the data processor 2021 by the message middleware includes:
distributing the checked vehicle real-time state data to TOPIC of the corresponding type in the message middleware;
accordingly, the data processor 2021 serves as a message consumer of the message middleware, listens to each TOPIC to receive the message, and therefore, before the data processor 2021 performs analysis processing on the real-time status data of the vehicle, it is further configured to: and monitoring all TOPICs of the message middleware to acquire the real-time state data of the checked vehicles.
When the message is received, the packet data is asynchronously unpacked, that is, the message is analyzed, so that the real-time state data of the vehicle in the field form can be obtained, then the format or the content invalid data can be filtered again to obtain the valid data, and further content filtering can be performed on the valid data, for example, whether the travel data is calculated and whether the travel is in the allowed travel range or not can be determined, and if the travel is in the allowed travel range, the real-time state data of the vehicle can be stored in the database 2022 through content filtering. The data processor 2021 is therefore also configured to, prior to performing the analysis processing on the vehicle real-time status data: and analyzing and filtering the real-time state data of the vehicle.
It will be appreciated that the analysis of the real-time status data of the vehicle by the data processor 2021 may be increased according to requirements, such as real-time calculation of travel-based data, driving behavior analysis, supporting UBI (Usage Based Insurance, insurance based on usage), and the like, without limitation. The data processor 2021 is pertinently configured with enough operation capability, so that the problems of high load and slow response of the traditional internet of vehicles cloud platform integrating business and data processing can not be generated.
It will be appreciated that the database 2022 stores various analysis results and vehicle real-time status data for review and feedback. In order to improve the query efficiency, a data buffer 2012 is provided at the front end, that is, the service platform 201, and the service processor 2011 reads the target buffer data possibly used from the database 2022 and temporarily stores the target buffer data in the data buffer 2012, if the service processor 2011 receives a service request, the corresponding target request data is firstly queried and returned from the data buffer 2012, and if no related data exists in the data buffer 2012, the data buffer 2012 is updated according to the database 2022 and the target request data is read again.
The service requests here are sent to the service processor 2011 by respective requesting terminals including a first terminal device, a second terminal device, a third terminal device as shown in fig. 1, and a vehicle controller. The request terminal sends a service request to the service processor 2011, the service processor 2011 determines target request data in the data buffer 2012, and then returns the target request data to the request terminal, and the request terminal is provided with an APP (application) capable of displaying the target request data.
Further, to improve the validity of the data in the data buffer 2012, the service processor 2011 is further configured to:
judging whether the cache time length of the target cache data in the data cache 2012 exceeds a preset time length;
if so, new target cache update data is read from the database 2022 to update the current target cache data.
The action of judging the validity of the data can be performed periodically or after receiving the service request.
In the process of periodically determining and updating, the process of determining whether the buffer duration of the target buffer data in the data buffer 2012 exceeds the preset duration includes:
according to the preset update frequency, it is determined whether the buffer duration of all the target buffer data in the data buffer 2012 exceeds the preset duration.
If the validity of the data is further determined after receiving the service request, the process of determining whether the buffer duration of the target buffer data in the data buffer 2012 exceeds the preset duration includes:
when a service request is received, judging whether the buffer time of target request data corresponding to the service request in the data buffer 2012 exceeds a preset time;
if yes, reading new target cache update data from the database to update the current target cache data, and triggering actions of reading corresponding target request data from the data cache according to the service request and returning the corresponding target request data;
if not, the action of reading the corresponding target request data from the data buffer according to the service request and returning is directly triggered.
The vehicle state data processing system solves the problems that vehicle state data are not timely acquired in the traditional vehicle networking application, and a large number of vehicles are high in load and response delay after being connected to a vehicle network. The embodiment of the application greatly improves the real-time processing efficiency of the vehicle state data and provides reliable data support for the analysis function expansion of the subsequent vehicle state data and the realization of other value added services.
According to the embodiment of the application, the service platform and the analysis platform are arranged, the data service processing task and the data analysis task are decoupled and distributed to the two processors, the service processor can respond to more data service requests and data uploading which are concurrent, the data processor can concentrate on data analysis processing of large data volume, the two processors are respectively configured according to different requirements, the processors are not affected each other, and the processors can work efficiently, so that more efficient data processing is realized, the service requests are responded quickly, and the user experience is improved.
Any combination of the above optional solutions may be adopted to form an optional embodiment of the present application, which is not described herein.
The following is an embodiment of the method of the present application, and may be applied to an embodiment of the system of the present application. For details not disclosed in the system embodiments of the present application, please refer to the method embodiments of the present application.
Fig. 3 is a flowchart of steps of a vehicle state data processing method according to an embodiment of the present application, where the method is applied to a service processor of a vehicle state data processing system as described above. As shown in fig. 3, the method includes:
s301: receiving real-time state data of the vehicle, preprocessing the real-time state data of the vehicle, and then sending the data to a data processor so that the data processor can analyze and process the real-time state data of the vehicle, and sending an analysis result and the real-time state data of the vehicle to a database for storage;
s302: reading target cache data from a database and caching the target cache data into a data cache;
s303: and receiving a service request, reading corresponding target request data from the data buffer according to the service request, and returning.
According to the embodiment of the application, the service platform and the analysis platform are arranged, the data service processing task and the data analysis task are decoupled and distributed to the two processors, the service processor can respond to more data service requests and data uploading which are concurrent, the data processor can concentrate on data analysis processing of large data volume, the two processors are respectively configured according to different requirements, the processors are not affected each other, and the processors can work efficiently, so that more efficient data processing is realized, the service requests are responded quickly, and the user experience is improved.
In some specific embodiments, the process of receiving the real-time status data of the vehicle, preprocessing the real-time status data of the vehicle, and then sending the preprocessed real-time status data to the data processor includes: and receiving the real-time state data of the vehicle, preprocessing the real-time state data of the vehicle, and then sending the preprocessed real-time state data of the vehicle to the data processor through the message middleware. The message middleware is also called a message queue, which means that an efficient and reliable message transmission mechanism is used for data communication between platforms, and currently, the main stream message middleware comprises ActiveMQ, rabbitMQ, rocketMQ, kafka, zeroMQ and the like.
In some specific embodiments, preprocessing includes checking the time and type of protocol header of the vehicle real-time status data;
correspondingly, the process of sending the preprocessed real-time state data of the vehicle to the data processor through the message middleware comprises the following steps:
the verified real-time state data of the vehicle is sent to the data processor through the message middleware.
In this embodiment, the real-time status data of the vehicle received by the service processor is packaged data, and because the service processor does not need to actually process the received real-time status data of the vehicle, and in order to avoid load and delay caused by data processing, the service processor does not unpack the packaged data, only checks the time and type of the protocol header, and mainly checks whether the time is out of date and the type corresponds to the status data, i.e. pre-processes the time and type of the protocol header including checking the real-time status data of the vehicle; if the packed data passes the check it is sent to the data processor.
It will be appreciated that when the vehicle real-time status data is sent through the message middleware, different types of vehicle real-time status data can be distributed to different TOPIC TOPICs of the message middleware according to the type of the protocol header. Thus in some specific embodiments, the process of sending verified vehicle real-time status data to the data processor through the message middleware includes:
and distributing the checked vehicle real-time state data to the TOPICs of the corresponding types in the message middleware, so that the data processor acquires the checked vehicle real-time state data when monitoring all TOPICs of the message middleware.
In some specific embodiments, a process of receiving vehicle real-time status data includes:
and receiving vehicle state data transmitted at different preset frequencies, wherein the preset frequencies are set in the MQTT protocol.
The real-time state data of the vehicle received by the service processor is sent to the service processor by the vehicle controller through the TBOX and the network. The real-time state data of the vehicle comprise state data, such as state data of a brake system, state data of a cabin and the like, received by the vehicle controller and returned by the control unit, and particularly comprise vehicle door and window states, temperature in the vehicle, tire pressure and the like, and the type of the real-time state data of the vehicle to be received and analyzed can be selected according to actual requirements. For reasons of more types of real-time state data of the vehicle, more data quantity of the real-time state data of the vehicle caused by more quantity of vehicle controllers communicated with the service processor and the like, in order to ensure that the real-time state data of the vehicle is not lost and stably uploaded to the service processor, different types of real-time state data of the vehicle usually correspond to different preset frequencies, the TBOX reads the preset frequencies set in the MQTT protocol, and the corresponding vehicle state data is sent to the service processor at the preset frequencies. To reduce the complexity, two preset frequencies, namely a first frequency of low frequency and a second frequency of high frequency, may be set, the vehicle state data with a slower rate of change is sent at the first frequency, and the vehicle state data with a faster rate of change is sent at the second frequency.
In some specific embodiments, after reading the target cache data from the database and caching the target cache data in the data cache, the method further comprises:
in order to improve the effectiveness of the data in the data buffer, the data can be regularly judged and updated, and whether the buffer duration of the target buffer data in the data buffer exceeds the preset duration is judged according to the preset update frequency;
if yes, the new target cache update data is read from the database to update the current target cache data.
In order to improve the validity of the data in the data buffer, the validity of the data may be determined when a service request is received, in some specific embodiments, the process of receiving the service request, reading the corresponding target request data from the data buffer according to the service request, and returning the target request data includes:
receiving a service request, and judging whether the buffer time of target request data corresponding to the service request in a data buffer exceeds a preset time;
if yes, reading new target cache update data from the database to update current target cache data, and then reading corresponding target request data from the data cache according to the service request and returning;
if not, the corresponding target request data is read from the data buffer directly according to the service request and returned.
FIG. 4 is a flow chart of steps of another vehicle state data processing method provided by an embodiment of the present application, which is applied to a data processor of a vehicle state data processing system as described above. As shown in fig. 4, the method includes:
s401: receiving real-time state data of the vehicle sent by a service processor;
s402: and analyzing and processing the real-time state data of the vehicle, and sending the analysis result and the real-time state data of the vehicle to a database for storage.
It will be appreciated that the analysis of the real-time status data of the vehicle by the data processor may be increased according to requirements, such as real-time calculation of travel-based data, analysis of driving behavior, supporting UBI (Usage Based Insurance, insurance based on use), and the like, without limitation. The data processor is provided with enough operation capability in a targeted manner, so that the problems of high load and slow response of the traditional Internet of vehicles cloud platform integrating the business and the data processing can not be generated.
According to the embodiment of the application, the service platform and the analysis platform are arranged, the data service processing task and the data analysis task are decoupled and distributed to the two processors, the service processor can respond to more data service requests and data uploading which are concurrent, the data processor can concentrate on data analysis processing of large data volume, the two processors are respectively configured according to different requirements, the processors are not affected each other, and the processors can work efficiently, so that more efficient data processing is realized, the service requests are responded quickly, and the user experience is improved.
After receiving the message, the packet data is asynchronously unpacked, namely the message is analyzed, the real-time state data of the vehicle in the field form can be obtained, then the format or the content invalid data can be filtered again to obtain the valid data, the valid data can be further filtered, for example, whether the travel data is calculated or not and whether the travel is in the allowed travel range or not can be determined, if the travel is in the allowed travel range, the real-time state data of the vehicle can be stored in the database through the content filtering. In some specific embodiments, before the analyzing and processing the real-time status data of the vehicle, the method further includes:
and analyzing the real-time state data of the vehicle by the message, and filtering invalid information from the real-time state data of the vehicle after the analysis of the message.
It should be understood that the sequence number of each step in the foregoing embodiment does not mean that the execution sequence of each process should be determined by the function and the internal logic, and should not limit the implementation process of the embodiment of the present application.
Fig. 5 is a schematic diagram of an electronic device 5 according to an embodiment of the present application. As shown in fig. 5, the electronic apparatus 5 of this embodiment includes: a processor 501, a memory 502 and a computer program 503 stored in the memory 502 and executable on the processor 501. The steps of the various method embodiments described above are implemented by processor 501 when executing computer program 503. Alternatively, the processor 501, when executing the computer program 503, performs the functions of the modules/units in the above-described apparatus embodiments.
The electronic device 5 may be a desktop computer, a notebook computer, a palm computer, a cloud server, or the like. The electronic device 5 may include, but is not limited to, a processor 501 and a memory 502. It will be appreciated by those skilled in the art that fig. 5 is merely an example of the electronic device 5 and is not limiting of the electronic device 5 and may include more or fewer components than shown, or different components.
The processor 501 may be a central processing unit (Central Processing Unit, CPU) or other general purpose processor, digital signal processor (Digital Signal Processor, DSP), application specific integrated circuit (Application Specific Integrated Circuit, ASIC), field programmable gate array (Field-Programmable Gate Array, FPGA) or other programmable logic device, discrete gate or transistor logic device, discrete hardware components, or the like.
The memory 502 may be an internal storage unit of the electronic device 5, for example, a hard disk or a memory of the electronic device 5. The memory 502 may also be an external storage device of the electronic device 5, for example, a plug-in hard disk, a Smart Media Card (SMC), a Secure Digital (SD) Card, a Flash Card (Flash Card) or the like, which are provided on the electronic device 5. Memory 502 may also include both internal storage units and external storage devices of electronic device 5. The memory 502 is used to store computer programs and other programs and data required by the electronic device.
It will be apparent to those skilled in the art that, for convenience and brevity of description, only the above-described division of the functional units and modules is illustrated, and in practical application, the above-described functional distribution may be performed by different functional units and modules according to needs, i.e. the internal structure of the apparatus is divided into different functional units or modules to perform all or part of the above-described functions. The functional units and modules in the embodiment may be integrated in one processing unit, or each unit may exist alone physically, or two or more units may be integrated in one unit, where the integrated units may be implemented in a form of hardware or a form of a software functional unit.
The integrated modules/units, if implemented in the form of software functional units and sold or used as stand-alone products, may be stored in a computer readable storage medium. Based on such understanding, the present application may implement all or part of the flow of the method of the above embodiment, or may be implemented by a computer program to instruct related hardware, and the computer program may be stored in a computer readable storage medium, where the computer program, when executed by a processor, may implement the steps of each of the method embodiments described above. The computer program may comprise computer program code, which may be in source code form, object code form, executable file or in some intermediate form, etc. The computer readable storage medium may include: any entity or device capable of carrying computer program code, a recording medium, a U disk, a removable hard disk, a magnetic disk, an optical disk, a computer Memory, a Read-Only Memory (ROM), a random access Memory (Random Access Memory, RAM), an electrical carrier signal, a telecommunications signal, a software distribution medium, and so forth. It should be noted that the content of the computer readable storage medium may be appropriately increased or decreased according to the requirements of jurisdictions in which the computer readable storage medium does not include electrical carrier signals and telecommunication signals, for example, according to jurisdictions in which the computer readable storage medium is not configured.
The above embodiments are only for illustrating the technical solution of the present application, and are not limiting; although the application has been described in detail with reference to the foregoing embodiments, it will be understood by those of ordinary skill in the art that: the technical scheme described in the foregoing embodiments can be modified or some technical features thereof can be replaced by equivalents; such modifications and substitutions do not depart from the spirit and scope of the technical solutions of the embodiments of the present application, and are intended to be included in the scope of the present application.

Claims (10)

1.一种车辆状态数据处理系统,其特征在于,包括业务平台和分析平台,所述业务平台包括业务处理器和数据缓存器,所述分析平台包括数据处理器和数据库,其中:1. A vehicle status data processing system, characterized in that it includes a business platform and an analysis platform, the business platform includes a business processor and a data cache, the analysis platform includes a data processor and a database, wherein: 所述业务处理器用于接收车辆实时状态数据,并对所述车辆实时状态数据进行预处理后发送给所述数据处理器;The business processor is used to receive vehicle real-time status data, preprocess the vehicle real-time status data and then send it to the data processor; 所述数据处理器用于对所述车辆实时状态数据进行分析处理,并将所述分析结果和所述车辆实时状态数据发送到所述数据库存储;The data processor is configured to analyze and process the vehicle real-time status data, and send the analysis results and the vehicle real-time status data to the database for storage; 所述业务处理器还用于从所述数据库中读取目标缓存数据并将所述目标缓存数据缓存至所述数据缓存器;The service processor is also configured to read target cache data from the database and cache the target cache data to the data cache; 所述业务处理器还用于接收业务请求,并根据所述业务请求从所述数据缓存器中读取对应的目标请求数据并返回。The service processor is also configured to receive a service request, read the corresponding target request data from the data cache according to the service request, and return it. 2.一种车辆状态数据处理方法,其特征在于,应用于如权利要求1所述的车辆状态数据处理系统的业务处理器,所述方法包括:2. A vehicle status data processing method, characterized in that it is applied to the business processor of the vehicle status data processing system as claimed in claim 1, and the method includes: 接收车辆实时状态数据,并对所述车辆实时状态数据进行预处理后发送给数据处理器,以使所述数据处理器对所述车辆实时状态数据进行分析处理,并将所述分析结果和所述车辆实时状态数据发送到数据库存储;Receive vehicle real-time status data, pre-process the vehicle real-time status data and then send it to the data processor, so that the data processor analyzes and processes the vehicle real-time status data, and combines the analysis results with all the vehicle real-time status data. The real-time status data of the vehicle are sent to the database for storage; 从所述数据库中读取目标缓存数据并将所述目标缓存数据缓存至数据缓存器;Read target cache data from the database and cache the target cache data to the data cache; 接收业务请求,根据所述业务请求从所述数据缓存器中读取对应的目标请求数据并返回。Receive a service request, read the corresponding target request data from the data cache according to the service request and return it. 3.根据权利要求2所述的方法,其特征在于,接收车辆实时状态数据,并对所述车辆实时状态数据进行预处理后发送给数据处理器的过程,包括:3. The method according to claim 2, characterized in that the process of receiving vehicle real-time status data, preprocessing the vehicle real-time status data and then sending it to the data processor includes: 接收车辆实时状态数据,并对所述车辆实时状态数据进行预处理,然后通过消息中间件将预处理后的所述车辆实时状态数据发送给数据处理器。Receive vehicle real-time status data, preprocess the vehicle real-time status data, and then send the preprocessed vehicle real-time status data to the data processor through the message middleware. 4.根据权利要求3所述的方法,其特征在于,所述预处理包括校验所述车辆实时状态数据的协议头的时间和类型;4. The method according to claim 3, wherein the preprocessing includes verifying the time and type of the protocol header of the vehicle real-time status data; 相应的,通过消息中间件将预处理后的所述车辆实时状态数据发送给数据处理器的过程,包括:Correspondingly, the process of sending the preprocessed vehicle real-time status data to the data processor through the message middleware includes: 通过消息中间件将校验通过的所述车辆实时状态数据发送给数据处理器。The verified vehicle real-time status data is sent to the data processor through the message middleware. 5.根据权利要求4的方法,其特征在于,通过消息中间件将校验通过的所述车辆实时状态数据发送给数据处理器的过程,包括:5. The method according to claim 4, characterized in that the process of sending the verified vehicle real-time status data to a data processor through a message middleware includes: 将校验通过的所述车辆实时状态数据分发到消息中间件中对应所述类型的TOPIC中,以使数据处理器在监听所述消息中间件的所有所述TOPIC时获取校验通过的所述车辆实时状态数据。Distribute the vehicle real-time status data that passes the verification to the TOPIC corresponding to the type in the message middleware, so that the data processor obtains the verification that passes the TOPIC when monitoring all the TOPICs of the message middleware. Real-time vehicle status data. 6.根据权利要求2所述的方法,其特征在于,接收车辆实时状态数据的过程,包括:6. The method according to claim 2, characterized in that the process of receiving vehicle real-time status data includes: 接收以不同的预设频率发送的车辆状态数据,所述预设频率设置于MQTT协议中。Receive vehicle status data sent at different preset frequencies, which are set in the MQTT protocol. 7.根据权利要求2至6任一项所述的方法,其特征在于,从所述数据库中读取目标缓存数据并将所述目标缓存数据缓存至数据缓存器之后,还包括:7. The method according to any one of claims 2 to 6, characterized in that after reading the target cache data from the database and caching the target cache data to the data cache, it further includes: 按照预设更新频率,判断所述数据缓存器中是否存在所述目标缓存数据的缓存时长超出预设时长;According to the preset update frequency, determine whether the cache duration of the target cache data in the data buffer exceeds the preset duration; 若是,则从所述数据库中读取新的所述目标缓存更新数据以更新当前所述目标缓存数据。If so, read new target cache update data from the database to update the current target cache data. 8.根据权利要求2至6任一项所述的方法,其特征在于,接收业务请求,根据所述业务请求从所述数据缓存器中读取对应的目标请求数据并返回的过程,包括:8. The method according to any one of claims 2 to 6, characterized in that the process of receiving a service request, reading the corresponding target request data from the data buffer according to the service request and returning it includes: 接收业务请求,判断所述数据缓存器中所述业务请求对应的所述目标请求数据的缓存时长是否超出预设时长;Receive a service request and determine whether the cache duration of the target request data corresponding to the service request in the data cache exceeds a preset duration; 若是,则从所述数据库中读取新的所述目标缓存更新数据以更新当前所述目标缓存数据,再根据所述业务请求从所述数据缓存器中读取对应的目标请求数据并返回;If so, read the new target cache update data from the database to update the current target cache data, and then read the corresponding target request data from the data cache according to the business request and return; 若否,则直接根据所述业务请求从所述数据缓存器中读取对应的目标请求数据并返回。If not, the corresponding target request data is directly read from the data cache according to the service request and returned. 9.一种车辆状态数据处理方法,其特征在于,应用于如权利要求1所述的车辆状态数据处理系统的数据处理器,所述方法包括:9. A vehicle status data processing method, characterized in that it is applied to the data processor of the vehicle status data processing system as claimed in claim 1, and the method includes: 接收业务处理器发送的车辆实时状态数据;Receive real-time vehicle status data sent by the business processor; 对所述车辆实时状态数据进行分析处理,并将所述分析结果和所述车辆实时状态数据发送到数据库存储。Perform analysis and processing on the vehicle real-time status data, and send the analysis results and the vehicle real-time status data to a database for storage. 10.根据权利要求9的方法,其特征在于,对所述车辆实时状态数据进行分析处理之前,还包括:10. The method according to claim 9, characterized in that before analyzing and processing the vehicle real-time status data, it further includes: 对所述车辆实时状态数据进行消息解析,并对消息解析后的所述车辆实时状态数据过滤无效信息。Perform message analysis on the vehicle real-time status data, and filter invalid information on the vehicle real-time status data after message analysis.
CN202310722411.0A 2023-06-16 2023-06-16 A vehicle status data processing system and method Pending CN116800611A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202310722411.0A CN116800611A (en) 2023-06-16 2023-06-16 A vehicle status data processing system and method

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202310722411.0A CN116800611A (en) 2023-06-16 2023-06-16 A vehicle status data processing system and method

Publications (1)

Publication Number Publication Date
CN116800611A true CN116800611A (en) 2023-09-22

Family

ID=88039627

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202310722411.0A Pending CN116800611A (en) 2023-06-16 2023-06-16 A vehicle status data processing system and method

Country Status (1)

Country Link
CN (1) CN116800611A (en)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN119621273A (en) * 2024-11-25 2025-03-14 数字广东网络建设有限公司 A data reporting method, device, equipment, medium and product

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103489301A (en) * 2013-09-25 2014-01-01 东风汽车公司 Vehicle running information acquisition system and method using dual-processor architecture
CN106326389A (en) * 2016-08-17 2017-01-11 深圳市金证科技股份有限公司 Data-caching-based service request processing method and system
CN106940660A (en) * 2016-01-05 2017-07-11 阿里巴巴集团控股有限公司 The method and apparatus of the realization of caching
CN115510012A (en) * 2022-09-13 2022-12-23 中国建设银行股份有限公司 Service data processing method, device, computer equipment and storage medium

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103489301A (en) * 2013-09-25 2014-01-01 东风汽车公司 Vehicle running information acquisition system and method using dual-processor architecture
CN106940660A (en) * 2016-01-05 2017-07-11 阿里巴巴集团控股有限公司 The method and apparatus of the realization of caching
CN106326389A (en) * 2016-08-17 2017-01-11 深圳市金证科技股份有限公司 Data-caching-based service request processing method and system
CN115510012A (en) * 2022-09-13 2022-12-23 中国建设银行股份有限公司 Service data processing method, device, computer equipment and storage medium

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN119621273A (en) * 2024-11-25 2025-03-14 数字广东网络建设有限公司 A data reporting method, device, equipment, medium and product

Similar Documents

Publication Publication Date Title
CN112749358B (en) Page rendering method and device, electronic device and storage medium
CN107370806B (en) HTTP status code monitoring method, device, storage medium and electronic device
CN111818136A (en) Data processing method, apparatus, electronic device and computer readable medium
CN108011904A (en) Method for sending information, method of reseptance, device and information transmission system
CN113645287B (en) Automobile message storage method and device and automobile message storage system
CN110297944B (en) Distributed XML data processing method and system
CN120029856B (en) System and method for data interaction, electronic device and storage medium
CN116582905A (en) Vehicle data transmission method, device, electronic device and storage medium
CN111885165A (en) Device data acquisition and transmission and reverse control method and device
CN115017374A (en) Data analysis method, target vehicle, data analysis system and storage device
CN117082137A (en) Communication method, device, equipment and medium for maintaining OTA upgrade refreshing mode
CN115643294A (en) Vehicle control method, apparatus, system, and storage medium
CN116800611A (en) A vehicle status data processing system and method
CN117201404A (en) Vehicle data upload method, equipment and storage medium
CN113758689A (en) Method and device for testing chassis characteristics of drivable equipment
CN114584618A (en) Information interaction method, device, equipment, storage medium and system
CN107231647A (en) Network detection method, network detection device and intelligent terminal
CN120768803A (en) Communication delay detection method, device, equipment, storage medium and program product
CN113411371B (en) Communication method and device applied to vehicle, electronic equipment and vehicle
CN111404842A (en) Data transmission method, device and computer storage medium
CN113766020A (en) Remote control system and method for satellite navigation receiver equipment
US20240311135A1 (en) Center device and campaign information distribution method
CN106302240A (en) Received server-side client concurrently connects and data processing method
CN112100414B (en) Data processing method, device, system and computer readable storage medium
CN117997727A (en) Log landing method and device for CDN, medium and electronic equipment

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
TA01 Transfer of patent application right
TA01 Transfer of patent application right

Effective date of registration: 20240116

Address after: No. 13 Xingxiang Road, Zengjia Town, High tech Zone, Shapingba District, Chongqing, 400039

Applicant after: Chongqing Selis Phoenix Intelligent Innovation Technology Co.,Ltd.

Address before: No. 801, 8th Floor, Building 2, No. 168 Tianfu Fifth Street, Chengdu High tech Zone, China (Sichuan) Pilot Free Trade Zone, Chengdu City, Sichuan Province, 610095

Applicant before: Chengdu Thalys Technology Co.,Ltd.