childe / gohangout

使用 golang 模仿的 Logstash。用于消费 Kafka 数据,处理后写入 ES、Clickhouse 等。
MIT License
1.01k stars 234 forks source link

unknownType main.Coordinates 写了一个插件解析geoip2 mmdb数据库,stdout 输出正常,es 确写入报错 #241

Closed zcola closed 5 months ago

zcola commented 5 months ago

写了一个插件解析geoip2 mmdb数据库,stdout 输出正常,es 确写入报错

"ip_geo":{"city_name":"Maianbar","country_name":"Australia","isp":"SingTel Optus Pty Ltd","location":{"lon":151.1241,"lat":-34.0837},"region_name":"New South Wales","timezone":"Australia/Sydney"}

2292 elasticsearch_output.go:77] could marshal event(map[@timestamp:2024-03-06 17:55:36 +0800 CST

6:5] ip_geo:map[city_name:Maianbar country_name:Australia isp:SingTel Optus Pty Ltd location:{151.1241 -34.0837} region_name:New South Wales timezone:Australia/Sydney] loc

4.4.0]):unknownType main.Coordinates

怎么给我 "location":{"lon":151.1241,"lat":-34.0837} 精简成 location:{151.1241 -34.0837}

zcola commented 5 months ago

我定义的数据结构问题,忽略

zcola commented 5 months ago

https://github.com/zcola/gohangout-filter-geoip2

能用了哈哈