数据质量稽核详细设计说明书

1、中国移动通信山西数据质量稽核功能规格说明书本文档及其所含信息为材料并且由中国移动通信山西和天睿信科技术（）共同拥有。文档中中国移动通信山西和天睿信科技术（），不得给第，也不得以任何、进行与文档信息文档变更历史文档签收签字：公司公司项目签收日期日期变更描述批准编者:公司项目日期版本 1.0天睿信科2015-6-26审核:公司项目日期版本 1.0天睿信科2015-7-2批准:公司项目日期版本 1.0用户名称中国移动通信山西项目名称数据质量稽核文档名称数据质量稽核_功能规格说明书版 本 号1.1发布日期2015 年 7 月 2 日目录1引言4编写目的4背景4参考资料4总体设计4简述4架构设计5功能架

2、构图5技术架构图5接口设计6系统接口设计6模块设计63总体框架6子模块说明6调用关系7子模块设计8主体程序模块8程序模块93.2.2稽核程序模块13通用程序模块18告警程序模块20数据库设计23逻辑结构设计23数据结果域23规则配置域25中间数据域26管理域281 引言1.1 编写目的本文档是为了说明说明数据质量稽核系统的体系架构，以及需求用例的各个功能点在架构中的体现，功能开发的逻辑处理顺序，为程序开发提供参考。1.2 背景系统的名称：数据质量稽核系统开发工具：JAV开发者：RL1.3参考资料数据质量稽核系统需求规格说明书2 总体设计2.1 简述系统采用流行的 B/S 结构模式。系统的分析设

3、计采用面象的技术，应用 Visio 等工具进行辅助设计。2.2 架构设计2.2.1功能架构图2.2.2技术架构图2.3 接口设计2.3.1系统接口设计3模块设计3.1 总体框架3.1.1 子模块说明程序包括：主体程序、程序、稽核程序、通用程序、告警程序。主体程序模块：程序总体管理者，负责其他程序的调度和启停。程序模块：实现作业运行信息与指标信息和入库。稽核程序模块：实现指标及时性、准确性校验和入库。通用程序模块：实现公用模块封装，为其他模块提供接口，暂要求实现数据库 API 封装 。告警程序模块：实现从告警的发送和告警的升级。3.1.2 调用关系3.2 子模块设计3.2.1 主体程序模块主体程

4、序模块主要实现对各子模块根据要求安排调度顺序，程序启动后需要守候执行，并根据设定的时间间隔循环执行。输入输出参考代码#!/usr/bin/perl # 程序名称：主体程序# 程序目标: 开启守护进程，按循环周期对各子模块实行调用# 程序描述:# 参数说明:# 开发：、高建新# 开发时间：# 修改：# 修改时间：# 其他说明：#use DBI; use DBI;use Time:localtime; use Data:Dumper; use Time:Local; use threads;#调用其他模块 use模块; use 稽核模块;#调度开始 while (1=1)$rs=模块:作业函数;

5、#创建两个子线程子线程 1：$rs1=模块:指标函数;子线程 2：$rs2=稽核模块:作业稽核函数;#循环判定子线程执行结果,直到子线程都返回结果时，则继续执行；否则休息 15 秒重新检查。子程序输入输出调用条件无无无系统初次使用、系统重启3.2.2程序模块程序模块包括作业运行信息与指标信息，被主体程序模块调用输入输出参考代码#!/usr/bin/perl # 程序名称：# 程序目标: 根据作业配置信息，从云 ETL 系统中抽取作业运行信息并入库;从 ASTER 或TD 库抽取指标信息并入库# 程序描述: 1.作业配置信息 2.连接云 ETL 库 3.取作业信息入库；1.指标配置信息 2.连接

6、ASTER/TD 库 指标值入库# 参数说明:# 开发：、高建新# 开发时间：# 修改：# 修改时间：# 其他说明：Perl DBI 编程，前提是本地机器上已经安装了 DBI 模块和 DBD:Pg 模块。注Perl模块的安装 1.$cpan 2.$install DBI 3.$install DBD:Pg#use DBI;my $HOME = $ENVHOME;子程序输入输出调用条件作业函数无运行标示主程序启动，且满足10 分钟调用条件指标函数无运行标示主程序收到作业 函数返回值后调用while ($rs1 未成功 OR $rs2 未成功) sleep(15)#回收子进程两个子线程 threa

