不为失败找理由,要为成功找方法。

ElasticSearch如何先聚合后过滤?

Elasticsearch | 作者 danier | 发布于2016年07月10日 | 阅读数:10195

场景:按日期纬度一个数据报表,字段有date_str, shop_code, new_user_count, active_count。字段分别含义:日期(精确到日)、车商id、 新增用户、活跃用户数;
          先需先按照时间范围查询,车商id分组,new_user_count字段取sum。然后在聚合后过滤new_user_count字段sum结果>30的所有车商id,以及sum结果。

类似sql:select shop_code, sum(new_user_count) from A where date_str >= ? and date_str <= ? group by shop_code having sum(new_user_count) > 30;

ps:不知道es有没有实现先聚合然后过滤的功能。希望大神们能解惑,谢了。
已邀请:

nihao

赞同来自:

post filter就是干这个用的

jacky_wang

赞同来自:

有解决方案了嘛?我也遇到这个问题了 能说下你是怎么实现的么

daodaodt

赞同来自:

在6.2版本中提到了一个Bucket Script Aggregation 的功能:
 
https://www.elastic.co/guide/e ... .html
 
用它实现了如下SQL
select company_id, count(1) from xxx_table where company_id between A and B group by company_id having count(1) > 1;
 
{
  "size": 0,
  "query": {
    "constant_score": {
      "filter": {
        "range": {
          "company_id": {
            "gte": A,
            "lte": B
          }
        }
      }
    }
  },
  "aggs": {
    "count_by_company_id": {
      "terms": {
        "field": "company_id"
      },
      "aggs": {
        "distinct_id": {
          "cardinality": {
            "field": "company_id"
          }
        },
        "id_bucket_filter": {
          "bucket_selector": {
            "buckets_path": {
              "value": "distinct_id"
            },
            "script": "params.value> 1"
          }
        }
      }
    }
  }
}

要回复问题请先登录注册