WO2020124619A1 - Data processing method and device, computer apparatus, and storage medium - Google Patents

Abstract

A data processing method and device, a computer apparatus, and a storage medium. The method comprises: obtaining a data processing request comprising a database identifier (S102); determining, according to the database identifier, a target database microservice, wherein the target database microservice provides a data processing interface of a target database corresponding to the data processing request (S104); and sending the data processing request to the target database microservice, and performing, by means of the data processing interface provided by the target database microservice, a data processing operation corresponding to the data processing request (S106). The present method can improve the efficiency of data processing.

Description

Data processing method, device, computer equipment and storage medium Technical field

The present invention relates to the field of database technology, and in particular, to a data processing method, device, computer equipment, and storage medium.

Background technique

Database refers to a collection of data. Existing databases include relational databases and non-relational databases. For example, mysql and Oracle are relatively common relational databases. However, with the rapid development of the Internet, traditional relational databases are dealing with large When it comes to dynamic websites with large scale, large traffic, and high concurrency, they seem to be unable to handle it. At this time, non-relational databases have developed rapidly.

technical problem

However, different non-relational databases have different operations for addition, deletion, modification, and checking. Developers need to spend a lot of time to understand the operation methods of different non-relational databases, that is, use different languages to perform addition, deletion, Modify and check operations to reduce data processing efficiency.

Technical solution

Based on this, it is necessary to propose a data processing method, device, computer equipment, and storage medium with high data processing efficiency in view of the above problems.

A data processing method, the method includes:

Obtain a data processing request, which includes a database identifier;

Determine the target database microservice according to the database identifier, the target database microservice provides a data processing interface of the target database corresponding to the data processing request;

Sending the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

In one of the embodiments, the data processing request further includes a function identifier, and sending the data processing request to the target database microservice includes sending the function identifier to the target database microservice, In order that the target database microservice executes the data processing operation corresponding to the function identifier through the function interface determined according to the function identifier.

In one of the embodiments, the sending the data processing request to the target database microservice includes: searching the address information of the target database microservice through a microservice registration center; based on the address information, the The data processing request is sent to the target database microservice.

In one of the embodiments, before the acquiring data processing request, the method further includes: receiving a microservice registration request through the microservice registration center, where the microservice registration request includes the microservice identifier and the location of the microservice to be registered The address information of the microservice to be registered; correspondingly storing the identifier of the microservice to be registered and the address information of the microservice to be registered to complete the registration of the microservice to be registered.

In one of the embodiments, the acquiring the data processing request includes: acquiring the sending time of the data processing request; determining the processing sequence number of the data processing request according to the sending time; when polling the processing sequence number At that time, the data processing request is obtained, and the step of determining the target database microservice according to the database identifier is entered.

In one embodiment, after the data processing request is sent to the target database microservice, the method further includes: when receiving data processing exception information, generating an abnormal data storage request according to the data processing exception information Sending the abnormal data storage request to the abnormal database to store the abnormal data processing information in the abnormal database.

A data processing device, the device includes:

An acquisition module, for acquiring a data processing request, the data processing request including a database identifier;

A determining module, configured to determine a target database microservice according to the database identifier, and the target database microservice provides a data processing interface of the target database corresponding to the data processing request;

The sending module is configured to send the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

In one of the embodiments, the data processing request further includes a function identifier, and the sending module 606 includes: a function sending module, configured to send the function identifier to the target database microservice to enable the target The database microservice performs a data processing operation corresponding to the function identifier through the function interface determined according to the function identifier.

In one of the embodiments, the sending module 606 includes: a searching module for searching the address information of the microservice of the target database through a microservices registration center; a searching sending module for searching the address based on the address information The data processing request is sent to the target database microservice.

In one of the embodiments, the apparatus 600 further includes: a receiving module, configured to receive a microservice registration request through the microservice registration center, where the microservice registration request includes the microservice identifier and the microservice identifier of the microservice to be registered Address information of the microservice to be registered; a storage module, configured to correspondingly store the identifier of the microservice to be registered and the address information of the microservice to be registered to complete the registration of the microservice to be registered.

