CN-116150214-B - Cluster data query method, device and system

CN116150214BCN 116150214 BCN116150214 BCN 116150214BCN-116150214-B

Abstract

The application discloses a method, a device and a system for inquiring cluster data, which are used for generating cluster information according to a data inquiry request of a client, acquiring real-time data of a plurality of data production ends corresponding to the cluster information, and sending the real-time data to the client when the data ready rate is larger than a preset proportion, wherein the data ready rate characterizes the proportion of the acquired real-time data corresponding to the cluster information to the required data corresponding to the cluster information, after the data inquiry request of the client is received, the cluster information is generated according to the data inquiry request, the real-time data of the corresponding data production ends is acquired according to the cluster information, and the real-time data of the cluster is sent to the client when the data ready rate is larger than the preset proportion, namely, the data inquiry is carried out step by step, decoupling is carried out, and the cluster relation is automatically managed, and the interaction quantity and frequency of the client and the data production ends are reduced, so that the real-time property and efficiency of the data inquiry of the client are improved.

Inventors

DU ENKUAN
WU WENCHAO
ZHANG YUNFEI
LIN HUAN

Assignees

深圳市云洲创新科技有限公司
珠海云洲智能科技股份有限公司

Dates

Publication Date: 20260505
Application Date: 20221123

Claims (9)

1. The cluster data query method is characterized by being applied to a cluster system, wherein the cluster system comprises a plurality of data production ends, and the cluster data query method comprises the following steps: Receiving a data query request of a client; Generating cluster information according to the data query request, wherein the cluster information corresponds to a plurality of data production ends; acquiring real-time data of a plurality of data production ends corresponding to the cluster information, and When the data ready rate is larger than a preset proportion, the real-time data is sent to the client, wherein the data ready rate characterizes the proportion of the acquired real-time data corresponding to the cluster information to the required data corresponding to the cluster information; the generating cluster information according to the data query request comprises the following steps: generating at least one cluster serial number according to the data query request, wherein the cluster serial number corresponds to a plurality of data production ends; The method comprises the steps of constructing a topic data table, a cluster corresponding table and a cluster position table, wherein the topic data table comprises a client address corresponding to a data query request, a character identifier corresponding to the data query request and a topic of the data query request, the character identifier represents a unique identifier corresponding to a cluster serial number, the cluster corresponding table comprises the character identifier, the cluster serial number and a data acquisition state, and the cluster position table comprises the cluster serial number and position information of a plurality of data production ends.
2. The method of claim 1, wherein the obtaining real-time data of the plurality of data generating ends corresponding to the cluster information includes: and comparing the theme and character identifier of the real-time data corresponding to the cluster serial number with the theme and character identifier of the theme data table to obtain the real-time data corresponding to the cluster information.
3. The clustered data query method of claim 1, wherein after generating clustered information from the data query request, the clustered data query method further comprises: sending the cluster information to the client; Receiving a state query request of the client, wherein the state query request comprises the cluster information; inquiring according to the cluster information to obtain the state information of the real-time data corresponding to the cluster information, and And sending the state information to the client.
4. The method for querying cluster data according to claim 3, wherein the obtaining the state information of the real-time data corresponding to the cluster information according to the cluster information query includes: Inquiring the data acquisition state of the corresponding real-time data according to the cluster serial number.
5. The clustered data query method of claim 1, wherein sending the real-time data to the client when the data ready rate is greater than a preset ratio comprises: When the data ready rate is larger than the preset proportion, receiving the data acquisition request of the client side and And sending the real-time data to the client according to the data acquisition request.
6. The clustered data query method of claim 1, wherein prior to the receiving the data acquisition request of the client, the clustered data query method further comprises: and calculating the proportion of the real-time data corresponding to the cluster information and the demand data corresponding to the cluster information to obtain the data ready rate.
7. The cluster data query device is characterized by being applied to a cluster system, wherein the cluster system comprises a plurality of data production ends, the cluster data query device is in communication connection with the plurality of data production ends in the cluster system, and the cluster data query device comprises: the data request module is used for receiving a data query request of the client; The state management module is used for generating cluster information according to the data query request, wherein the cluster information corresponds to a plurality of data production ends, the generating of the cluster information according to the data query request comprises generating at least one cluster serial number according to the data query request, the cluster serial number corresponds to a plurality of data production ends, constructing a topic data table, a cluster corresponding table and a cluster position table, wherein the topic data table comprises a client address corresponding to the data query request, a character identifier corresponding to the data query request and a topic of the data query request, the character identifier represents a unique identifier corresponding to the cluster serial number, the cluster corresponding table comprises the character identifier, the cluster serial number and a data acquisition state, and the cluster position table comprises the cluster serial number and position information of a plurality of data production ends; A data transceiver module for acquiring real-time data of a plurality of data production ends corresponding to the cluster information, and And the data feedback module is used for sending the real-time data to the client when the data ready rate is larger than a preset proportion, wherein the data ready rate characterizes the proportion of the acquired real-time data corresponding to the cluster information to the required data corresponding to the cluster information.
8. The clustered data query device of claim 7, wherein the clustered data query device further comprises: And the state query module is used for receiving the state query request of the client and sending the state information of the real-time data corresponding to the cluster information to the client.
9. A clustered data query system, comprising: A plurality of data producing terminals; client side, and The clustered data query apparatus of claim 7 or 8, communicatively coupled to a plurality of the data producing ends, the clients.

