Обработка событий из Elasticsearch

Написать обработчик документов из Elasticsearch с применением сортировки и агрегации между документами.

Обогащение текущих данных из эластика новыми полями и запись их в отдельный индекс.

- есть индекс в ElasticSearch, в котором хранятся документы с определенным набором полей(такие как время, статус объекта, id объекта и пр)

- есть сборщик документов, который обрабатывает новые записи и отправляет их в  ElasticSearch.

Новые документы поступают на вход сборщика так же с определенным набором полей(среди которых время, статус объекта, id объекта и пр)

В результате обогащения данных, тех которые уже хранятся в эластике, и новых, поступивших через сборщик, нужно высчитать время нахождения объекта с id 123 в заданном статусе X.