Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

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

Highlighted

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

New Contributor

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 !!