7、d-join(子线程 1);thread-join(子线程 2); #指标稽核$rs=稽核模块:作业稽核函数;#程序休眠 10 分钟sleep(600)use DBI;use Time:localtime; use Data:Dumper; use Time:Local; use Net:FTP;#数据库配置 my $driver=Pg;#配置库服务器参数my $host=.; my $database=tgres;my $port =X;#云 ETL 库服务器参数my $etlhost=.; my $etldatabase=tgres;my $etlport =X; #TD 库服务器参数my

8、 $etlhost=.; my $etldatabase=teradata;my $etlport =X; #ASTER 库服务器参数my $etlhost=.; my $etldatabase=aster;my $etlport =X;#用户名my $user=username; my $passwd=password; #云 ETL 库用户名my $etluser=username; my $etlpasswd=password; #TD 库用户名my $tdetluser=username; my $tdetlpasswd=password; #ASTER 库用户名my $asteret

9、luser=username; my $asteretlpasswd=password;sub 作业函数 #1.获得数据质量数据库句柄my $dbh = DBI-connect(dbi:$driver:dbname=$database;host=$host;port=$port, $user,$passwd, RaiseError = 1,mit = 0 ) or die $DBI:errstr;#2.查询配置信息 SQLmy $tqsql = SELECT 作业名称FROM 配置表 A INNER JOIN结果表 BON A.作业编码=B.作业编码 AND B.作业状态成功 ;my $rsi

10、te = $npmdb_dbh-prepare($sel_sql);$rsite-execute();my $ref_data = $rsite-fetchall_arrayref(); #结果的数组$rsite-finish;#3.拼接云 ETL 查询条件my $cond_str=;foreay $row ($ref_data) my data = $row;$cond_str=$cond_str+,$data0;#4.获得云 ETL 数据库句柄my $dbh2 = 云 ETL 数据库句柄#5.执行作业运行信息查询 SQLmy $yetlsql = SELECT 数据周期，作业名称，作业编码

11、，开始时间，结束时间，作业状态FROM 云ETL 日志表WHERE 处理日期=当日AND作业编码 IN ($cond_str);my $yetlrs = $npmdb_dbh-prepare($sel_sql);$yetlrs-execute();my $etl_data = $yetlrs-fetchall_arrayref(); #结果的数组$yetlrs-finish;#6.清空作业结果表my $DELSQL =DELETE FROM结果表;$rv = $dbh-do($DELSQL)or die Cant execute $s ement: $dbh- errstr/n;#7.将新数据

12、作业结果表和作业历史结果表foreay $row ($etl_data) my data = $row;my $INSTSQL1 =INSERTO结果表 VALUES (作业名称，数据周期，作业名称，作业编码，开始时间，结束时间，作业状态，当前时间);my $INSTSQL2 =INSERTO结果历史表 VALUES (作业名称，数据周期，作业名称，作业编码，开始时间，结束时间，作业状态，当前时间);my $rv=$dbh-do($INSTSQL1); my $rv=$dbh-do($INSTSQL2);#9.数据库句柄$rc = $dbh-disconnect;$rc = $dbh2-dis

13、connect;sub 指标函数 #1.获得数据质量数据库句柄my $dbh = DBI-connect(dbi:$driver:dbname=$database;host=$host;port=$port, $user,$passwd, RaiseError = 1,mit = 0 ) or die $DBI:errstr; #2.获得 ASTER 数据库句柄my $dbh2 = ASTER 句柄 #3.获得 TD 数据库句柄 my $dbh3 = TD 句柄#4.查询配置信息 SQLmy $tqsql = SELECT 库名,指标名,指标提取语句FROM 配置表 A INNER JOIN结

14、果表 BON A.作业编码=B.作业编码 AND B.作业 状态=成功 ;my $rsite = $npmdb_dbh-prepare($sel_sql);$rsite-execute();my $ref_data = $rsite-fetchall_arrayref(); #结果的数组$rsite-finish;#5.循环执行指标foreay $row ($ref_data)my $cond_str=目标表+指标提取语句+条件; if(数据库名=ASTER)$rv = $dbh2-do($cond_str) or die Cant execute $cond_str: $dbh- errst

