aze*_*lix 4 dataflow iot apache-nifi
我是Apache Nifi的新手,我有一个用例,我需要解析和解码来自传感器的不同类型的消息,转换并加载Hbase中的数据我的所有传感器每隔10分钟通过API通过一个请求发送数据,我现在所做的是一个JAVA服务,它监听特定端口并执行所有ETL数据流,任何想法如何使用Apache Nifi用于此用例？
您的用例听起来像是NiFi为处理而设计的数据流,而NiFi具有您想要的特定功能.NiFi有几个处理器可以帮助您实现HTTP Web服务.
ListenHTTP - 通过POST从HTTP轻松接收到流文件.
HandleHttpRequest和HandleHttpResponse - 处理器的组合,用于根据处理流文件更好地控制HTTP动词和响应代码.
NiFi还具有处理HBase的处理器,尤其是用于将JSON源数据插入HBase的PutHBaseJSON.
除了这些特定的处理器,NiFi还有许多用于整形和路由数据的处理器.我建议查看一些示例数据流模板,其中一些与您的案例直接相关:
| 归档时间： |
|
| 查看次数： |
323 次 |
| 最近记录： |