Сводка данных Elasticsearch

Задача агрегации - это периодическая задача, которая агрегирует данные из индексов, указанных в шаблоне индексов, и агрегирует их в новый индекс. В следующем примере мы создали индекс sensor, который имеет различные временные метки. Затем мы создали задачу агрегации rollup, которая периодически агрегирует данные из этих индексов.

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

При выполнении вышеуказанного кода мы получаем следующий результат-

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

Теперь добавим второй документ для других документов, и так далее.

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

Создание задачи агрегации

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"
　　　　　　　　　}
　　　　　　}
　　　}
}