15、r/n;else3.2.3 稽核程序模块稽核程序模块包括作业稽核与指标稽核，被主体程序模块调用。输入输出参考代码#!/usr/bin/perl # 程序名称：稽核# 程序目标: 根据作业信息和作业稽核配置信息对作业运行情况稽核;根据指标信息和稽核指标配置信息对指标稽核# 程序描述:# 参数说明:# 开发：、高建新# 开发时间：# 修改：# 修改时间：# 其他说明：Perl DBI 编程，前提是本地机器上已经安装了 DBI 模块和 DBD:Pg 模块。注Perl模块的安装 1.$cpan 2.$install DBI 3.$install DBD:Pg #use DBI;my $HOME = $

16、ENVHOME;use DBI;use Time:localtime; use Data:Dumper; use Time:Local; use Net:FTP;#数据库配置 my $driver=Pg;#配置库服务器参数子程序输入输出调用条件作业稽核函数无运行标示主程序启动，且满足10 分钟调用条件指标稽核函数无运行标示主程序收到作业 函数返回值后调用$rv = $dbh3-do($cond_str) or die Cant execute $cond_str: $dbh- errstr/n;return $rv;my $host=.; my $database= tgres;my $por

17、t =X;#云 ETL 库服务器参数my $etlhost=.; my $etldatabase= tgres;my $etlport =X; #TD 库服务器参数my $etlhost=.; my $etldatabase=teradata;my $etlport =X; #ASTER 库服务器参数my $etlhost=.; my $etldatabase=aster;my $etlport =X;#用户名my $user=username; my $passwd=password; #云 ETL 库用户名my $etluser=username; my $etlpasswd=passwo

18、rd; #TD 库用户名my $tdetluser=username; my $tdetlpasswd=password; #ASTER 库用户名my $asteretluser=username; my $asteretlpasswd=password;sub 作业稽核函数 #1.获得数据质量数据库句柄my $dbh = DBI-connect(dbi:$driver:dbname=$database;host=$host;port=$port, $user,$passwd, RaiseError = 1,mit = 0 ) or die $DBI:errstr;#2.查出结果表中所有作业m

19、y $tqsql = SELECT 数据周期,作业名称,上限运行时长,最后完成时间,作业名称,数据周期,作业名称,作业编码,开始时间,CASE WHEN 结束时间 IS NULL THEN 当前时间 END,作业状态,当前时间,CASE WHEN 结束时间 IS NULL THEN 当前时间-开始时间 ELSE 结束时间-开始时间 END AS 运行时长,FROM 配置表 A INNER JOIN结果表 BON A.作业编码=B.作业编码 ;my $rsite = $npmdb_dbh-prepare($sel_sql);$rsite-execute();my $ref_data = $rsi

20、te-fetchall_arrayref(); #结果的数组$rsite-finish;#3.循环执行作业稽核foreay $row ($ref_data)my $result=1 #初始化稽核结果通过 my $resut_desc=; #结果描述my rs_array#盛放结果数据数组 my data = $row;#3.1 作业稽核判断if (作业状态=失败) push rs_array,作业运行失败; #结果数组rs_array 中元素作业运行失败if (运行时长=上限运行时长) push rs_array,运行时间超长; #结果数组rs_array 中元素运行时间超长if (完成时间0

21、,则作业稽核不通过，通过数组循环拼接未通过原因；如果数组元素=0，则作业稽核通过if(rs_array0) $result=0; #作业稽核不通过 foreach $i (rs_array) $resut_desc=$resut_desc+$i;#拼接稽核未通过原因else $result=1; #作业稽核不通过$resut_desc=作业稽核成功;#3.3稽核结果：作业稽核结果表中删除本数据周期的，本，同时将到作业稽核结果历史表$job_delete=delete from 作业稽核结果表 WHERE 数据周期为本次稽核周期 AND 作业名称为该作业;$job_insert1=inserto

22、 作业稽核结果表 values ($data0,$data1,$datan,$result,$resut_desc);$job_insert2=inserto 作业稽核历史表结果表 values ($data0,$data1,$datan,$result,$resut_desc);$rv=$dbh-do(job_result) or die Cant execute $cond_str: $dbh- errstr/n;$rv=$dbh-do(job_insert1) or die Cant execute $cond_str: $dbh- errstr/n;$rv=$dbh-do(job_in

23、sert2) or die Cant execute $cond_str: $dbh- errstr/n;return 完成标示; #4.数据库句柄$rc = $dbh-disconnect;sub 指标函数 #1.获得数据质量数据库句柄my $dbh = DBI-connect(dbi:$driver:dbname=$database;host=$host;port=$port, $user,$passwd, RaiseError = 1,mit = 0 ) or die $DBI:errstr;#2.查询配置信息 SQLmy $tqsql1 = 已生成尚未稽核的指标及平衡性规则、规则类型、

