Агрегирование вложенных документов с безболезненным написанием сценариев

Question

ИСПОЛЬЗОВАНИЕ ЭЛАСТИЧЕСКОГО ПОИСКА 6.2 Итак, у меня есть глубоко вложенная структура документа, которая имеет все правильное отображение (вложенное, текстовое, ключевое слово и т. Д.).Пример документа выглядит следующим образом:

{
    "type": "Certain Type",
    "lineItems": [
        {
            "lineValue": 10,
            "events": [
                {
                    "name": "CREATED",
                    "timeStamp": "TIME VALUE"
                },
                {
                    "name": "ENDED",
                    "timeStamp": "TIME VALUE"
                }
            ]
        }
    ]
}

Я хочу узнать среднее время, необходимое для перехода всех строк из CREATED в ENDED.

Я создал следующий запрос

GET /_search
{
  "size": 0,
  "query": {
    "match": {
      "type": "Certain Type"
    }
  },
  "aggs": {
    "avg time": {
      "nested": {
        "path": "lineItems.events"
      },
      "aggs": {
        "avg time": {
          "avg": {
            "script": {
              "lang": "painless",
              "source": """
          long timeDiff = 0; 
          long fromTime = 0; 
          long toTime = 0; 
          if(doc['lineItems.events.name.keyword'] == "CREATED"){
            fromTime = doc['lineItems.events.timeValue'].value.getMillis();
          }
          else if(doc['lineItems.events.name.keyword'] == "ENDED"){
            toTime = doc['lineItems.events.timeValue'].value.getMillis();
          }
          timeDiff = toTime-fromTime;
          return (timeDiff)
          """
            }
          }
        }
      }
    }
  }
}

Результатом было то, что я получил 0 в качестве результата агрегации, что неверно.

Есть ли способ достичь этого?

Answer 1

Использовать документ [в сценарии с вложенными объектами не работает, так как вложенный новый документ для упругого поиска.

Вместо этого используйте params._source (https://www.elastic.co/guide/en/elasticsearch/reference/current/search-request-script-fields.html). Обратите внимание, что доступ к источнику будет очень медленным, если у вас много документов или вам нужно много раз запросить этот запрос, рассмотрите возможность добавления этого поля в основной документ.

Я считаю, что все значения существуют, добавьте, если необходимо проверить надежность, если это необходимо,

long toTime = 0; 
long fromTime = 0; 
timeDiff  = params['_source']['ENDED'] 
fromTime  = params['_source']['CREATED']
return (toTime - fromTime);