Как вы получаете события?
Возможно, проще всего написать агента, который обновляет данные эластичного поиска на основе поля изменений.
Если вы используете Kafka для получения этих данных, вы можете просто написать это в потребителе Kafka, где вы получите все документы изasticsearch на основе измененного поля.Обновите результаты JSON, чтобы обновить новые данные, а затем обновите их обратно в Elasticsearch.
Попытка написания этого может быть не слишком большой.2-3 часа должно быть достаточно хорошо.