Description

Cluster data query method, device and system Technical Field The present application relates to the field of cluster data query technologies, and in particular, to a cluster data query method, device and system. Background The producer consumer mode is a mode of transmitting data that is unique to Controlnet networks. In the producer consumer mode, the messages of the internet of things platform are multiple first-in first-out queues. In the consumption of real-time messages, the time difference (real-time threshold) between the earliest and latest messages is an adjustable threshold, and it is apparent that the larger the time difference is, the more abundant the real-time messages theoretically are, but the lower the time efficiency of the consumption distribution is. The unmanned surface vessel (Unmanned Surface Vehicles, USV) can realize manual control and autonomous navigation functions through the cooperation of an on-board intelligent control system and a remote wireless remote control system. The unmanned surface vessel can be regarded as an intelligent robot for executing tasks on the water surface, corresponding functional modules can be carried according to different requirements, and the robot with specific functions can be formed to replace a user to execute various tasks. In the intelligent boat big data platform, real-time monitoring and decision command are required to conduct command control according to clear and accurate historical tracks, and quick real-time feedback data is required, so that the accuracy of command control is further improved, the intelligent boat big data platform has the characteristics of multiple clusters, large cluster scale, dense information, large information data volume and high real-time degree, the application support is required to be completed based on the real-time information of the information middleware, the real-time threshold cannot be set too small, but the data volume of the real-time information is rapidly enlarged after the real-time threshold is large, and the system pressure is rapidly deteriorated. And the wireless communication is further aggravated under the adverse effects of limited bandwidth, numerous interference factors and higher data packet loss rate of the wireless communication in the open water area. Disclosure of Invention The present application has been made to solve the above-mentioned technical problems. The embodiment of the application provides a cluster data query method, device and system, which solve the technical problems. According to one aspect of the application, a cluster data query method is provided and applied to a cluster system, the cluster system comprises a plurality of data production ends, the cluster data query method comprises the steps of receiving a data query request of a client, generating cluster information according to the data query request, wherein the cluster information corresponds to a plurality of the data production ends, acquiring real-time data of the plurality of the data production ends corresponding to the cluster information, and sending the real-time data to the client when the data ready rate is larger than a preset proportion, and the data ready rate represents the proportion of the acquired real-time data corresponding to the cluster information to the required data corresponding to the cluster information. In an embodiment, generating cluster information according to the data query request comprises generating at least one cluster serial number according to the data query request, wherein the cluster serial number corresponds to a plurality of data production ends, constructing a theme data table, a cluster corresponding table and a cluster position table, wherein the theme data table comprises a client address corresponding to the data query request, a character identifier corresponding to the data query request and a theme of the data query request, the character identifier represents a unique identifier corresponding to the cluster serial number, the cluster corresponding table comprises the character identifier, the cluster serial number and a data acquisition state, and the cluster position table comprises the cluster serial number and position information of a plurality of data production ends. In an embodiment, the obtaining the real-time data of the plurality of data production ends corresponding to the cluster information includes comparing a theme and a character identifier of the real-time data corresponding to the cluster serial number with a theme and a character identifier of the theme data table to obtain the real-time data corresponding to the cluster information. In one embodiment, after generating the cluster information according to the data query request, the cluster data query method further comprises the steps of sending the cluster information to the client, receiving a state query request of the client, wherein the state query request comprises the cluster in