Created 06-06-2017 11:00 AM
Using Nifi, it's possible to make this kind of request without destroy the original flowfile ?
curl -XPOST "http://localhost:9200/my_index/_search" -H 'Content-Type: application/json' -d' { "query": { "bool": { "must": { "term": { "user.screen_name": "userName" } }, "filter": { "range": { "date": { "gte": "now-3M", "lte": "now", "format": "EEE MMM dd HH:mm:ss Z YYYY" } } } } }, "aggs": { "sum_RTs": { "sum": { "field": "retweetCount" } } } }'
Thanks so much
Created 06-06-2017 07:47 PM
It is possible with a custom Processor, the out of the box processors supports query based on flowfile: https://community.hortonworks.com/questions/42727/using-invokehttp-flowfile-and-replacetext-from-nif...