input {
http_poller {
urls => {
test => {
url => "http://myurl:80/test"
headers => {
Accept => "application/json"
}
}
}
schedule => { cron => "* * * * * UTC"}
codec => "json"
}
}
filter {
split {
field => "features"
}
}
output {
elasticsearch { hosts => ["myhost:9200"]
hosts => "myhost:9200"
codec => json
}
}
The data coming from api is
{
"type": "FeatureCollection",
"name": "logan_international_airport",
"crs": { "type": "name", "properties": { "name": "urn:ogc:def:crs:OGC:1.3:CRS84" } },
"features": [
{ "type": "Feature", "properties": { }, "geometry": { "type": "Point", "coordinates": [ -71.004550070725642, 42.364101185471185 ] } }
]
}