Как агрегироваться по определённому полю в массиве массивов? (с дальнейшей визуализацией)

Elastic In Your Native Tongue Вопросы на русском языке
1

Есть индекс, каждый элемент которого содержит следующую информацию:

  1. общая информация о прохождении туториала игры
  2. несколько массивов с информацией о прохождении каждого из этапов туториала

Один элемент выглядит так:
id:206 duration:35 created_at:Oct 23, 2019 @ 16:55:11.000 build:0.2.3.889 player_id:450 is_tester:true stages:{ "id": 1475, "stage_id": 0, "duration": 11, "completed": true }, { "id": 1476, "stage_id": 1, "duration": 6, "completed": true }, { "id": 1477, "stage_id": 2, "duration": 2, "completed": true }, { "id": 1478, "stage_id": 3, "duration": 2, "completed": true }, { "id": 1479, "stage_id": 4, "duration": 3, "completed": true }, { "id": 1480, "stage_id": 5, "duration": 3, "completed": true }, { "id": 1481, "stage_id": 6, "duration": 4, "completed": true } _id:Hdrq-G0BSOdvtuXl5PqJ _type:data _index:tutorial_data _score: -

(Или то же самое на JSON) 
{
  "_index": "tutorial_data",
  "_type": "data",
  "_id": "Sdoi-W0BSOdvtuXlEfvi",
  "_version": 1,
  "_score": null,
  "_source": {
    "id": 207,
    "duration": 28,
    "created_at": "2019-10-23T14:26:28.000+00:00",
    "build": "0.2.3.889",
    "player_id": 450,
    "is_tester": true,
    "stages": [
      {
        "id": 1482,
        "stage_id": 0,
        "duration": 4,
        "completed": true
      },
      {
        "id": 1483,
        "stage_id": 1,
        "duration": 5,
        "completed": true
      },
      {
        "id": 1484,
        "stage_id": 2,
        "duration": 2,
        "completed": true
      },
      {
        "id": 1485,
        "stage_id": 3,
        "duration": 7,
        "completed": true
      },
      {
        "id": 1486,
        "stage_id": 4,
        "duration": 3,
        "completed": true
      },
      {
        "id": 1487,
        "stage_id": 5,
        "duration": 6,
        "completed": true
      }
    ]
  },
  "fields": {
    "created_at": [
      "2019-10-23T14:26:28.000Z"
    ]
  },
  "sort": [
    1571840788000
  ]
}

Задача - визуализировать (пока в виде таблицы, но потом и в виде диаграммы) среднее время прохождения каждого из этапов туториала.
Когда я агрегируюсь по "stages.duration" (не по просто "duration" !) и далее разбиваю строки таблицы по "stages.stage_id", то высчитывается среднее время на основе данных со ВСЕХ этапов сессий, которые содержат данный stages.stages_id (например, сессии с этапом №2).

Так выглядит запрос 
{
  "aggs": {
"3": {
  "terms": {
    "field": "stages.stage_id",
    "order": {
      "_key": "desc"
    },
    "size": 9
  },
  "aggs": {
    "1": {
      "avg": {
        "field": "stages.duration"
      }
    }
  }
}
  },
  "size": 0,
  "_source": {
"excludes": []
  },
  "stored_fields": [
"*"
  ],
  "script_fields": {},
  "docvalue_fields": [
{
  "field": "created_at",
  "format": "date_time"
}
  ],
  "query": {
"bool": {
  "must": [
    {
      "range": {
        "created_at": {
          "format": "strict_date_optional_time",
          "gte": "2019-10-11T20:30:00.000Z",
          "lte": "2019-10-24T08:10:54.837Z"
        }
      }
    }
  ],
  "filter": [
    {
      "match_all": {}
    }
  ],
  "should": [],
  "must_not": []
}
  }
}
Так выглядит ответ 
{
  "took": 4,
  "timed_out": false,
  "_shards": {
    "total": 1,
    "successful": 1,
    "skipped": 0,
    "failed": 0
  },
  "hits": {
    "total": 203,
    "max_score": null,
    "hits": []
  },
  "aggregations": {
    "3": {
      "doc_count_error_upper_bound": 0,
      "sum_other_doc_count": 0,
      "buckets": [
        {
          "1": {
            "value": 8.141304347826088
          },
          "key": 8,
          "doc_count": 147
        },
        {
          "1": {
            "value": 8.164634146341463
          },
          "key": 7,
          "doc_count": 150
        },
        {
          "1": {
            "value": 8.108289768483944
          },
          "key": 6,
          "doc_count": 154
        },
        {
          "1": {
            "value": 8.036390101892286
          },
          "key": 5,
          "doc_count": 160
        },
        {
          "1": {
            "value": 8.02030456852792
          },
          "key": 4,
          "doc_count": 161
        },
        {
          "1": {
            "value": 7.935256861365236
          },
          "key": 3,
          "doc_count": 172
        },
        {
          "1": {
            "value": 8.189151599443672
          },
          "key": 2,
          "doc_count": 179
        },
        {
          "1": {
            "value": 8.189151599443672
          },
          "key": 1,
          "doc_count": 179
        },
        {
          "1": {
            "value": 9.656871218668972
          },
          "key": 0,
          "doc_count": 160
        }
      ]
    }
  },
  "status": 200
}

Как в итоге можно "выцепить" информацию по каждому из этапов туториала в отдельности?

2

В elasticsearch это делается с помощью объектов с типом nested. К сожалению, kibana c такими объектами не работает.

Если с ними надо работать в Kibana, то надо каждый этап индексировать, как отдельную запись, либо создавать отдельные поля для каждого этапа. То есть duration_1, completed_1, duration_2, completed_2 и т.д.

3

Спасибо!

4

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.