Schedule job for elasticsearch

Hi Team

i would like to setup schedule job for elasticsearch input plugin? how to do it?

There's nothing built-in for this (see but you can always fire up Logstash via crontab.

I have a customized plugin to do that
I can do a fork in github if you want to build on it

So it won't be lost.. :
It's inspired from logstash input jdbc plugin

configuration example :

elasticsearch {
hosts => "forge.local"
record_last_run => true
tracking_field => "computation"
last_run_metadata_path => "/etc/logstash/states/my.state"
query => '{"query":{"query_string":{"query":
"+_type:activity +computation:>=&elastic_last_value +computation:<now-1h"}},
"sort": ["computation" ]}'
size => 1000
index => "index_201710,index_201711"
schedule => "* * * * *"
legacy_scrolling => true

legacy_scrolling is to scroll data from ES1.x server

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.