指标统计sql脚本

RZ_DM/RZ_DM_RUNSTATUS.sql

@@ -7,12 +7,12 @@ select
      ,s1.agentId                                                              as `agentid`
      ,s1.endPoint                                                             as `endpoint`
      ,s1.rpc                                                                  as `rpc`
-     ,DATE_FORMAT(tumble_end(d1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss')     as `time`
+     ,DATE_FORMAT(tumble_end(s1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss')     as `time`
      ,cast(AVG(cast(s1.elapsed as decimal(18,2)) )        as varchar)                      as `averageelapsed`
      ,cast(sum(1)                                         as varchar)                      as `total`
      ,cast(sum(if(s1.status = '200',1,0))                 as varchar)                      as `suctotal`
      ,cast(sum(if(s1.status = '200' is not true,1,0))     as varchar)                      as `errortotal`
-     ,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute) ) as varchar)  as `createtime`
+     ,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar)  as `createtime`
 from RZ_ODS.RZ_ODS_KAFKA.RZDATA s1
 where
     UPPER(RIGHT(s1.`rpc`,3)) not in ('.JS')
@@ -33,12 +33,12 @@ insert into RZ_DM.RZ_DM_KAFKA.RUNSTATUS_AGENTID
 select
     s1.applicationName                                                        as `applicationname`
      ,s1.agentId                                                              as `agentid`
-     ,DATE_FORMAT(tumble_end(d1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss')     as `time`
+     ,DATE_FORMAT(tumble_end(s1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss')     as `time`
      ,cast(AVG(cast(s1.elapsed as decimal(18,2)) )        as varchar)                      as `averageelapsed`
      ,cast(sum(1)                                         as varchar)                      as `total`
      ,cast(sum(if(s1.status = '200',1,0))                 as varchar)                      as `suctotal`
      ,cast(sum(if(s1.status = '200' is not true,1,0))     as varchar)                      as `errortotal`
-     ,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute) ) as varchar)  as `createtime`
+     ,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar)  as `createtime`
 from RZ_ODS.RZ_ODS_KAFKA.RZDATA s1
 group by
     s1.applicationName
@@ -51,12 +51,12 @@ group by
 insert into RZ_DM.RZ_DM_KAFKA.RUNSTATUS_APP
 select
     s1.applicationName                                                      as `applicationname`
-     ,DATE_FORMAT(tumble_end(d1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss')     as `time`
+     ,DATE_FORMAT(tumble_end(s1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss')     as `time`
      ,cast(AVG(cast(s1.elapsed as decimal(18,2)) )        as varchar)                      as `averageelapsed`
      ,cast(sum(1)                                         as varchar)                      as `total`
      ,cast(sum(if(s1.status = '200',1,0))                 as varchar)                      as `suctotal`
      ,cast(sum(if(s1.status = '200' is not true,1,0))     as varchar)                      as `errortotal`
-     ,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute) ) as varchar)  as `createtime`
+     ,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar)  as `createtime`
 from RZ_ODS.RZ_ODS_KAFKA.RZDATA s1
 group by
     s1.applicationName