Support Questions
Find answers, ask questions, and share your expertise

How to consume data from MQTT and put into HBase ??

How to consume data from MQTT and put into HBase ??

Explorer

Hi,

I want to do below process in NiFi.

Step 1) ConsumeMQTT using mosquitto

Step 2) UpdateAttributes

Step 3) EvaluateJsonPath

Step 4) SplitJson - will produce the separate flowfile for each JSON array

Step 5) PutHbaseJSON --> Store the Json Array to HBASE

Hope you can now simulate the same

or

i'm having json array as

{"weather": [ {"id":"1","latitude":"13.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"}, {"id":"2","latitude":"14.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"}, {"id":"3","latitude":"15.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"}, {"id":"4","latitude":"16.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"}, {"id":"5","latitude":"17.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"} ] }

i'm trying to insert the same to hbase,

how to get the each array into hbase row.

Any help would be appreciated, Thanks !!