24、日环比、月环比 SQL、指标值;my $rsite = $dbh-prepare($tqsql1);$rsite-execute();my $ref_data = $rsite-fetchall_arrayref(); #结果的数组$rsite-finish;#3.循环执行指标稽核foreay $row ($ref_data)my $result=1 #初始化稽核结果通过 my $resut_desc=; #结果描述my rs_array#盛放结果数据数组 my data = $row;#3.1 指标波动性稽核if (稽核类型=月环比)if(月环比值上限值) push rs_array,月环比

25、值超过上限; #结果数组rs_array 中元素月环比值超过上限if(月环比值上限值) push rs_array,月环比值超过上限; #结果数组rs_array 中元素月环比值超过上限if(日环比值prepare($balance);$bal_rs-execute();my $ref_bal = $bal_rs-fetchall_arrayref(); #结果的数组$bal_rs-finish;#3.2.2 循环执行当前指标的平衡性稽核foreay $i ($ref_bal) balarray=$i;if($balarray稽核指标值+$balarray操作符+$balarray对比指标值)

26、 push rs_array,$balarray操作符+$balarray对比指标名平衡性不满足; #结果数组rs_array 中元素例如数据用户数平衡性不满足#3.3 原因描述生成： 如果数组元素0,则指标稽核不通过，通过数组循环拼接未通过原因；如果数组元素=0，则指标稽核通过if(rs_array0) $result=0; #指标稽核不通过 foreach $i (rs_array) $resut_desc=$resut_desc+$i;#拼接稽核未通过原因else 3.2.4 通用程序模块通用程序模块封装了程序中通用的函数功能，当前程序封装了数据库连接 API，被其他程序模块调用。输入输

27、出参考代码#!/usr/bin/perl # 程序名称：通用功能# 程序目标: 提供系统通用功能封装，包括数据库连接KPI # 程序描述:# 参数说明:# 开发：、高建新# 开发时间：# 修改：# 修改时间：# 其他说明：子程序输入输出调用条件连接数据库数据库名数据库连接句柄无断开数据库数据库句柄数据库断开连接返回值无$result=1; #指标稽核不通过$resut_desc=指标稽核成功;#3.4稽核结果：指标稽核结果表中删除本数据周期的，本，同时将到指标稽核结果历史表$job_delete=delete from 指标稽核结果表 WHERE 数据周期为本次稽核周期 AND 指标编码为该指

28、标;$job_insert1=inserto 指标稽核结果表 values ($data0,$data1,$datan,$result,$resut_desc);$job_insert2=inserto 指标稽核历史表结果表 values ($data0,$data1,$datan,$result,$resut_desc);$rv=$dbh-do(job_result) or die Cant execute $cond_str: $dbh- errstr/n;$rv=$dbh-do(job_insert1) or die Cant execute $cond_str: $dbh- errst

29、r/n;$rv=$dbh-do(job_insert2) or die Cant execute $cond_str: $dbh- errstr/n;return 完成标志;#4数据库句柄$rc = $dbh-disconnect;#use DBI;my $HOME = $ENVHOME;use DBI;use Time:localtime; use Data:Dumper; use Time:Local; use Net:FTP;#数据库配置 my $driver=Pg;#配置库服务器参数my $host=.; my $database=tgres;my $port =X;#云 ETL 库服

30、务器参数my $etlhost=.; my $etldatabase=tgres;my $etlport =X; #TD 库服务器参数my $etlhost=.; my $etldatabase=teradata;my $etlport =X; #ASTER 库服务器参数my $etlhost=.; my $etldatabase=aster;my $etlport =X;#用户名my $user=username; my $passwd=password; #云 ETL 库用户名my $etluser=username; my $etlpasswd=password; #TD 库用户名my

31、$tdetluser=username; my $tdetlpasswd=password; #ASTER 库用户名my $asteretluser=username; my $asteretlpasswd=password;sub 连接数据库() my $db_type=$_0; my $dbh;3.2.5 告警程序模块通用程序模块封装了作业告警及指标告警，被其他主程序模块调用。其中作业告警可实现针对已告警的作业在制定时间内不再发送告警。输入输出参考代码#!/usr/bin/perl # 程序名称：告警# 程序目标: 提供告警功能# 程序描述:# 参数说明:# 开发：、高建新# 开发时间：#

