Aws elasticsearch input plugin

I am trying to import data from amazon elasticsearch service but, unlike amazon_es output plugin, there is no input plugin for amazon_es.
Using elasticsearch input plugin did not work .....
<
input {
amazon_es {
hosts => "https://******************.es.amazonaws.com"
index => "index_name"
query => '{ "_source": ["rowid","equipmentid"], "query": { "match_all": {} } }'
}
}

output {
stdout { codec => json_lines }
amazon_es {
action => "update"
doc_as_upsert => "true"
hosts => "https://********.es.amazonaws.com"
index => "index_name"
region => "
"
}
}
/>
Can anyone tell me how do I import the indexed data from amazon ES using logstash!!
Thanks in advance.......

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