feat: lineage edit

Author: 15764265847

.env.development

@@ -1,2 +1 @@
-VITE_BASE_URL="/ml"
-VITE_BASE_DATAHUB_URL="/datahubServer"
+VITE_BASE_URL="/ml"

.env.production

@@ -1,2 +1 @@
-VITE_BASE_URL="http://8.135.49.240:8081"
-VITE_BASE_DATAHUB_URL="/datahubServer"
+VITE_BASE_URL="http://8.135.49.240:8081"

.env.staging

@@ -1,2 +1 @@
-VITE_BASE_URL="http://172.16.1.192:8080"
-VITE_BASE_DATAHUB_URL="/datahubServer"
+VITE_BASE_URL="http://172.16.1.192:8080"

config/vite/proxy.ts

@@ -8,14 +8,7 @@ const init: ProxyTargetList = {
     rewrite: (path) => {
       return path.replace(/^\/ml/, '')
     }
-  },
-  '/datahubServer': {
-    target: 'http://172.16.1.190:9002', // 公司开发
-    changeOrigin: true,
-    rewrite: (path) => {
-      return path.replace(/^\/datahubServer/, '')
-    }
-  },
+  }
 }
 
 export default init

src/components/metrics/clusterAnalysis/ClusterAnalysis.vue

@@ -14,15 +14,7 @@ import sqls, { SqlParams } from '../dataAnalysis/sqls'
 import { ref, watch } from 'vue'
 import { getRealSqlOfArr, getUndefined } from '../dataAnalysis/utils'
 import TableBanner from '../TableBanner.vue'
-
-type ChangeValue = {
-  database?: string,
-  table?: string,
-  time?: string | number,
-  queryKind?: string,
-  user?: string,
-  type?: string
-}
+import { ChangeValue } from '../types'
 
 const props = defineProps<{
   activeName: string

src/components/metrics/dataAnalysis/DataAnalysis.vue

@@ -14,25 +14,18 @@ import { computed, ref } from 'vue'
 import { getRealSqlOfArr, getStartAndEndTime, getUndefined } from './utils'
 import dayjs from 'dayjs'
 import TableBanner from '../TableBanner.vue'
-
-type ChangeValue = {
-  database?: string,
-  table?: string,
-  time?: string | number,
-  queryKind?: string,
-  user?: string,
-  type?: string
-}
+import { ChangeValue } from '../types'
 
 const queryFunc = (sql: string) => {
   return query(sql)
 }
 const databaseReal = ref<string | undefined>(undefined)
 const tableReal = ref<string | undefined>(undefined)
 const timeReal = ref<string | number>(dayjs.duration(24, 'hours').asMilliseconds())
+const timeDuration = ref<string>('1 MINUTE')
 
 const selectChangeData = (data: ChangeValue) => {
-  const { database, table, time } = data
+  const { database, table, time, option } = data
   if (database) {
     databaseReal.value = getRealSqlOfArr(getUndefined(database))
   }
@@ -41,6 +34,7 @@ const selectChangeData = (data: ChangeValue) => {
   }
   if (time) {
     timeReal.value = time
+    timeDuration.value = option?.duration || '1 MINUTE'
   }
 }
 
@@ -101,6 +95,20 @@ const queryFunction = (
         ></count>
       </el-col>
     </el-row>
+    <el-row :gutter="10">
+      <el-col :span="24">
+        <ChartsVue
+          index="3"
+          title="Write Rows"
+          sql-func-name="queryWriteRowDataAnalysis"
+          :time-range="timeRange"
+          :time-duration="timeDuration"
+          :query-func="queryFunction"
+          type="line"
+          :height="470"
+        ></ChartsVue>
+      </el-col>
+    </el-row>
     <el-row :gutter="10">
       <el-col :span="12">
         <Progress

src/components/metrics/dataAnalysis/sqls.ts

@@ -304,6 +304,26 @@ function queryMaxPartsPerPartition({database, table}: SqlParams) {
       LIMIT 10
     `)
 }
+
+/**
+ * 查询近期的分析
+ */
+function queryWriteRowDataAnalysis ({
+  timeDuration,
+  startTime,
+  endTime
+}: SqlParams) {
+  const whereStr = dealSQLWhere([
+    { value: `event_time > '${startTime}' AND event_time < '${endTime}'` }
+  ])
+
+  return formatJson(`
+    SELECT toStartOfInterval(toDateTime(event_time), INTERVAL ${timeDuration}),
+    sum(written_rows) written_rows FROM system.query_log
+    ${whereStr} GROUP BY event_time ORDER BY event_time ASC
+  `)
+}
+
 /**
  * 查询近期的分析
  */
@@ -919,6 +939,7 @@ export default {
   queryPartsOverTimeWithRowCount,
   queryMaxPartsPerPartition,
   queryRecentPartAnalysis,
+  queryWriteRowDataAnalysis,
   // Cluster Analysis start
   queryDatabaseNumber,
   queryTableNumber,

src/components/metrics/queryAnalysis/QueryAnalysis.vue

@@ -15,20 +15,7 @@ import { getRealSqlOfArr, getStartAndEndTime, getUndefined } from '../dataAnalys
 import totalImg from '@/assets/images/metrics/total_query_analysis.svg'
 import aveMemory from '@/assets/images/metrics/ave_memory.svg'
 import aveTime from '@/assets/images/metrics/ave_time.svg'
-
-type ChangeValue = {
-  database?: string,
-  table?: string,
-  time?: string | number,
-  queryKind?: string,
-  user?: string,
-  type?: string,
-  option?: {
-    duration: string,
-    name: string,
-    value: number | string
-  }
-}
+import { ChangeValue } from '../types'
 
 const props = defineProps<{
   activeName: string

src/components/metrics/types.ts

@@ -14,4 +14,18 @@ export type CommonData = CommonMeta | CommonMeta[]
 export type DataQueryFunc = (
   sqlFuncName: string,
   params: SqlParams
-) => Promise<CommonResType>
+) => Promise<CommonResType>
+
+export type ChangeValue = {
+  database?: string,
+  table?: string,
+  time?: string | number,
+  queryKind?: string,
+  user?: string,
+  type?: string,
+  option?: {
+    duration: string,
+    name: string,
+    value: number | string
+  }
+}