32、 修改：# 修改时间：# 其他说明：Perl DBI 编程，前提是本地机器上已经安装了 DBI 模块和 DBD:Pg 模块。注Perl 模块的安装 1.$cpan 2.$install DBI 3.$install DBD:Pg子程序输入输出调用条件作业告警无执行结果无指标告警无执行结果无#1.判断参数范围，返回提示信息,满足条件则执行下一步 #2.判断连接数据库if($db_type=1)$dbh = 数据质量库连接;elif($db_type=2)$dbh = 云 ETL 库连接;elif($db_type=3)$dbh = TD 库连接;elif($db_type=4)$dbh = AS

33、TER 库连接;return $dbh;sub 断开数据库() my $dbh=$_0;$rc = $dbh-disconnect; return $rc;#use DBI;my $HOME = $ENVHOME;use DBI;use Time:localtime; use Data:Dumper; use Time:Local; use Net:FTP;#1.获得数据库句柄my $dbh=数据质量库句柄my $alarm_dbh=告警质量库句柄#2.警语提取语句#2.1 提取作业告警内容my $job_sql=select A.作业名称,A.作业编码, A.结果描述, A.执行周期,C.号

34、码from 作业执行结果查询 A left join作业配置表 BON A.作业编码=B.作业编码 LEFT JOIN告警配置表 C ON B.告警=C.告警WHERE A.稽核结果=失败;#2.2 提取指标告警内容my $index_sql=select A.指标名称,A.作业名称, A.结果描述, A.执行周期,C.号码from 指标执行结果查询 A left join指标作业对应关系 BON A.指标编码=B.指标编码 left join作业配置表 CON B.作业编码=C.作业编码 LEFT JOIN告警配置表 DON C.告警=D.告警 WHERE A.稽核结果=失败#作业告警sub

35、 作业告警 my $yetlrs = $dbh-prepare($job_sql);$yetlrs-execute();my $etl_data = $yetlrs-fetchall_arrayref(); #结果的数组$yetlrs-finish;foreay $row ($etl_data) my data = $row;#判断该次作业是否在指定时间内已告警一次 #1.查询该做也在制定时间间隔内次数my $sql=select count(*) from 告警表 where时间(当前时间-指定时间间隔) my $cnt=结果;#2.判定结果结果是否大于 0，如果大于 0 则不;否则需要 i

36、f($cnt0) my $index_alarm= INSERTO 告警表 VALUES号、告警内容; my $rv=$alarm_dbh-do($index_alarm);#指标告警sub 指标告警 my $yetlrs = $dbh-prepare($index_sql);$yetlrs-execute();my $etl_data = $yetlrs-fetchall_arrayref(); #结果的数组$yetlrs-finish;foreay $row ($etl_data) my data = $row;my $index_alarm= INSERTO 告警表 VALUES号、告警

37、内容; my $rv=$alarm_dbh-do($index_alarm);4 数据库设计4.1 逻辑结构设计4.1.1数据结果域作业稽核结果表指标稽核结果表列名数据类型是否主键 是否自增 是否为空 约束注释DEAL_DATEEGER否否无稽核日期INDEX_CODEVARCHAR(32)否否无指标编码INDEX_DESCVARCHAR(64)否否无指标名称INDEX_VALUEFLOAT否否无指标值INDEX_CYCLECHAR(2)否否无指标周期GATHER_TIMETIMEST否否无时间GATHER_SUSCHAR(4)否否无状态CHECK_TIMETIMEST否否无稽核时间CHECK

38、_RESULTCHAR(4)否否无稽核结果表名注释指标稽核结果表分布键JOB_CODE索引PHONE_NO说明1.归属系统指的是归属于 ASTER 还是 TERADATA列名数据类型是否主键 是否自增 是否为空 约束注释DEAL_DATE否否无执行日期JOB_CODEVARCHAR(32)否否无作业编码JOB_DESCVARCHAR(64)否否无作业名称BELNG_SYSVARCHAR(12)否否无归属系统JOB_CYCLECHAR(2)否否无作业周期BEGIN_TIMETIMEST否否无开始时间FINISH_TIMETIMEST否否无完成时间EXEC_DUREGER否否无执行时长EXEC_S