In one of the embodiments, the acquisition module 602 includes: a time acquisition module for acquiring the sending time of the data processing request; a serial number determining module for determining the data processing request according to the sending time Processing sequence number; the rotation training module is used to obtain the data processing request when polling the processing sequence number, and enter the step of determining the target database microservice according to the database identification.

In one of the embodiments, the device 600 further includes: an abnormal request generating module, configured to generate an abnormal data storage request according to the data processing abnormal information when receiving data processing abnormal information; an abnormal request sending module, used Sending the abnormal data storage request to the abnormal database to store the data processing abnormal information in the abnormal database.

A computer device includes a memory and a processor. The memory stores a computer program. When the computer program is executed by the processor, the processor is caused to perform the following steps:

Obtain a data processing request, which includes a database identifier;

Determine the target database microservice according to the database identifier, the target database microservice provides a data processing interface of the target database corresponding to the data processing request;

Sending the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

A computer-readable storage medium stores a computer program, and when the computer program is executed by a processor, the processor is caused to perform the following steps:

Obtain a data processing request, which includes a database identifier;

Determine the target database microservice according to the database identifier, the target database microservice provides a data processing interface of the target database corresponding to the data processing request;

Sending the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

Beneficial effect

The implementation of the embodiments of the present invention will have the following beneficial effects:

The invention proposes a data processing method, device, computer equipment and storage medium. First, a data processing request is obtained, and the data processing request includes a database identifier; then according to the database identifier, a target database microservice is determined, and the target database The microservice provides a data processing interface of the target database corresponding to the data processing request; finally, the data processing request is sent to the target database microservice to execute and execute the data processing interface provided by the target database microservice The data processing operation corresponding to the data processing request. It can be seen that, in the above manner, because different databases correspond to different database microservices, database microservices provide data processing interfaces corresponding to the database, so that when performing related operations on the database, it is no longer necessary to understand the operating language of the database, and Directly confirm the corresponding database microservice according to the data processing request and send the request to the microservice, which improves the efficiency of data processing.

BRIEF DESCRIPTION

In order to more clearly explain the embodiments of the present invention or the technical solutions in the prior art, the following will briefly introduce the drawings required in the embodiments or the description of the prior art. Obviously, the drawings in the following description are only These are some embodiments of the present invention. For those of ordinary skill in the art, without paying any creative labor, other drawings can be obtained based on these drawings.

among them:

1 is a schematic diagram of an implementation process of a data processing method in an embodiment;

2 is a schematic diagram of a partial implementation process of a data processing method in an embodiment;

FIG. 3 is a schematic diagram of database microservices registered in a microservices registration center in an embodiment;

4 is a schematic diagram of an application environment of a data processing method in an embodiment;

5 is a schematic diagram of an implementation process of a data processing method in an embodiment;

6 is a structural block diagram of a data processing device in an embodiment;

7 is a structural block diagram of a computer device in an embodiment;

FIG. 8 is an application environment diagram of a data processing method in an embodiment.

Embodiments of the invention

The technical solutions in the embodiments of the present invention will be described clearly and completely in conjunction with the drawings in the embodiments of the present invention. Obviously, the described embodiments are only a part of the embodiments of the present invention, but not all of the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by a person of ordinary skill in the art without making creative efforts fall within the protection scope of the present invention.

As shown in FIG. 1, in one embodiment, a data processing method is provided. This method is applied to the server. The server is a high-performance computer or a high-performance computer cluster. The data processing method specifically includes the following steps:

Step 102: Obtain a data processing request, where the data processing request includes a database identifier.

The data processing request is used to indicate a database to perform an operation and a data processing operation to be performed by the database, wherein the data processing operation refers to an operation performed on the database, and the data processing operation may include but is not limited to adding data Operation, delete data operation, find data operation and modify data operation. In the embodiment of the present invention, a database identifier is set in the data processing request to indicate the database.

The database identifier is used to uniquely mark a database, or to uniquely identify a database microservice. For example, a certain database is a Redis database, and the database identifier of the database may be Redis-SJCC, which is used to indicate a Redis database; if a certain database identifier is RedisWservice-SJCC, then the database identifier is used to indicate a database microservice.

