Elasticsearch DSL python 查询嵌套属性的过滤器和聚合

Question

我想使用通过嵌套对象进行过滤并进行聚合以获取嵌套对象列表中嵌套对象的最小值来构建过滤后的 Elasticsearch 查询。

过滤部分有效，但我无法将其与 aggs（聚合）部分绑定。当我在过滤器之后将 .aggs.bucket 部分添加到我的代码时，它要么被忽略（在 search.to_dict() 中不可见），要么给我语法错误。

任何人都可以给我一个关于如何将它们绑定在一起的例子吗？我正在尝试在一个响应

中同时获取过滤后的查询结果和 nested1.foo.bar 计算出的最小值

示例架构：

class MyExample(DocType):
    myexample_id = Integer()
    nested1 = Nested(
        properties={
            'timestamp': Date(),
            'foo': Nested(
                properties={
                    'bar': Float(),
                }
            )
        }
    )
    nested2 = Nested(
        multi=False,
        properties={
            'x': String(),
            'y': String(),
        }
    )

构建查询：

from elasticsearch_dsl import Search, Q

search = Search().filter(
    'nested', path='nested1', inner_hits={},
    query=Q(
        'range', **{
            'nested1.timestamp': {
                'gte': exampleDate1,
                'lte': exampleDate2
            }
        }
    )
).filter(
    'nested', path='nested2', inner_hits={'name': 'x'},
    query=Q(
        'term', **{
            'nested2.x': x
        }
    )
).filter(
    'nested', path='nested2', inner_hits={'name': 'y'},
    query=Q(
        'term', **{
            'nested2.y': y
        }
    )
)

基本上我需要做的是获取每个唯一 MyExample 文档的所有嵌套 nested1.foo.bar 值的最小值（它们具有唯一的 myexample_id 字段）

Answer 1

正在添加

search.aggs\
    .bucket('nested1', 'nested', path='nested1')\
    .bucket('nested_foo', 'nested', path='nested1.foo')\
    .metric('min_bar', 'min', field='nested1.foo.bar')

在下一行应该可以解决问题。

Elasticsearch DSL python 查询嵌套属性的过滤器和聚合

Elasticsearch DSL python queries with filters and aggregations on nested properties

python

elasticsearch

elasticsearch-dsl