fix: 当业务下有大量的执行作业，加载 web 页面首页的时候会触发DB慢查询 #2228

TencentBlueKing · Jul 14, 2023 · 56fc950 · 56fc950
1 parent 6d1daf6
commit 56fc950
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 1 deletion.
diff --git a/...ob-execute/src/main/java/com/tencent/bk/job/execute/api/inner/ServiceMetricsResource.java b/...ob-execute/src/main/java/com/tencent/bk/job/execute/api/inner/ServiceMetricsResource.java
@@ -27,10 +27,13 @@
 import com.tencent.bk.job.common.annotation.InternalAPI;
 import com.tencent.bk.job.common.model.InternalResponse;
 import com.tencent.bk.job.common.statistics.model.dto.StatisticsDTO;
+import com.tencent.bk.job.execute.model.inner.request.ServiceTriggerStatisticsRequest;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -72,4 +75,11 @@ InternalResponse<StatisticsDTO> getStatistics(
         @ApiParam(value = "统计日期(yyyy-MM-dd)", required = true)
         @RequestParam(value = "dateStr", required = true) String dateStr
     );
+
+    @ApiOperation(value = "触发指定时间的数据统计", produces = "application/json")
+    @PostMapping("/service/metrics/statistics/trigger")
+    InternalResponse<Boolean> triggerStatistics(
+        @ApiParam(value = "统计日期(yyyy-MM-dd)", required = false)
+        @RequestBody ServiceTriggerStatisticsRequest request
+    );
 }
diff --git a/...xecute/src/main/java/com/tencent/bk/job/execute/api/inner/ServiceMetricsResourceImpl.java b/...xecute/src/main/java/com/tencent/bk/job/execute/api/inner/ServiceMetricsResourceImpl.java
@@ -26,6 +26,7 @@
 
 import com.tencent.bk.job.common.model.InternalResponse;
 import com.tencent.bk.job.common.statistics.model.dto.StatisticsDTO;
+import com.tencent.bk.job.execute.model.inner.request.ServiceTriggerStatisticsRequest;
 import com.tencent.bk.job.execute.service.TaskInstanceService;
 import com.tencent.bk.job.execute.statistics.StatisticsService;
 import io.micrometer.core.annotation.Timed;
@@ -67,4 +68,9 @@ public InternalResponse<StatisticsDTO> getStatistics(Long appId, String resource
         return InternalResponse.buildSuccessResp(statisticsService.getStatistics(appId, resource, dimension,
             dimensionValue, dateStr));
     }
+
+    @Override
+    public InternalResponse<Boolean> triggerStatistics(ServiceTriggerStatisticsRequest request) {
+        return InternalResponse.buildSuccessResp(statisticsService.triggerStatistics(request.getDateList()));
+    }
 }
diff --git a/...ob-execute/src/main/java/com/tencent/bk/job/execute/statistics/StatisticsServiceImpl.java b/...ob-execute/src/main/java/com/tencent/bk/job/execute/statistics/StatisticsServiceImpl.java
@@ -531,7 +531,6 @@ public Boolean triggerStatistics(List<String> dateList) {
                             updateStartJobStatistics(taskInstance);
                         }
                         offset += limit;
-                        Thread.sleep(2000);
                     } while (taskInstanceIds.size() == limit);
                 }
             }