Apache Nifi with IOT sensors

Question

Im new to Apache Nifi , and I'm having a use case which i need to parse and decode different kind of messages from Sensors, transform and load the data in Hbase all my sensors send data every 10 minutes through an API via a post request, what I have done for now is a service with JAVA that listen on a specific port and do all the ETL dataflow, any idea how can I use Apache Nifi for this use case ?

Answer 1

Your use case sounds like the kind of data flow NiFi was built to handle, and NiFi has specific capabilities you will want. NiFi has several processors that can help you implement an HTTP web service.

• ListenHTTP - Simple receive from HTTP to a flowfile via POST.

• HandleHttpRequest and HandleHttpResponse - Combination of processors for better control of HTTP verbs and response codes based on the processing the flowfile.

NiFi also has processors for working with HBase, especially PutHBaseJSON for inserting JSON source data into HBase.

In addition to these specific processors, NiFi has many processors for shaping and routing your data. I recommend looking at some of the Example Dataflow Templates, some appear directly relevant to your case:

• Hello NiFi Web Service
• Fun with HBase