导入地理空间数据
logstash怎么把csv文件中的x列和y列编程geo_shape的point导入es集群中
Logstash • zhangleikxyt 发表了文章 • 0 个评论 • 3313 次浏览 • 2018-10-25 09:57
最近开始研究elasticsearch例如添加geo_hash类型的坐标是这样的
filter {
mutate {
add_field => {"location" => "%{y},%{x}"} --把x,y变为location属性,类型为geohash
remove_field => ["@version","@timestamp","qsdwmc","gldwmc","bz","sjly","rksj","guid","clsj"," czsj","x","y","mjzrq","gxsj"]
}
}
但是我看了官网上的例子:
PUT /example
{
"mappings": {
"doc": {
"properties": {
"location": {
"type": "geo_shape"
}
}
}
}
}
POST /example/doc?refresh
{
"name": "Wind & Wetter, Berlin, Germany",
"location": {
"type": "point",
"coordinates": [13.400544, 52.530286]
}
}
请问各位大佬通过logstash怎么添加这样子的location的属性,type为point,然后还有个coordinates数组
logstash怎么把csv文件中的x列和y列编程geo_shape的point导入es集群中
Logstash • zhangleikxyt 发表了文章 • 0 个评论 • 3313 次浏览 • 2018-10-25 09:57
最近开始研究elasticsearch例如添加geo_hash类型的坐标是这样的
filter {
mutate {
add_field => {"location" => "%{y},%{x}"} --把x,y变为location属性,类型为geohash
remove_field => ["@version","@timestamp","qsdwmc","gldwmc","bz","sjly","rksj","guid","clsj"," czsj","x","y","mjzrq","gxsj"]
}
}
但是我看了官网上的例子:
PUT /example
{
"mappings": {
"doc": {
"properties": {
"location": {
"type": "geo_shape"
}
}
}
}
}
POST /example/doc?refresh
{
"name": "Wind & Wetter, Berlin, Germany",
"location": {
"type": "point",
"coordinates": [13.400544, 52.530286]
}
}
请问各位大佬通过logstash怎么添加这样子的location的属性,type为point,然后还有个coordinates数组