39、USCHAR(4)否否无执行状态EXEC_RESULTCHAR(4)否否无稽核结果JOB_RULE_DESCVARCHAR(256)否否无稽核规则RESULT_DESCVARCHAR(256)否否无结果描述表名注释作业稽核结果查询指标稽核历史结果表指标稽核历史结果表列名数据类型是否主键 是否自增是否为空约束注释DEAL_DATEEGER否否无执行日期JOB_CODEVARCHAR(32)否否无作业编码JOB_DESCVARCHAR(64)否否无作业名称BELNG_SYSVARCHAR(12)否否无归属系统JOB_CYCLECHAR(2)否否无作业周期BEGIN_TIMETIMEST否否无开始时

40、间FINISH_TIMETIMEST否否无完成时间EXEC_DUREGER否否无执行时长EXEC_SUSCHAR(4)否否无执行状态EXEC_RESULTCHAR(4)否否无稽核结果表名注释指标稽核历史结果表列名数据类型是否主键是否自增是否为空约束注释DEAL_DATEEGER否否无稽核日期INDEX_CODEVARCHAR(32)否否无指标编码INDEX_DESCVARCHAR(64)否否无指标名称INDEX_VALUEFLOAT否否无指标值INDEX_CYCLECHAR(2)否否无指标周期GATHER_TIMETIMEST否否无时间GATHER_SUSCHAR(4)否否无状态CHECK_T

41、IMETIMEST否否无稽核时间CHECK_RESULTCHAR(4)否否无稽核结果WAVE_VALUEFLOAT否否无波动性BALANCE_VALUEFLOAT否否无平衡性INDEX_RULE_DESCVARCHAR(256)否否无稽核规则RESULT_DESCVARCHAR(256)否否无结果描述INSERT_TIMETIMEST否否无时间表名注释指标稽核历史结果表分布键JOB_CODE索引JOB_CODE说明1.归属系统指的是归属于 ASTER 还是 TERADATAWAVE_VALUEFLOAT否否无波动性BALANCE_VALUEFLOAT否否无平衡性INDEX_RULE_DESCV

42、ARCHAR(256)否否无稽核规则RESULT_DESCVARCHAR(256)否否无结果描述4.1.2规则配置域作业执行稽核配置主表作业指标对应关系码表分布键JOB_ID索引JOB_ID说明约列名数据类型是否主键是否自增是否为空束注释JOB_IDVARCHAR(32)否否无作业 IDINDEX_CODEVARCHAR(64)否否无指标编码INDEX_VALUEFLOAT否否无更新时间INDEX_CYCLECHAR(2)否否无更新人表名注释作业指标对应关系码表分布键JOB_CODE索引JOB_CODE说明1.归属系统指的是归属于 ASTER 还是 TERADATA列名数据类型是否主键 是否自

43、增 是否为空 约束 注释JOB_IDVARCHAR(32)否否无作业 IDJOB_CODEVARCHAR(32)否否无作业名称JOB_DESCVARCHAR(32)否否无作业描述JOB_DESCVARCHAR(64)否否无作业归属系统BELNG_SYSVARCHAR(12)否否无作业归属库JOB_CYCLECHAR(2)否否无作业周期BEGIN_TIMEEGER否否无运行上限时间FINISH_TIMEVARCHAR(64)否否无超时时间点EXEC_DUREGER否否无名称EXEC_SUSCHAR(4)否否无IDUPDATE_TIMETIMEST否否无更新时间UPDATERVARCHAR(32)

44、否否无更新人表名注释作业执行稽核配置主表JOB_RULE_DESCVARCHAR(256)否否无稽核规则RESULT_DESCVARCHAR(256)否否无结果描述INSERT_TIMETIMEST否否无时间指标码表指标稽核规则配置表4.1.3中间数据域标准化指标依赖关系表列名数据类型是否主键是否自增是否为空约束注释表名注释标准化指标依赖关系表分布键ITEM_CODE索引ITEM_CODE说明列名数据类型是否主键是否自增是否为空约束 注释INDEX_CODEVARCHAR(32)否否无指标编码RULE_DESCVARCHAR(128)规则描述RULE_TYPECHAR(2)规则类型RULE_V