The database identifier may be composed of numbers and/or letters and/or characters. For example, the database identifier is 01-Redis-SJK for indicating the Redis database, or the database identifier is 01-RedisWservice-SJKWFF for Indicates database microservices.

The data processing request may be sent by the user to the server through the client, that is, the user remotely operates the server on the client. For example, a user performs a data query operation on a database on the client, and then submits a data processing request for querying the data.

The data processing request may also be that the user directly operates the server, that is, the user submits the data processing request on the server side, for example, the user passes the database operation interface on the server side (through the data operation interface, it is convenient for the user to perform data processing on multiple databases Operation, unified management of multiple databases) Enter the query information, and click the query button, by clicking the query button, a data processing request is generated, so that the server obtains the data processing request.

Step S104: Determine a target database microservice according to the database identifier, and the target database microservice provides a data processing interface of the target database corresponding to the data processing request.

In the embodiment of the present invention, a one-to-one relationship is established between a database and a database microservice, that is, one database uniquely corresponds to one database microservice. Therefore, regardless of whether the database identifier is used to indicate the database or the database microservice, the corresponding data processing operation can be performed on the corresponding database.

In the embodiment of the present invention, according to the database identifier, the target database microservice can be uniquely identified. Specifically, if the database identifier is a library identifier used to indicate the database, the database is first found according to the library identifier, and then the target database microservice is determined according to the one-to-one correspondence between the database and the database microservice, as shown in Table 1; If the database identifier is a microservice identifier used to indicate the database microservice, the target database microservice corresponding to the microservice identifier can be directly found, and then the data processing is determined according to the one-to-one correspondence between the database microservice and the database The target database for operation is shown in Table 2.

Table 1

Library ID database Database microservices Re Redis Re-Wservice HB HBbase HB-Wservice Mo MongoDb Mo-Wservice

Table 2

Microservice logo Database microservices database Redis-service Re-Wservice Redis HBbase-service HB-Wservice HBbase MongoDb-service Mo-Wservice MongoDb

In the embodiment of the present invention, the database includes a relational database and a non-relational database. Among them, the relational database may include but not limited to: MySQL, Oracle and Microsoft Access; the non-relational database may include but not limited to: Redis, HBbase and MongoDb.

The database microservice is a microservice corresponding to the database and capable of realizing the data processing operation of the database. Specifically, the database microservice can provide a data processing interface of the database, for example, database add operation, delete operation, check operation and Change the data processing interface of the operation to realize the data processing function of adding, deleting, checking and modifying. The target database microservice is used to indicate the database microservice determined according to the database identifier.

The data processing interface may use a restful service interface. REST principle: all things on the network are abstracted as resources; each resource has a unique resource identifier; the same resource has multiple manifestations (XML, JSON, etc.) (xml, json, etc.); Various operations do not change the resource identifier; all operations are stateless. By adopting the restful service interface for the data processing interface of the database microservices, it is possible to shield the problem of calling in different languages and realize the calling in different languages of clients.

Step S106: Send the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

Here, the data processing request is sent to the target database microservice. After receiving the data processing request, the target database microservice knows the data processing operation to be performed by parsing the data data processing request, and then executes the data through the data processing interface Handling operations.

In the embodiment of the present invention, the data processing request further includes a function identifier, and sending the data processing request to the target database microservice includes:

Sending the function identifier to the target database microservice, so that the target database microservice performs a data processing operation corresponding to the function identifier through a function interface determined according to the function identifier.

The function identifier is used to indicate a data processing operation that needs to be completed by a database microservice.

The function identifier may include only the function task identifier, which is used to indicate the data processing operation completed by the database microservice. For example, the function identifier is 01-cha-zeng, where 01-cha-zeng is the function task identifier, indicating that the database microservice After the service completes the data processing operation of adding data, after identifying the functional task identifier, the database microservice first obtains the newly added resource data from the data area indicated by the server according to the identifier information cha, and then obtains the obtained resource data according to the identifier information zeng Join the database. Correspondingly, after the resource data is added to the database, the server instructs the data area to delete the resource data; for another example, the function ID is 02-cha-shan, instructing the database microservice to complete the data processing operation of deleting data, the database After identifying the functional task identifier, the microservice first queries resource data to be deleted from the data area indicated by the server according to the identifier information cha, and then deletes the queried resource data in the database according to the identifier information shan. The instruction data area is a storage area in the server, and the instruction data area is used to indicate data that needs to be added, deleted, or modified.

