在这种情况下,如何将 mongoDB 的地理点数据转换为 Elasticsearch 7.x?

How can I convert geopoint data of mongoDB to Elasticsearch 7.x in this case?

我想将 mongodb 的地理数据实时转换为 elasticsearch 7.x。 我只知道应该使用 logstashlogstash-input-mongodb 插件。

请告诉我如何使 logstash.conf 参考下面的内容。

我有一个 mongodb 数据,例如:

(一些字段已加密。使用 GibberishAES.size(256) 和自定义字符串密钥。)

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

像 elasticsearch 数据:

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

我按照 mongodb oplog 发件人的方式解决了。

读取 mongodb 带有编码数据的 oplog,然后将其与解码一起发送到 logstash

如果有人找到解决方案,您可以在下面找到它:

Here : https://github.com/gnokoheat/oplog