elasticsearch collapse折叠聚合

目前经验：折叠只能用于筛选数据，不能进行聚合，需要聚合，自己在内存中聚合

from elasticsearch import Elasticsearchdef query_2coll(index_name):query = {'size': 10000,"query": {"match_all": {}},"collapse": {"field": "subject_id","inner_hits": {"name": "group","size": 5,"sort": [{"group": "asc"}]},"max_concurrent_group_searches": 4}}try:datas = []allDoc = es.search(index=index_name, doc_type='koala-index', body=query)for data in allDoc['hits']['hits']:print(data['_source']['id'], data['_source']['group'], data['_source']['subject_id'])# for val, buckets in enumerate(data['_source']):#     if val>1:#         print('data error')# print(buckets['_source'])datas.append(data['_source'])return datasexcept Exception as e:print('query1 error', e)return datasdef query(index_name):query ={'size':10000,"query": {"match_all": {}},"sort": [{"group": {"order": "asc"}}],"collapse": {"field": "group","terms": {"field": "subject_id", 'size': 10000}},"aggs": {"agg_sex": {"terms": {"field": "subject_id",'size':10000}}}}try:datas=[]allDoc = es.search(index=index_name, doc_type='koala-index', body=query)for data in allDoc['hits']['hits']:print(data['_source']['id'],data['_source']['group'],data['_source']['subject_id'])# for val, buckets in enumerate(data['_source']):#     if val>1:#         print('data error')# print(buckets['_source'])datas.append(data['_source'])return datasexcept Exception as e:print('query1 error', e)return datasdef query_ju(index_name):query = {"from": 0,"size": 10000,"sort": [{"event_id": {"order": "desc"}}],"collapse": {"field": "subject_id","inner_hits": {"name": "quality","size": 1,"sort": [{"event_id": {"order": "asc"}}]}}}datas=[]try:allDoc = es.search(index=index_name, doc_type='koala-index', body=query)for data in allDoc['hits']['hits']:print(data['_source']['date'])# for val, buckets in enumerate(data['_source']):#     if val>1:#         print('data error')# print(buckets['_source'])# datas.append(buckets['_source'])return datasexcept Exception as e:print('query1 error', e)return datasif __name__ == '__main__':es = Elasticsearch(['127.0.0.1:9200'])index_name = 'event_tk'query_2coll(index_name)

elasticsearch collapse折叠聚合相关推荐

java操作es聚合操作并显示其他字段_java使用elasticsearch分组进行聚合查询过程解析...
这篇文章主要介绍了java使用elasticsearch分组进行聚合查询过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 java连接elas ...
element-plus 组件解析 - Collapse 折叠面板
element-plus 组件解析 - Collapse 折叠面板 1, 组件介绍 2,组件组成 3,组件实现 3.1,el-collapse 1,v-model="activeNames& ...
用timeline 时间线和 Collapse 折叠面板做一个简单的时间轴
项目上有个时间轴功能,我看了一下element上有时间轴功能,不过有点太简单,我想改造一下这个时间轴,记录一下,用Timeline 时间线和 Collapse 折叠面板,两个加起来做了一时间轴,当是 ...
Elasticsearch查询和聚合基本语法
1.概述 Elasticsearch主要的查询语法包括URI查询和body查询,URI比较轻便快速,而body查询作为一种json的格式化查询,可以有许多限制条件.本文主要介绍结构化查询的query, ...
七.Elasticsearch 字段折叠
概要:字段折叠其实就是聚合,不过在es中字段折叠是单独一个模块,聚合也是一个模块,在某些时候两者可以实现同样的功能,字段折叠是简单的聚合,而聚合aggs则是一个大模块,里面有更多更详细的各种聚合功能. ...
Elasticsearch: 权威指南 » 聚合 » Doc Values and Fielddata » 聚合与分析
2019独角兽企业重金招聘Python工程师标准>>> 有些聚合,比如 terms 桶, 操作字符串字段.字符串字段可能是 analyzed 或者 not_analyzed , 那么 ...
java操作es聚合操作并显示其他字段_java使用elasticsearch分组进行聚合查询（group by）-项目中实际应用...
java连接elasticsearch 进行聚合查询进行相应操作一:对单个字段进行分组求和 1.表结构图片: 根据任务id分组,分别统计出每个任务id下有多少个文字标题 1.SQL:select i ...
Elasticsearch过滤与聚合的先后顺序java实现
一.Elasticsearch的聚合 ES的聚合相当于关系型数据库里面的group by,例如查找在性别字段男女人数的多少并且按照人数的多少进行排序,在使用mysql的时候,可以使用如下的句子 sel ...
【Elasticsearch】Elasticsearch 存储桶聚合
1.概述翻译:https://iridakos.com/programming/2018/10/22/elasticsearch-bucket-aggregations [Elasticsearch ...

elasticsearch collapse折叠聚合

elasticsearch collapse折叠聚合相关推荐

最新文章

热门文章