The function identifier may include a function task identifier and a processing data identifier, which are used to instruct the database microservice to complete the specified data processing operation on the specified data. For example, the function identifier is 01-zeng-yonghu1, instructing the database microservice to add user 1's data to the database; for another example, the function identifier is 01-shan-yonghu1, instructing the database microservice to delete user 1's data in the database. The function identifier may also indicate the data location more specifically. For example, the function identifier is 01-shan-biao1-yonghu1, and the user instructs the database to delete the data of user 1 in Table 1.

The function identifier may be composed of numbers and/or letters and/or characters. For example, the function identifier is 01-zeng-yonghu1.

In the embodiment of the present invention, as shown in FIGS. 2 and 3, before acquiring the data processing request described in step 102, the method further includes:

Step 100: Receive a microservice registration request through the microservice registration center, where the microservice registration request includes a microservice identifier of the microservice to be registered and address information of the microservice to be registered.

Step 101: Correspondingly store the ID of the microservice to be registered and the address information of the microservice to be registered to complete the registration of the microservice to be registered.

The microservice registration center is used to realize the registration of microservices of different databases. Through the registration of database microservices, the microservice registration center can obtain the microservice identification and address information of microservices of different databases.

Before performing step 102, database microservices corresponding to different databases are registered in the registration center. Specifically, when the database microservices are online (that is, when a new database is added), a microservice registration request is sent to the microservice registration center The microservice registration request includes the microservice identifier of the microservice to be registered and the address information of the microservice to be registered. After receiving the microservice registration request, the microservice registration center parses out the microservice identifier and address information, And store it, so that when there is a data processing request, it can provide the address information of the registered database microservice.

When the database microservice is offline, that is, when the database corresponding to the database microservice is stopped, the microservice registration center needs to delete the microservice identification information and address information of the database microservice. Specifically, when the database microservice goes offline, a logoff request is sent to the microservice registration center, and the logoff request includes an offline identifier indicating that the database microservice is offline, and the microservice registration center parses out the After going offline, delete the microservice ID and address information of the database microservice.

Optionally, Table 1 and Table 2 are built into the microservice management module and the microservice registration center.

Optionally, Tables 1 and 2 are built in the microservices registration center. After a database microservice is registered in the microservices registration center, the microservices registration center will register the database ID, microservices ID and The address information is sent to the microservice management module, and at the same time, the microservice management module stores the library identifier, microservice identifier, and address information of the received database microservice, so that when the microservice management module receives the data processing request , Can directly obtain the address information of the target database microservice according to the database identifier in the data processing request, without searching the address information of the target database microservice through the microservice registration center.

In the embodiment of the present invention, the sending the data processing request to the target database microservice includes:

Find the address information of the microservice of the target database through the microservice registration center;

According to the address information, send the data processing request to the target database microservice.

When there is no address information stored in the microservice management module, that is, the microservice registration center does not send the address information of the database microservice to the microservice management module. When the microservice management module receives the data processing request, it processes the data The request is parsed to obtain the database identifier, and then the database identifier is sent to the microservice registration center. The microservice registration center searches for the address information of the target database microservice based on the database identifier, and sends the address information of the database microservice found To the microservice management module module, after obtaining the address information of the target database microservice, the microservice management module module sends a data processing request to the target database microservice according to the address information.

Specifically, the data processing method can be applied to the system shown in FIG. 4, the microservice management module obtains a data processing request, the data processing request includes a database identifier, and then, according to the database identifier, through the microservice registration center Find the address information of the target database microservice, and after finding the address information, send the data processing request to the target database microservice according to the address information.

