mongodb - 在这种情况下，如何将mongoDB的地理位置数据转换为Elasticsearch 7.x？

Question

我想将mongodb的地理数据实时转换为elasticsearch7.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"
}

像这样的Elasticsearch数据:

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

Answer 1

我将其作为mongodb oplog发件人解决了。

使用编码数据读取mongodb oplog，然后将其解码后发送到logstash。

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

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