Data processing method and data processing device

1. A data processing method, applied in a data center, comprising:

obtaining stored procedures of a development environment, a data quality assurance system environment and a production environment and column information of all tables from the data center;

for each stored procedure, analyzing the stored procedure and determining whether the stored procedure contains a wildcard;

for each stored procedure, converting and restoring the stored procedure into a restored stored procedure with complete column information based on the wildcard;

generating column lineage graphs of the development environment, the data quality assurance system environment and the production environment respectively according to the restored stored procedures of the development environment, the data quality assurance system environment and the production environment, comprising:

parsing each restored stored procedure to determine directed graphs of all columns of the restored stored procedure for each environment of the development environment, the data quality assurance system environment and the production environment; and

merging directed graphs of columns of all restored stored procedures in each environment to generate a column lineage graph for each environment; and

comparing the column lineage graphs of the development environment, the data quality assurance system environment and the production environment to generate a comparison result and performing a notification function according to the comparison result.

2. The data processing method of claim 1 , wherein the step of for each stored procedure converting and restoring the stored procedure into the restored stored procedure with complete column information based on the wildcard comprises:

analyzing contextual information of the wildcard in the stored procedure to determine whether the wildcard is included in a selection query statement;

when determining that the wildcard is in the selection query statement, determining a specified table to be queried in the selection query statement, wherein the selection query statement comprises a first clause and a second clause, the second clause is after the first clause, and the wildcard is in the first clause of the selection query statement, wherein the step comprises determining the specified table to be queried from the second clause of the selection query statement;

comparing the specified table with the obtained column information of all tables to determine all column information corresponding to the specified table; and

replacing the wildcard in the stored procedure with all column information corresponding to the specified table to generate the restored stored procedure with complete column information.

3. The data processing method of claim 1 , wherein the step of for each stored procedure, converting and restoring the stored procedure into the restored stored procedure with complete column information based on the wildcard comprises:

for each stored procedure, when determining that the stored procedure does not contain any wildcard, the stored procedure is outputted as the restored stored procedure.

4. The data processing method of claim 1 , wherein the step of merging the directed graphs of the columns of all restored stored procedures in each environment to generate the column lineage graph for each environment comprises:

when determining that a source column of a first restored stored procedure and a target column of a second restored stored procedure are the same column, merging a first node representing the source column of the first restored stored procedure and a second node representing the target column of the second restored stored procedure.

5. The data processing method of claim 1 , wherein the step of comparing the column lineage graphs of the development environment, the data quality assurance system environment and the production environment to generate the comparison result and performing the notification function according to the comparison result comprises:

comparing the column lineage graphs of at least two environments, source directed subgraphs or target directed subgraphs corresponding to at least one column of the column lineage graphs of at least two environments among the development environment, the data quality assurance system environment and the production environment to generate the comparison result; and

when the comparison result indicates that there is a difference between the column lineage graphs of two of the development environment, the data quality assurance system environment and the production environment, generating and sending a notification signal to execute the notification function.

6. A data processing device, applied in a data center, comprising:

a storage device, configured to store instructions;

a processor circuit, configured to execute the instructions of:

obtaining stored procedures of a development environment, a data quality assurance system environment and a production environment and column information of all tables from the data center;

for each stored procedure, analyzing the stored procedure and determining whether the stored procedure contains a wildcard;

for each stored procedure, converting and restoring the stored procedure into a restored stored procedure with complete column information based on the wildcard;

generating column lineage graphs of the development environment, the data quality assurance system environment and the production environment respectively according to the restored stored procedures of the development environment, the data quality assurance system environment and the production environment, comprising:

parsing each restored stored procedure to determine directed graphs of all columns of the restored stored procedure for each environment of the development environment, the data quality assurance system environment and the production environment; and

merging directed graphs of columns of all restored stored procedures in each environment to generate a column lineage graph for each environment; and

comparing the column lineage graphs of the development environment, the data quality assurance system environment and the production environment to generate a comparison result and performing a notification function according to the comparison result.

7. The data processing device of claim 6 , wherein the instructions further comprise:

analyzing contextual information of the wildcard in the stored procedure to determine whether the wildcard is included in a selection query statement;

when determining that the wildcard is in the selection query statement, determining a specified table to be queried in the selection query statement, wherein the selection query statement comprises a first clause and a second clause, the second clause is after the first clause, and the wildcard is in the first clause of the selection query statement, wherein the step comprises determining the specified table to be queried from the second clause of the selection query statement;

comparing the specified table with the obtained column information of all tables to determine all column information corresponding to the specified table; and

replacing the wildcard in the stored procedure with all column information corresponding to the specified table to generate the restored stored procedure with complete column information.

8. The data processing device of claim 6 , wherein the instructions further comprise:

for each stored procedure, when determining that the stored procedure does not contain any wildcard, the stored procedure is outputted as the restored stored procedure.

9. The data processing device of claim 6 , wherein the instructions further comprise:

when determining that a source column of a first restored stored procedure and a target column of a second restored stored procedure are the same column, merging a first node representing the source column of the first restored stored procedure and a second node representing the target column of the second restored stored procedure.

10. The data processing device of claim 6 , wherein the instructions further comprise:

comparing the column lineage graphs of at least two environments, source directed subgraphs or target directed subgraphs corresponding to at least one column of the column lineage graphs of at least two environments among the development environment, the data quality assurance system environment and the production environment to generate the comparison result; and

when the comparison result indicates that there is a difference between the column lineage graphs of two of the development environment, the data quality assurance system environment and the production environment, generating and sending a notification signal to execute the notification function.