In the above data processing method, a data processing request is first obtained, and the data processing request includes a database identifier; then, based on the database identifier, a target database microservice is determined, and the target database microservice provides a target database corresponding to the data processing request Data processing interface; and finally send the data processing request to the target database microservice to perform the data processing operation corresponding to the data processing request through the data processing interface provided by the target database microservice. It can be seen that, in the above manner, because different databases correspond to different database microservices, database microservices provide data processing interfaces corresponding to the database, so that when performing related operations on the database, it is no longer necessary to understand the operating language of the database, and Directly confirm the corresponding database microservice according to the data processing request and send the request to the microservice, which improves the efficiency of data processing.

It should be noted that when the database completes the data processing operation required in the data processing request, it returns the result information to the client or the microservice management module.

In the embodiment of the present invention, after sending the data processing request to the target database microservice in step 106, the method further includes:

When receiving data processing abnormal information, generate an abnormal data storage request according to the data processing abnormal information;

Sending the abnormal data storage request to an abnormal database to store the data processing abnormal information in the abnormal database.

The data processing exception information is used to indicate that the data processing operation failed to be completed successfully, and is sent to the microservice management module by the database. The data processing exception information may include but is not limited to: client address information, data processing request initiation time , Time-consuming data processing and error description information.

Here, when the database does not complete the data processing operation required in the database processing request, an abnormal data storage request is generated based on the data processing abnormal information, and an abnormal data storage request is sent to the abnormal database to make the abnormal data inventory record data processing abnormal information , Used as an exception information check.

In one embodiment, as shown in FIG. 5, a data processing method is provided. The method includes:

Step 502: Obtain the sending time of the data processing request.

The sending time is the time when the server (that is, the microservice management module in the server) receives the data processing request.

Step 504: Determine the processing sequence number of the data processing request according to the sending time.

Determine the processing sequence number of the data processing request according to the sending time, for example, the processing sequence number of the data processing request received at 10:00:00 is 1, and the processing sequence number of the data processing request received at 10:00:05 is 2. The processing sequence number of the data processing request received at 10:00:20 is 3.

Step 506: When polling the processing sequence number, obtain the data processing request, where the data processing request includes a database identifier, and enter a step of determining a target database microservice according to the database identifier.

If the processing sequence number of a certain data processing request is N, the data processing request needs to be acquired only when the training sequence number N is polled, and then step 508 is entered.

When it needs to be explained, the server can process multiple data processing requests at the same time or only one data processing request at a time.

Step 508: Determine a target database microservice according to the database identifier, and the target database microservice provides a data processing interface of the target database corresponding to the data processing request.

Step 510: Send the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

The above data processing method first obtains the sending time of the data processing request, then determines the processing number of the data processing request according to the sending time, and finally obtains the data processing request when polling the processing number The data processing request includes a database identifier, and the step of determining the target database microservice according to the database identifier is entered. It can be seen that through the above method, when a large number of data requests are obtained in a small period of time, since the data request is processed according to the processing sequence number, the problem of request failure caused by high concurrency is solved to a certain extent. Increased request success rate.

In one embodiment, as shown in FIG. 6, a data processing device 600 is provided. The device 600 includes:

The obtaining module 602 is used to obtain a data processing request, where the data processing request includes a database identifier;

The determining module 604 is configured to determine a target database microservice according to the database identifier, and the target database microservice provides a data processing interface of the target database corresponding to the data processing request;

The sending module 606 is configured to send the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

The above data processing device first obtains a data processing request, and the data processing request includes a database identifier; and then determines a target database microservice according to the database identifier, and the target database microservice provides a target database corresponding to the data processing request Data processing interface; and finally send the data processing request to the target database microservice to perform the data processing operation corresponding to the data processing request through the data processing interface provided by the target database microservice. It can be seen that, in the above manner, because different databases correspond to different database microservices, database microservices provide data processing interfaces corresponding to the database, so that when performing related operations on the database, it is no longer necessary to understand the operating language of the database, and Directly confirm the corresponding database microservice according to the data processing request and send the request to the microservice, which improves the efficiency of data processing.

In one embodiment, the data processing request further includes a function identifier, and the sending module 606 includes:

The function sending module is configured to send the function identifier to the target database microservice, so that the target database microservice performs a data processing operation corresponding to the function identifier through the function interface determined according to the function identifier.

