Only show anomalies with a score greater than 50

elastic · Sep 29, 2020 · b7a9f8c · b7a9f8c
1 parent ecee577
commit b7a9f8c
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 10 deletions.
diff --git a/x-pack/plugins/infra/server/lib/infra_ml/metrics_hosts_anomalies.ts b/x-pack/plugins/infra/server/lib/infra_ml/metrics_hosts_anomalies.ts
@@ -175,16 +175,6 @@ async function fetchMetricsHostsAnomalies(
 
   const finalizeFetchLogEntryAnomaliesSpan = startTracingSpan('fetch metrics hosts anomalies');
 
-  // console.log(
-  //   'data',
-  //   JSON.stringify(
-  //     await mlSystem.mlAnomalySearch(
-  //       createMetricsHostsAnomaliesQuery(jobIds, startTime, endTime, sort, expandedPagination)
-  //     ),
-  //     null,
-  //     2
-  //   )
-  // );
   const results = decodeOrThrow(metricsHostsAnomaliesResponseRT)(
     await mlSystem.mlAnomalySearch(
       createMetricsHostsAnomaliesQuery(jobIds, startTime, endTime, sort, expandedPagination)

diff --git a/x-pack/plugins/infra/server/lib/infra_ml/queries/common.ts b/x-pack/plugins/infra/server/lib/infra_ml/queries/common.ts
@@ -40,6 +40,16 @@ export const createTimeRangeFilters = (startTime: number, endTime: number) => [
   },
 ];
 
+export const createAnomalyScoreFilter = (minScore: number) => [
+  {
+    range: {
+      record_score: {
+        gte: minScore,
+      },
+    },
+  },
+];
+
 export const createResultTypeFilters = (resultTypes: Array<'model_plot' | 'record'>) => [
   {
     terms: {

diff --git a/x-pack/plugins/infra/server/lib/infra_ml/queries/metrics_hosts_anomalies.ts b/x-pack/plugins/infra/server/lib/infra_ml/queries/metrics_hosts_anomalies.ts
@@ -11,6 +11,7 @@ import {
   createTimeRangeFilters,
   createResultTypeFilters,
   defaultRequestParameters,
+  createAnomalyScoreFilter,
 } from './common';
 import { Sort, Pagination } from '../../../../common/http_api/infra_ml';
 
@@ -35,6 +36,7 @@ export const createMetricsHostsAnomaliesQuery = (
 
   const filters = [
     ...createJobIdsFilters(jobIds),
+    ...createAnomalyScoreFilter(50),
     ...createTimeRangeFilters(startTime, endTime),
     ...createResultTypeFilters(['record']),
   ];

diff --git a/x-pack/plugins/infra/server/lib/infra_ml/queries/metrics_k8s_anomalies.ts b/x-pack/plugins/infra/server/lib/infra_ml/queries/metrics_k8s_anomalies.ts
@@ -11,6 +11,7 @@ import {
   createTimeRangeFilters,
   createResultTypeFilters,
   defaultRequestParameters,
+  createAnomalyScoreFilter,
 } from './common';
 import { Sort, Pagination } from '../../../../common/http_api/infra_ml';
 
@@ -35,6 +36,7 @@ export const createMetricsK8sAnomaliesQuery = (
 
   const filters = [
     ...createJobIdsFilters(jobIds),
+    ...createAnomalyScoreFilter(50),
     ...createTimeRangeFilters(startTime, endTime),
     ...createResultTypeFilters(['record']),
   ];