Elasticsearch 汇总数据

L'operazione di aggregazione è un compito periodico che aggrega i dati degli indici specificati dal modello di indice e li aggrega in un nuovo indice. Nell'esempio seguente, creiamo un indice chiamato sensor con diversi timestamp di data/ora. Poi creiamo un'operazione di aggregazione che esegue un cron job per aggregare i dati da questi indici.

PUT /sensor/_doc/1
{
　　　"timestamp": 1516729294000,
　　　"temperature": 200,
　　　"voltage": 5.2,
　　　"node": "a"
{}

Quando eseguiamo il codice sopra, otteniamo i seguenti risultati-

{
　　　"_index" : "sensor",
　　　"_type" : "_doc",
　　　"_id" : "1",
　　　"_version" : 1,
　　　"result" : "created",
　　　"_shards" : {
　　　　　　"total" : 2,
　　　　　　"successful" : 1,
　　　　　　"failed" : 0
　　　},
　　　"_seq_no" : 0,
　　　"_primary_term" : 1
{}

Ora, aggiungi un secondo documento per altri documenti, ecc.

PUT /sensor-2018-01-01/_doc/2
{
　　　"timestamp": 1413729294000,
　　　"temperature": 201,
　　　"voltage": 5.9,
　　　"node": "a"
{}

Creazione dell'operazione di aggregazione

PUT "_rollup/job/sensor
{
　　　"index_pattern": "sensor-*",
　　　"rollup_index": "sensor_rollup",
　　　"cron": "*/30 * * * * * ?",
　　　"page_size" :1000,
　　　"groups" : {
　　　　　　"date_histogram": {
　　　　　　　　　"field": "timestamp",
　　　　　　　　　"interval": "60m"
　　　　　　},
　　　　　　"terms": {
　　　　　　　　　"fields": ["node"]
　　　　　　{}
　　　},
　　　"metrics": [
　　　　　　{
　　　　　　　　　"field": "temperature",
　　　　　　　　　"metrics": ["min", "max", "sum"]
　　　　　　},
　　　　　　{
　　　　　　　　　"field": "voltage",
　　　　　　　　　"metrics": ["avg"]
　　　　　　{}
　　　]
{}

cron参数控制作业的激活时间和激活频率。当汇总作业的cron计划触发时，它将从上次激活后从上次中断的地方开始汇总

在作业运行并处理了一些数据之后，我们可以使用DSL查询进行一些搜索。

GET /sensor_rollup/_rollup_search
{
　　　"size": 0,
　　　"aggregations": {
　　　　　　"max_temperature": {
　　　　　　　　　"max": {
　　　　　　　　　　　　"field": "temperature"
　　　　　　　　　{}
　　　　　　{}
　　　{}
{}