在这种情况下,如何将 mongoDB 的地理点数据转换为 Elasticsearch 7.x?
How can I convert geopoint data of mongoDB to Elasticsearch 7.x in this case?
我想将 mongodb 的地理数据实时转换为 elasticsearch 7.x。
我只知道应该使用 logstash
的 logstash-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
。
如果有人找到解决方案,您可以在下面找到它:
我想将 mongodb 的地理数据实时转换为 elasticsearch 7.x。
我只知道应该使用 logstash
的 logstash-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
。
如果有人找到解决方案,您可以在下面找到它: