elasticsearch 6.* 기본기-3 Aggregations

orders-bulk.json

################## 집계(aggs)
# SQL 의 group by 와 같이 데이터를 그룹화하고 통계를 얻는 기능.
# ES는 검색과 동시에 집계 결과를 반환할 수 있다.
# 집계만 표시하려면 size: 0
 
#################### Metrics Aggregations
 
# 인덱스 생성
PUT order
{
    "mappings": {
      "default": {
        "properties": {
          "lines": {
            "properties": {
              "amount": {
                "type": "double"
              },
              "product_id": {
                "type": "integer"
              },
              "quantity": {
                "type": "short"
              }
            }
          },
          "purchased_at": {
            "type": "date"
          },
          "sales_channel": {
            "type": "keyword"
          },
          "salesman": {
            "properties": {
              "id": {
                "type": "integer"
              },
              "name": {
                "type": "text"
              }
            }
          },
          "status": {
            "type": "keyword"
          },
          "total_amount": {
            "type": "double"
          }
        }
      }
    }
}
 
# _bulk API로 데이터 밀어넣기
POST order/default/_bulk
# 첨부 json
 
# 전체 판매금액과 판매량 집계
POST order/_search
{
  "size": 0,
  "aggs": {
    "total_sales": {
      "stats": {
        "field": "total_amount"
      }
    },
    "total_cnt": {
      "stats": {
        "field": "lines.quantity"
      }
    }
  }
}
# stats 를 개별적으로 가져오려면 stats 대신 value_count, min, max, avg, sum 을 넣는다
 
# 판매원의 숫자 
# cardinality는 고유한 값의 개수를 계산한다.
POST order/_search
{
  "size": 0,
  "aggs": {
    "total_salesman": {
      "cardinality": {
        "field": "salesman.id"
      }
    }
  }
}
 
#################### Bucket Aggregations
# default는 desc
 
# 진행상태별 갯수
GET /order/_search
{
  "size": 0,
  "aggs": {
    "status_terms": {
      "terms": {
        "field": "status",
        "order": {
          "_term": "asc"
        }
        
      }
    }
  }
}
 
# sql 로 표현하자면 아래와 같다.
# SELECT status, COUNT(*) FROM order GROUP BY status ORDER BY COUNT(*) 
 
GET /order/_search
{
  "size": 0,
  "aggs": {
    "status_terms": {
      "terms": {
        "field": "total_amount",
        "size": 10
      }
    }
  }
}
 
# terms 는 갯수가 많은 숫자로 노출이 되지만 significant_terms 은 흥미롭거나 비정상적인 발생을 반환한다. 흥미로운 결과를 얻을 수 있다.
 
#################### Nested Aggregations(중첩집계)
# 상태별 금액
GET /order/_search
{
  "size": 0,
  "aggs": {
    "status_terms": {
      "terms": {
        "field": "status"
      },
      "aggs": {
        "status_stats": {
          "stats": {
            "field": "total_amount"
          }
        }
      }
    }
  }
}
 
# 판매원별 판매액
GET /order/_search
{
  "size": 0,
  "aggs": {
    "group_by_state": {
      "terms": {
        "field": "salesman.id"
      },
      "aggs": {
        "id_total_amount": {
          "sum": {
            "field": "total_amount"
          }
        }
      }
    }
  }
}
 
# 기간 검색 추가
GET /order/_search
{
  "size": 0,
  "query": {
    "range": {
      "purchased_at": {
        "gte": "2016-06-01T00:00:00Z",
        "lte": "2016-12-31T23:59:59"
      }
    }
  }, 
  "aggs": {
    "status_terms": {
      "terms": {
        "field": "status"
      },
      "aggs": {
        "status_stats": {
          "stats": {
            "field": "total_amount"
          }
        }
      }
    }
  }
}
 
#################### filter와 함께 사용하기
GET /order/_search
{
  "size": 0,
  "aggs": {
    "high_value": {
      "filter": {
        "range": {
          "total_amount": {
            "gt": 100
          }
        }
      },
      "aggs": {
        "avg_amount": {
          "avg": {
            "field": "total_amount"
          }
        }
      }
    }
  }
}
 
#쿼리로 바꾸면
 
GET /order/_search
{
  "size": 0,
  "query": {
    "range": {
      "total_amount": {
        "gt": 100
      }
    }
  },
  "aggs": {
    "avg_amount": {
      "avg": {
        "field": "total_amount"
      }
    }
  }
}
 

orders-bulk.json

0.26MB