In one embodiment, the sending module 606 includes:

A search module, used to search the address information of the microservice of the target database through the microservice registration center;

The searching and sending module is configured to send the data processing request to the target database microservice according to the address information.

In one embodiment, the device 600 further includes:

A receiving module, configured to receive a microservice registration request through the microservice registration center, where the microservice registration request includes a microservice identifier of the microservice to be registered and address information of the microservice to be registered;

The storage module is configured to correspondingly store the ID of the microservice to be registered and the address information of the microservice to be registered to complete the registration of the microservice to be registered.

In one embodiment, the acquisition module 602 includes:

A time obtaining module, used to obtain the sending time of the data processing request;

A serial number determining module, configured to determine the processing serial number of the data processing request according to the sending time;

The rotation training module is used to obtain the data processing request when polling the processing serial number and enter the step of determining the target database microservice according to the database identification.

In one embodiment, the device 600 further includes:

The abnormal request generating module is configured to generate an abnormal data storage request according to the data processing abnormal information when receiving the data processing abnormal information;

The abnormal request sending module is configured to send the abnormal data storage request to the abnormal database to store the data processing abnormal information in the abnormal database.

7 shows an internal structure diagram of a computer device in an embodiment. The computer device may specifically be a server. As shown in FIG. 7, the computer device includes a processor, a memory, and a network interface connected through a system bus. Among them, the memory includes a non-volatile storage medium and an internal memory. The non-volatile storage medium of the computer device stores an operating system and may also store a computer program. When the computer program is executed by the processor, the processor may cause the processor to implement a data processing method. A computer program may also be stored in the internal memory. When the computer program is executed by the processor, the processor may cause the processor to execute the data processing method. The network interface is used to communicate with the outside. Those skilled in the art may understand that the structure shown in FIG. 7 is only a block diagram of a part of the structure related to the solution of the present application, and does not constitute a limitation on the computer equipment to which the solution of the present application is applied. The specific computer equipment may It includes more or fewer components than shown in the figure, or some components are combined, or have a different component arrangement.

In one embodiment, the data processing method provided by the present application may be implemented in the form of a computer program, and the computer program may run on the computer device shown in FIG. 7. Various program templates constituting the data processing device can be stored in the memory of the computer equipment. For example, the obtaining module 602, the determining module 604, and the sending module 606.

A computer device includes a memory and a processor. The memory stores a computer program. When the computer program is executed by the processor, the processor is caused to perform the following steps:

Obtain a data processing request, which includes a database identifier;

Determine the target database microservice according to the database identifier, the target database microservice provides a data processing interface of the target database corresponding to the data processing request;

Sending the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

The above computer device first obtains a data processing request, the data processing request includes a database identifier; and then determines a target database microservice according to the database identifier, the target database microservice provides a target database corresponding to the data processing request Data processing interface; finally send the data processing request to the target database microservice to perform the data processing operation corresponding to the data processing request through the data processing interface provided by the target database microservice. It can be seen that, in the above manner, because different databases correspond to different database microservices, database microservices provide data processing interfaces corresponding to the database, so that when performing related operations on the database, it is no longer necessary to understand the operating language of the database, and Directly confirm the corresponding database microservice according to the data processing request and send the request to the microservice, which improves the efficiency of data processing.

In one embodiment, the data processing request further includes a function identifier, and sending the data processing request to the target database microservice includes:

Sending the function identifier to the target database microservice, so that the target database microservice performs a data processing operation corresponding to the function identifier through a function interface determined according to the function identifier.

In one embodiment, the sending the data processing request to the target database microservice includes:

Find the address information of the microservice of the target database through the microservice registration center;

According to the address information, send the data processing request to the target database microservice.

In one embodiment, when the above computer program is executed by the processor, it is also used to perform the following steps:

Receiving a microservice registration request through the microservice registration center, where the microservice registration request includes a microservice identifier of the microservice to be registered and address information of the microservice to be registered;

Correspondingly storing the ID of the microservice to be registered and the address information of the microservice to be registered to complete the registration of the microservice to be registered.

In one embodiment, the processing request for acquiring data includes:

