如果我使用带有指标的aggregations.bucket,该如何对其进行过滤以控制回溯期?同样,是否可以将过滤器以相同的方式用于扩展统计信息?这是一个有效的代码片段(以及我想使用的那种过滤器):
s = Search(using=client)
s.aggs.bucket('some_bucket_by_day', 'date_histogram', field='time_field', interval='day')
.metric('some_avg', 'avg', field='some_field')
尝试这样过滤:filter='range', **{'time_field': {'gte': 'now-10d'}}
另外,如果使用extended_stats,过滤器也可以工作吗?s.aggs.bucket('exchange_stats', 'extended_stats', field='some_field')
谢谢!
最佳答案
可以在查询级别应用过滤器,这将减少需要在其上计算聚合的文档数量。 extended_stats
也是度量标准聚合,而不是存储桶聚合。因此,您可以这样做:
// create search and filter the document by date
s = Search(using=client)
.filter('range', time_field={'gte': 'now-10d'})
// add some aggregations
s.aggs.bucket('some_bucket_by_day', 'date_histogram', field='time_field', interval='day')
.metric('some_avg', 'avg', field='some_field')
.metric('exchange_stats', 'extended_stats', field='some_field')
关于elasticsearch - Elasticsearch DSL过滤器,用于聚合和扩展统计信息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63056160/