Бюджет:
5000 руб
Обогащение текущих данных из эластика новыми полями и запись их в отдельный индекс.
- есть индекс в ElasticSearch, в котором хранятся документы с определенным набором полей(такие как время, статус объекта, id объекта и пр)
- есть сборщик документов, который обрабатывает новые записи и отправляет их в ElasticSearch.
Новые документы поступают на вход сборщика так же с определенным набором полей(среди которых время, статус объекта, id объекта и пр)
В результате обогащения данных, тех которые уже хранятся в эластике, и новых, поступивших через сборщик, нужно высчитать время нахождения объекта с id 123 в заданном статусе X.
Интересует разработка обработчика на языке Python