Obtaining the sending time of the data processing request;

Determine the processing sequence number of the data processing request according to the sending time;

When the processing sequence number is polled, the data processing request is obtained, and the step of determining the target database microservice according to the database identifier is entered.

In one embodiment, when the above computer program is executed by the processor, it is also used to perform the following steps:

When receiving data processing abnormal information, generate an abnormal data storage request according to the data processing abnormal information;

Sending the abnormal data storage request to an abnormal database to store the data processing abnormal information in the abnormal database.

A computer-readable storage medium stores a computer program, and when the computer program is executed by a processor, the processor is caused to perform the following steps:

Obtain a data processing request, which includes a database identifier;

Determine the target database microservice according to the database identifier, the target database microservice provides a data processing interface of the target database corresponding to the data processing request;

Sending the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice.

The above computer-readable storage medium first obtains a data processing request, and the data processing request includes a database identifier; then, based on the database identifier, a target database microservice is determined, and the target database microservice provides the corresponding The data processing interface of the target database; finally, the data processing request is sent to the target database microservice to perform the data processing operation corresponding to the data processing request through the data processing interface provided by the target database microservice. It can be seen that, in the above manner, because different databases correspond to different database microservices, database microservices provide data processing interfaces corresponding to the database, so that when performing related operations on the database, it is no longer necessary to understand the operating language of the database, and Directly confirm the corresponding database microservice according to the data processing request and send the request to the microservice, which improves the efficiency of data processing.

In one embodiment, the data processing request further includes a function identifier, and sending the data processing request to the target database microservice includes:

Sending the function identifier to the target database microservice, so that the target database microservice performs a data processing operation corresponding to the function identifier through a function interface determined according to the function identifier.

In one embodiment, the sending the data processing request to the target database microservice includes:

Find the address information of the microservice of the target database through the microservice registration center;

According to the address information, send the data processing request to the target database microservice.

In one embodiment, when the above computer program is executed by the processor, it is also used to perform the following steps:

Receiving a microservice registration request through the microservice registration center, where the microservice registration request includes a microservice identifier of the microservice to be registered and address information of the microservice to be registered;

Correspondingly storing the ID of the microservice to be registered and the address information of the microservice to be registered to complete the registration of the microservice to be registered.

In one embodiment, the processing request for acquiring data includes:

Obtaining the sending time of the data processing request;

Determine the processing sequence number of the data processing request according to the sending time;

When the processing sequence number is polled, the data processing request is obtained, and the step of determining the target database microservice according to the database identifier is entered.

In one embodiment, when the above computer program is executed by the processor, it is also used to perform the following steps:

When receiving data processing abnormal information, generate an abnormal data storage request according to the data processing abnormal information;

Sending the abnormal data storage request to an abnormal database to store the data processing abnormal information in the abnormal database.

FIG. 8 is an application environment diagram of a data processing method in an embodiment. Referring to FIG. 8, this data processing method is applied to a data processing system. The data processing system includes a terminal 802 and a server 804. The terminal 802 and the server 804 are connected through a network. The terminal 802 may specifically be a desktop terminal or a mobile terminal, the desktop terminal may specifically be a desktop computer, and the mobile terminal may specifically be at least one of a mobile phone, a tablet computer, a notebook computer, and the like. The server 904 may be implemented by an independent server or a server cluster composed of multiple servers. The terminal 802 is used to send a data processing request to the server 804, and the server 804 is used to obtain a data processing request, the data processing request includes a database identifier; according to the database identifier, a target database microservice is determined, and the target database microservice provides A data processing interface of the target database corresponding to the data processing request; sending the data processing request to the target database microservice to execute the data processing request through the data processing interface provided by the target database microservice Corresponding data processing operations.

It should be noted that the data processing method, data processing apparatus, computer equipment, and computer-readable storage medium described in the embodiments all belong to the same inventive concept. The data processing method, data processing apparatus, computer equipment, and computer-readable storage medium The contents involved in the embodiments are applicable to each other.

