Агрегирование вложенных документов
Специальное агрегирование по одной корзине, которое позволяет агрегировать вложенные документы.
Например, предположим, что у нас есть индекс продуктов, и каждый продукт содержит список дилеров — каждый со своей ценой на продукт. Структура отображения может выглядеть следующим образом:
resp = client.indices.create(
index="products",
mappings={
"properties": {
"resellers": {
"type": "nested",
"properties": {
"reseller": {
"type": "keyword"
},
"price": {
"type": "double"
}
}
}
}
},
)
print(resp) response = client.indices.create(
index: 'products',
body: {
mappings: {
properties: {
resellers: {
type: 'nested',
properties: {
reseller: {
type: 'keyword'
},
price: {
type: 'double'
}
}
}
}
}
}
)
puts response const response = await client.indices.create({
index: "products",
mappings: {
properties: {
resellers: {
type: "nested",
properties: {
reseller: {
type: "keyword",
},
price: {
type: "double",
},
},
},
},
},
});
console.log(response); PUT /products
{
"mappings": {
"properties": {
"resellers": {
"type": "nested",
"properties": {
"reseller": {
"type": "keyword"
},
"price": {
"type": "double"
}
}
}
}
}
} |
|
Следующий запрос добавляет продукт с двумя дилерами:
resp = client.index(
index="products",
id="0",
refresh=True,
document={
"name": "LED TV",
"resellers": [
{
"reseller": "companyA",
"price": 350
},
{
"reseller": "companyB",
"price": 500
}
]
},
)
print(resp) response = client.index(
index: 'products',
id: 0,
refresh: true,
body: {
name: 'LED TV',
resellers: [
{
reseller: 'companyA',
price: 350
},
{
reseller: 'companyB',
price: 500
}
]
}
)
puts response const response = await client.index({
index: "products",
id: 0,
refresh: "true",
document: {
name: "LED TV",
resellers: [
{
reseller: "companyA",
price: 350,
},
{
reseller: "companyB",
price: 500,
},
],
},
});
console.log(response); PUT /products/_doc/0?refresh
{
"name": "LED TV",
"resellers": [
{
"reseller": "companyA",
"price": 350
},
{
"reseller": "companyB",
"price": 500
}
]
} | Мы используем динамическое отображение для атрибута |
Следующий запрос возвращает минимальную цену, по которой можно приобрести продукт:
resp = client.search(
index="products",
size="0",
query={
"match": {
"name": "led tv"
}
},
aggs={
"resellers": {
"nested": {
"path": "resellers"
},
"aggs": {
"min_price": {
"min": {
"field": "resellers.price"
}
}
}
}
},
)
print(resp) response = client.search(
index: 'products',
size: 0,
body: {
query: {
match: {
name: 'led tv'
}
},
aggregations: {
resellers: {
nested: {
path: 'resellers'
},
aggregations: {
min_price: {
min: {
field: 'resellers.price'
}
}
}
}
}
}
)
puts response const response = await client.search({
index: "products",
size: 0,
query: {
match: {
name: "led tv",
},
},
aggs: {
resellers: {
nested: {
path: "resellers",
},
aggs: {
min_price: {
min: {
field: "resellers.price",
},
},
},
},
},
});
console.log(response); GET /products/_search?size=0
{
"query": {
"match": {
"name": "led tv"
}
},
"aggs": {
"resellers": {
"nested": {
"path": "resellers"
},
"aggs": {
"min_price": {
"min": {
"field": "resellers.price"
}
}
}
}
}
} Как видно выше, для агрегирования вложенных документов требуется доступ к path этих документов в документах верхнего уровня. Затем можно определить любой тип агрегирования над этими вложенными документами.
Ответ:
{
...
"aggregations": {
"resellers": {
"doc_count": 2,
"min_price": {
"value": 350.0
}
}
}
} Можно использовать под-агрегирование filter, чтобы получить результаты для конкретного дилера.
resp = client.search(
index="products",
size="0",
query={
"match": {
"name": "led tv"
}
},
aggs={
"resellers": {
"nested": {
"path": "resellers"
},
"aggs": {
"filter_reseller": {
"filter": {
"bool": {
"filter": [
{
"term": {
"resellers.reseller": "companyB"
}
}
]
}
},
"aggs": {
"min_price": {
"min": {
"field": "resellers.price"
}
}
}
}
}
}
},
)
print(resp) response = client.search(
index: 'products',
size: 0,
body: {
query: {
match: {
name: 'led tv'
}
},
aggregations: {
resellers: {
nested: {
path: 'resellers'
},
aggregations: {
filter_reseller: {
filter: {
bool: {
filter: [
{
term: {
'resellers.reseller' => 'companyB'
}
}
]
}
},
aggregations: {
min_price: {
min: {
field: 'resellers.price'
}
}
}
}
}
}
}
}
)
puts response const response = await client.search({
index: "products",
size: 0,
query: {
match: {
name: "led tv",
},
},
aggs: {
resellers: {
nested: {
path: "resellers",
},
aggs: {
filter_reseller: {
filter: {
bool: {
filter: [
{
term: {
"resellers.reseller": "companyB",
},
},
],
},
},
aggs: {
min_price: {
min: {
field: "resellers.price",
},
},
},
},
},
},
},
});
console.log(response); GET /products/_search?size=0
{
"query": {
"match": {
"name": "led tv"
}
},
"aggs": {
"resellers": {
"nested": {
"path": "resellers"
},
"aggs": {
"filter_reseller": {
"filter": {
"bool": {
"filter": [
{
"term": {
"resellers.reseller": "companyB"
}
}
]
}
},
"aggs": {
"min_price": {
"min": {
"field": "resellers.price"
}
}
}
}
}
}
}
} Поиск возвращает:
{
...
"aggregations": {
"resellers": {
"doc_count": 2,
"filter_reseller": {
"doc_count": 1,
"min_price": {
"value": 500.0
}
}
}
}
}
© 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-bucket-nested-aggregation.html