45、ALUE1VARCHAR(32)规则值 1RULE_VALUE2VARCHAR(32)规则值 2表名注释指标稽核规则配置表分布键ITEM_CODE索引ITEM_CODE说明表名注释指标码表列名数据类型是否主键是否自增 是否为空 约束注释INDEX_CODEVARCHAR(32)否否无指标编码INDEX_NAMEVARCHAR(64)否否无指标名称INDEX_DESCVARCHAR(256)否否无指标定义EXTRA_SQLVARCHAR(512)否否无提取 SQLRULE_DESCVARCHAR(256)否否无稽核规则描述WAVE_RULEVARCHAR(128)否否无波动性稽核规则BALANC

46、E_RULEVARCHAR(128)否否无平衡性稽核规则UPDATE_TIMETIMEST否否无更新时间UPDATERVARCHAR(32)否否无更新人标准化指标依赖关系表指标稽核结果列名数据类型是否主键是否自增是否为空约束 注释DEAL_DATEEGER否否无稽核日期INDEX_CODEVARCHAR(32)否否无指标编码INDEX_DESCVARCHAR(64)否否无指标名称INDEX_VALUEFLOAT否否无指标值INDEX_CYCLECHAR(2)否否无指标周期GATHER_TIMETIMEST否否无时间表名注释指标稽核结果列名数据类型是否主键是否自增是否为空约束 注释DEAL_DA

47、TE否否无执行日期JOB_CODEVARCHAR(32)否否无作业编码JOB_DESCVARCHAR(64)否否无作业名称BELNG_SYSVARCHAR(12)否否无归属系统JOB_CYCLECHAR(2)否否无作业周期BEGIN_TIMETIMEST否否无开始时间FINISH_TIMETIMEST否否无完成时间EXEC_DUREGER否否无执行时长EXEC_SUSCHAR(4)否否无执行状态INSERT_TIMETIMEST否否无时间表名注释作业结果表分布键INDEX_CODE索引INDEX_CODE说明本表来源于配置表中指标关系、指标作业对应关系。方便前端查关系组织结构方便针对目标指标告

48、警：某个节点或者作业报错，直接能查出他影响的最终标准化指标及上层作业_INDEXVARCHAR(32)否否无体系目标指标LEVEL_IDCHAR(2)否否无体系级别INDEX_NAMEVARCHAR(32)否否无指标名称JOB_CODEVARCHAR(32)否否无本层作业INDEX_CODEVARCHAR(32)否否无指标编码PAR_INDEXVARCHAR(32)否否无父级指标编码PAR_JOBVARCHAR(32)否否无父级指标所在作业作业结果历史表4.1.4管理域告警表分布键USER_ID索引USER_ID说明注释注释告警表列名数据类型是否主键 是否自增 是否为空 约束注释USER_ID

49、VARCHAR(32)否否无用户账号USER_NAMEVARCHAR(32)否否无用户DEPT_NOVARCHAR(32)否否无归属部门编码DEPT_NAMEVARCHAR(32)否否无归属部门名称ROLE_NOVARCHAR(32)否否无角色PHONE_NOVARCHAR(32)否否无号码UPDATE_TIMETIMEST否否无更新时间UPDATORVARCHAR(32)否否无更新列名数据类型是否主键是否自增是否为空约束注释DEAL_DATEEGER否否无执行日期JOB_CODEVARCHAR(32)否否无作业编码JOB_DESCVARCHAR(64)否否无作业名称BELNG_SYSVARC

50、HAR(12)否否无归属系统JOB_CYCLECHAR(2)否否无作业周期BEGIN_TIMETIMEST否否无开始时间FINISH_TIMETIMEST否否无完成时间EXEC_DUREGER否否无执行时长EXEC_SUSCHAR(4)否否无执行状态INSERT_TIMETIMEST否否无时间表名注释作业结果历史表GATHER_SUSCHAR(4)否否无状态CHECK_TIMETIMEST否否无稽核时间CHECK_RESULTCHAR(4)否否无稽核结果WAVE_VALUEFLOAT否否无波动性BALANCE_VALUEFLOAT否否无平衡性INSERT_TIMETIMEST否否无时间服务管理表告警日志表服务运行日志分布键SEQ索引说明该节点时程序报错表名注释服务运行日志列名数据类型是否主键是否自增是否为空约束注释SEQEGER是否无序列INDEX_CODEVARCHAR(32)否否无指标编码INDEX_NAMEVARCHAR(64)