I'm trying to create a web service dataflow using Apache NiFi. I've setup the request and response http processors however I can't seem to figure out how to update the flowfile from the request processor with data from say... another connection. Can someone please let me know how I can achieve this behaviour?
0
votes
1 Answers
4
votes
You would need a processor that can take an incoming flow file and replace the contents with results. One example would be the ExecuteSQL processor which will replace the contents of an incoming flow file with the results of querying the database (in Avro format). So a flow of HandleHttpRequest -> ExecuteSQL -> HandleHttpResponse.
One problem is that many processors that retrieve data from somewhere are not meant to take incoming flow files. For example, processors like GetSolr, GetHBase, and many other Get processors are meant to be source processors on their own.
