Как я могу преобразовать данные геопункта mongoDB в Elasticsearch 7.x в этом случае?

Question

Я хочу конвертировать геоданные mongodb вasticsearch 7.x в режиме реального времени. Я просто знаю, что следует использовать logstash-input-mongodb плагин из logstash.

Пожалуйста, дайте мне знать, как я могу сделать logstash.conf см. Ниже.

У меня есть данные mongodb как:

(некоторые поля были зашифрованы с использованием GibberishAES.size(256) с пользовательским строковым ключом.)

{
"id" : "john",
"age" : 26,
"geo" : "Cdzv5OoMXFw89do5NUorGkiRzAtnIpIw66kg=", // "57.233, 129.11"
"address" : "I6LoxOQPRPF7h4SLQo2g=" // "Rovert Hall"
}

Для эластичного поиска данных, таких как:

{
"id" : "john",
"age" : 26,
"geo" : "drm3bt", // geohash data of "57.233, 129.11"
"address" : "Rovert Hall"
}

Answer 1

Я решил это как сделал отправителя mongodb oplog.

прочитал оплог mongodb с данными кодирования и затем отправил его с расшифровкой в ​​logstash.

, если кто-то найдет решение, вы можетенайдите его ниже:

Здесь: https://github.com/gnokoheat/oplog