Those of ordinary skill in the art can understand that all or part of the process in the method of the above embodiments can be completed by instructing relevant hardware through a computer program, and the program can be stored in a non-volatile computer readable storage In the medium, when the program is executed, it may include the processes of the foregoing method embodiments. Wherein, any reference to the memory, storage, database or other media used in the embodiments provided in this application may include non-volatile and/or volatile memory. Non-volatile memory may include read-only memory (ROM), programmable ROM (PROM), electrically programmable ROM (EPROM), electrically erasable programmable ROM (EEPROM), or flash memory. Volatile memory can include random access memory (RAM) or external cache memory. By way of illustration and not limitation, RAM is available in many forms, such as static RAM (SRAM), dynamic RAM (DRAM), synchronous DRAM (SDRAM), double data rate SDRAM (DDRSDRAM), enhanced SDRAM (ESDRAM), synchronous chain Road (Synchlink) DRAM (SLDRAM), memory bus (Rambus) direct RAM (RDRAM), direct memory bus dynamic RAM (DRDRAM), and memory bus dynamic RAM (RDRAM), etc.

The technical features of the above embodiments can be arbitrarily combined. In order to simplify the description, all possible combinations of the technical features in the above embodiments are not described. However, as long as there is no contradiction in the combination of these technical features, they should be It is considered as the scope described in this specification.

The above-mentioned embodiment only expresses several implementation manners of the present application, and its description is more specific and detailed, but it cannot be understood as a limitation of the patent scope of the present application. It should be noted that, for those of ordinary skill in the art, without departing from the concept of the present application, a number of modifications and improvements can also be made, which all fall within the protection scope of the present application. Therefore, the protection scope of the patent of this application shall be subject to the appended claims.

Claims (10)

A data processing method, characterized in that the method includes: Obtain a data processing request, which includes a database identifier; Determine the target database microservice according to the database identifier, the target database microservice provides a data processing interface of the target database corresponding to the data processing request; Sending the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice. The method of claim 1, wherein the data processing request further includes a function identifier, and the sending the data processing request to the target database microservice includes: Sending the function identifier to the target database microservice, so that the target database microservice performs a data processing operation corresponding to the function identifier through a function interface determined according to the function identifier. The method of claim 1, wherein the sending the data processing request to the target database microservice includes: Find the address information of the microservice of the target database through the microservice registration center; According to the address information, send the data processing request to the target database microservice. The method according to claim 3, characterized in that, before the data processing request is obtained, the method further comprises: Receiving a microservice registration request through the microservice registration center, where the microservice registration request includes a microservice identifier of the microservice to be registered and address information of the microservice to be registered; Correspondingly storing the ID of the microservice to be registered and the address information of the microservice to be registered to complete the registration of the microservice to be registered. The method of claim 1, wherein the processing request for acquiring data comprises: Obtaining the sending time of the data processing request; Determine the processing sequence number of the data processing request according to the sending time; When the processing sequence number is polled, the data processing request is obtained, and the step of determining the target database microservice according to the database identifier is entered. The method according to any one of claims 1 to 5, wherein after the sending the data processing request to the target database microservice, the method further comprises: When receiving data processing abnormal information, generate an abnormal data storage request according to the data processing abnormal information; Sending the abnormal data storage request to an abnormal database to store the data processing abnormal information in the abnormal database. A data processing device, characterized in that the device includes: An acquisition module, for acquiring a data processing request, the data processing request including a database identifier; A determining module, configured to determine a target database microservice according to the database identifier, and the target database microservice provides a data processing interface of the target database corresponding to the data processing request; The sending module is configured to send the data processing request to the target database microservice to perform a data processing operation corresponding to the data processing request through a data processing interface provided by the target database microservice. The apparatus according to claim 7, wherein the data processing request further includes a function identifier, and the sending module includes: The function sending module is configured to send the function identifier to the target database microservice, so that the target database microservice performs a data processing operation corresponding to the function identifier through the function interface determined according to the function identifier. A computer device comprising a memory and a processor, the memory storing a computer program, when the computer program is executed by the processor, the processor is caused to perform the method according to any one of claims 1 to 6. A step of. A computer-readable storage medium storing a computer program, which when executed by a processor, causes the processor to perform the steps of the method according to any one of claims 1 to 6.