How to fetch realtime data from Elasticsearch

[#1]

Hi,

We were processing realtime data pushing every minute, i want to pull streaming data from elasticsearch like every second. can we give me suggestion. How could i collect streaming data from elasticsearch. After i collect the data from elasticsearch i need to apply machine intelligence with python support. Can please help me??

[#2]

You would likely need to checkout NiFi to query elastic search and Nifi ExecuteScript processor to run python against the results.