github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 09:48:58 -04:00
Code Issues Projects Releases Packages Wiki Activity

[Uptime] Improve perf / accuracy of overview queries (#29998)

Browse source 
Improves the accuracy and perf of the up/down/total counts
Sets the correct size of 50 for the monitor list. The widget shows 50 entries.
This commit is contained in:
Andrew Cholakian 2019-02-05 15:48:55 -06:00 • committed by GitHub
parent 529162a044
commit 486a5d3654
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 34 deletions
Download patch file Download diff file Expand all files Collapse all files

60
x-pack/plugins/uptime/server/lib/adapters/monitors/elasticsearch_monitors_adapter.ts
View file

@ -150,7 +150,7 @@ export class ElasticsearchMonitorsAdapter implements UMMonitorsAdapter {
query,
size: 0,
aggs: {
urls: {
ids: {
composite: {
sources: [
{
@ -160,13 +160,6 @@ export class ElasticsearchMonitorsAdapter implements UMMonitorsAdapter {
},
},
},
{
port: {
terms: {
field: 'url.full',
},
},
},
],
size: 10000,
},
@ -187,35 +180,33 @@ export class ElasticsearchMonitorsAdapter implements UMMonitorsAdapter {
},
};
const queryResult = await this.database.search(request, params);
const hostBuckets = get(queryResult, 'aggregations.urls.buckets', []);
const monitorStatuses = hostBuckets.map(bucket => {
const latest = get(bucket, 'latest.hits.hits', []);
return latest.reduce(
(acc, doc) => {
const status = get(doc, '_source.monitor.status', null);
if (statusFilter && statusFilter !== status) {
return acc;
}
let up: number = 0;
let down: number = 0;
let searchAfter: any = null;
do {
if (searchAfter) {
set(params, 'body.aggs.ids.composite.after', searchAfter);
}
const queryResult = await this.database.search(request, params);
const idBuckets = get(queryResult, 'aggregations.ids.buckets', []);
idBuckets.forEach(bucket => {
// We only get the latest doc
const status = get(bucket, 'latest.hits.hits[0]._source.monitor.status', null);
if (!statusFilter || (statusFilter && statusFilter === status)) {
if (status === 'up') {
acc.up += 1;
up++;
} else {
acc.down += 1;
down++;
}
return acc;
},
{ up: 0, down: 0 }
);
});
const { up, down } = monitorStatuses.reduce(
(acc, status) => {
acc.up += status.up;
acc.down += status.down;
return acc;
},
// @ts-ignore TODO update typings and remove this comment
{ up: 0, down: 0 }
);
}
});
searchAfter = get(queryResult, 'aggregations.ids.after_key');
} while (searchAfter);
return { up, down, total: up + down };
}
@ -261,6 +252,7 @@ export class ElasticsearchMonitorsAdapter implements UMMonitorsAdapter {
},
},
],
size: 50,
},
aggs: {
latest: {