Средняя совокупность сегментов, включая 0 значений
Я использую ES для получения статистики за день в случае, когда у меня нет входных данных на каждый день, но где отсутствующие данные также являются информацией как таковой (в моем случае я измеряю активность). Чтобы решить эту задачу, я использую усредненную совокупность сегментов и устанавливаю min_doc_count равным 0, чтобы иметь значение, даже если мои данные отсутствуют. Мой запрос следующий:
query = {
"size": 0,
"query": {
"bool" : {
"should" :{
"match" : { "LogEntryType" : "LogEntry" }
},
"must" : {
'match' : {'Id' : id}
}
}
},
"aggs": {
"actions_per_day": {
"date_histogram": {
"field": "CreationTime",
"interval": "day",
"min_doc_count" : 0
},
"aggs": {
"amount": {
"value_count": {
"field": "CreationTime"
}
}
}
},
"avg_daily_action": {
"avg_bucket": {
"buckets_path": "actions_per_day>amount"
}
}
}
}
es1.search(index=indx1, body=query)
И он возвращает объекты со значением, установленным на 0, как вы можете видеть в следующем фрагменте ответа:
{'took': 1,
'timed_out': False,
'_shards': {'total': 2, 'successful': 2, 'failed': 0},
'hits': {'total': 4321, 'max_score': 0.0, 'hits': []},
'aggregations': {'actions_per_day': {'buckets': [
{'key_as_string': '2018-07-13T00:00:00.000Z',
'key': 1531440000000,
'doc_count': 631,
'amount': {'value': 631}},
{'key_as_string': '2018-07-14T00:00:00.000Z',
'key': 1531526400000,
'doc_count': 0,
'amount': {'value': 0}}...
Но моя проблема в том, что для среднего ежедневного действия вычисление не учитывает значения 0, оно возвращает:
...'avg_daily_action': {'value': 432.1}
Что соответствует среднему, не принимая во внимание те дни, когда не было предоставлено никаких данных. Я обнаружил эту проблему, где упоминается, что я должен использовать "отсутствующий" параметр, однако я думаю, что он предназначен для извлечения элементов с 0, и у меня их уже есть. Любые подсказки о том, как принять их во внимание?
1 ответ
Оказывается, я был почти там. Для учета значений 0 необходимо использовать параметр gap_policy в агрегации среднего сегмента. Средняя часть ковша теперь становится
"avg_daily_operations": {
"avg_bucket": {
"buckets_path": "modifications_per_day>amount",
"gap_policy" : "insert_zeros"
}
}
Значение по умолчанию установлено, чтобы пропустить, и изменение его решает проблему.