Как получить часы между минимальной и максимальной датой в Elasticsearch Aggregation? - PullRequest
0 голосов
/ 12 февраля 2020

Как рассчитать часы между максимальными и минимальными датами (тот же уровень дерева максимальных и минимальных значений) в Elasticsearch?

Мой запрос: -

{
    "size": 0,
    "query": {
        "bool": {
            "must": []
        }
    },
    "aggs": {
        "group_by_areaId": {
            "terms": {
                "size": 100000,
                "field": "areaId.keyword"
            },
            "aggs": {
                "4m": {
                    "date_histogram": {
                        "field": "timestamp",
                        "format": "yyyy-MM-dd'T'HH:mm:ssZZ",
                        "interval": "4m",
                        "order": {
                            "_key": "asc"
                        }
                    },
                    "aggs": {
                        "maxDate": {
                            "max": {
                                "field": "timestamp"
                            }
                        },
                        "minDate": {
                            "min": {
                                "field": "timestamp"
                            }
                        }
                    }
                }
            }
        }
    }
}

И ответ (короткий) as,

"aggregations": {
        "group_by_areaId": {
            "doc_count_error_upper_bound": 0,
            "sum_other_doc_count": 0,
            "buckets": [
                {
                    "key": "key1",
                    "doc_count": 15,
                    "4m": {
                        "buckets": [
                            {
                                "key_as_string": "2020-02-12T06:08:00+0000",
                                "key": 1581487680000,
                                "doc_count": 3,
                                "minDate": {
                                    "value": 1.581487847E12,
                                    "value_as_string": "2020-02-12T06:10:47Z"
                                },
                                "maxDate": {
                                    "value": 1.58148791E12,
                                    "value_as_string": "2020-02-12T06:11:50Z"
                                },                             
                                 *// Need hours between maxDate and minDate here
                                 //{
                                 //    "hours" : "0.0175" (maxDate-minDate)
                                 //}*
                            }
                        ]
                    }
                }
            ]
        }
    }

Кто-нибудь, пожалуйста, помогите мне найти решение? Заранее спасибо.

1 Ответ

2 голосов
/ 12 февраля 2020

Вы можете использовать bucket_script конвейерную агрегацию , чтобы вычислить разницу между min и max для каждого сегмента.

Просто добавьте следующее на том же уровне, что и minDate и maxDate:

            "hours": {
                "bucket_script": {
                    "buckets_path": {
                      "min": "minDate",
                      "max": "maxDate"
                    },
                    "script": "(params.max - params.min) / 3600000"
                }
            }

Для приведенных выше образцов данных результат в этом случае будет 0,0175 (т.е. примерно 1 минут)

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...