Агрегирование MAX
Агрегирование метрик single-value, которое отслеживает и возвращает максимальное значение среди числовых значений, извлеченных из агрегированных документов.
Агрегирования min и max работают с представлением данных double. Вследствие этого результат может быть приближенным при работе с числами типа long, абсолютное значение которых больше 2^53.
Вычисление максимальной цены по всем документам
resp = client.search(
index="sales",
size="0",
aggs={
"max_price": {
"max": {
"field": "price"
}
}
},
)
print(resp) response = client.search(
index: 'sales',
size: 0,
body: {
aggregations: {
max_price: {
max: {
field: 'price'
}
}
}
}
)
puts response const response = await client.search({
index: "sales",
size: 0,
aggs: {
max_price: {
max: {
field: "price",
},
},
},
});
console.log(response); POST /sales/_search?size=0
{
"aggs": {
"max_price": { "max": { "field": "price" } }
}
} Ответ:
{
...
"aggregations": {
"max_price": {
"value": 200.0
}
}
} Как можно видеть, имя агрегирования (max_price выше) также используется в качестве ключа для извлечения результата агрегирования из возвращенного ответа.
Скрипт
Если вам нужно получить max чего-то более сложного, чем одного поля, выполните агрегирование по полю runtime.
resp = client.search(
index="sales",
size=0,
runtime_mappings={
"price.adjusted": {
"type": "double",
"script": "\n double price = doc['price'].value;\n if (doc['promoted'].value) {\n price *= 0.8;\n }\n emit(price);\n "
}
},
aggs={
"max_price": {
"max": {
"field": "price.adjusted"
}
}
},
)
print(resp) response = client.search(
index: 'sales',
body: {
size: 0,
runtime_mappings: {
'price.adjusted' => {
type: 'double',
script: "\n double price = doc['price'].value;\n if (doc['promoted'].value) {\n price *= 0.8;\n }\n emit(price);\n "
}
},
aggregations: {
max_price: {
max: {
field: 'price.adjusted'
}
}
}
}
)
puts response const response = await client.search({
index: "sales",
size: 0,
runtime_mappings: {
"price.adjusted": {
type: "double",
script:
"\n double price = doc['price'].value;\n if (doc['promoted'].value) {\n price *= 0.8;\n }\n emit(price);\n ",
},
},
aggs: {
max_price: {
max: {
field: "price.adjusted",
},
},
},
});
console.log(response); POST /sales/_search
{
"size": 0,
"runtime_mappings": {
"price.adjusted": {
"type": "double",
"script": """
double price = doc['price'].value;
if (doc['promoted'].value) {
price *= 0.8;
}
emit(price);
"""
}
},
"aggs": {
"max_price": {
"max": { "field": "price.adjusted" }
}
}
} Отсутствующее значение
Параметр missing определяет, как следует обрабатывать документы, у которых отсутствует значение. По умолчанию они будут игнорироваться, но также можно обработать их как имеющие значение.
resp = client.search(
index="sales",
aggs={
"grade_max": {
"max": {
"field": "grade",
"missing": 10
}
}
},
)
print(resp) response = client.search(
index: 'sales',
body: {
aggregations: {
grade_max: {
max: {
field: 'grade',
missing: 10
}
}
}
}
)
puts response const response = await client.search({
index: "sales",
aggs: {
grade_max: {
max: {
field: "grade",
missing: 10,
},
},
},
});
console.log(response); POST /sales/_search
{
"aggs" : {
"grade_max" : {
"max" : {
"field" : "grade",
"missing": 10
}
}
}
} | Документы без значения в поле |
Поля гистограммы
Когда агрегирование max вычисляется на полях гистограммы, результатом агрегирования является максимальное значение всех элементов в массиве values. Обратите внимание, что массив counts гистограммы игнорируется.
Например, для следующего индекса, который хранит предварительно агрегированные гистограммы с метриками задержки для разных сетей:
resp = client.indices.create(
index="metrics_index",
mappings={
"properties": {
"latency_histo": {
"type": "histogram"
}
}
},
)
print(resp)
resp1 = client.index(
index="metrics_index",
id="1",
refresh=True,
document={
"network.name": "net-1",
"latency_histo": {
"values": [
0.1,
0.2,
0.3,
0.4,
0.5
],
"counts": [
3,
7,
23,
12,
6
]
}
},
)
print(resp1)
resp2 = client.index(
index="metrics_index",
id="2",
refresh=True,
document={
"network.name": "net-2",
"latency_histo": {
"values": [
0.1,
0.2,
0.3,
0.4,
0.5
],
"counts": [
8,
17,
8,
7,
6
]
}
},
)
print(resp2)
resp3 = client.search(
index="metrics_index",
size="0",
filter_path="aggregations",
aggs={
"max_latency": {
"max": {
"field": "latency_histo"
}
}
},
)
print(resp3) response = client.indices.create(
index: 'metrics_index',
body: {
mappings: {
properties: {
latency_histo: {
type: 'histogram'
}
}
}
}
)
puts response
response = client.index(
index: 'metrics_index',
id: 1,
refresh: true,
body: {
'network.name' => 'net-1',
latency_histo: {
values: [
0.1,
0.2,
0.3,
0.4,
0.5
],
counts: [
3,
7,
23,
12,
6
]
}
}
)
puts response
response = client.index(
index: 'metrics_index',
id: 2,
refresh: true,
body: {
'network.name' => 'net-2',
latency_histo: {
values: [
0.1,
0.2,
0.3,
0.4,
0.5
],
counts: [
8,
17,
8,
7,
6
]
}
}
)
puts response
response = client.search(
index: 'metrics_index',
size: 0,
filter_path: 'aggregations',
body: {
aggregations: {
max_latency: {
max: {
field: 'latency_histo'
}
}
}
}
)
puts response const response = await client.indices.create({
index: "metrics_index",
mappings: {
properties: {
latency_histo: {
type: "histogram",
},
},
},
});
console.log(response);
const response1 = await client.index({
index: "metrics_index",
id: 1,
refresh: "true",
document: {
"network.name": "net-1",
latency_histo: {
values: [0.1, 0.2, 0.3, 0.4, 0.5],
counts: [3, 7, 23, 12, 6],
},
},
});
console.log(response1);
const response2 = await client.index({
index: "metrics_index",
id: 2,
refresh: "true",
document: {
"network.name": "net-2",
latency_histo: {
values: [0.1, 0.2, 0.3, 0.4, 0.5],
counts: [8, 17, 8, 7, 6],
},
},
});
console.log(response2);
const response3 = await client.search({
index: "metrics_index",
size: 0,
filter_path: "aggregations",
aggs: {
max_latency: {
max: {
field: "latency_histo",
},
},
},
});
console.log(response3); PUT metrics_index
{
"mappings": {
"properties": {
"latency_histo": { "type": "histogram" }
}
}
}
PUT metrics_index/_doc/1?refresh
{
"network.name" : "net-1",
"latency_histo" : {
"values" : [0.1, 0.2, 0.3, 0.4, 0.5],
"counts" : [3, 7, 23, 12, 6]
}
}
PUT metrics_index/_doc/2?refresh
{
"network.name" : "net-2",
"latency_histo" : {
"values" : [0.1, 0.2, 0.3, 0.4, 0.5],
"counts" : [8, 17, 8, 7, 6]
}
}
POST /metrics_index/_search?size=0&filter_path=aggregations
{
"aggs" : {
"max_latency" : { "max" : { "field" : "latency_histo" } }
}
} Агрегирование max вернет максимальное значение всех полей гистограммы:
{
"aggregations": {
"max_latency": {
"value": 0.5
}
}
}
© 2023-2025 Elasticsearch
As of September 2024, Elasticsearch is available under a choice of three licenses: the Server Side Public License (SSPL), the Elastic License, or the AGPLv3 (OSI approved).
Elasticsearch and the Elasticsearch logo are trademarks of Elasticsearch B.V., registered in the U.S. and in other countries.
https://www.elastic.co/guide/en/elasticsearch/reference/8.17/search-aggregations-metrics-max-aggregation.html
