带有物联网传感器的 Apache Nifi
Apache Nifi with IOT sensors
我是 Apache Nifi 的新手，我有一个用例，我需要解析和解码来自传感器的不同类型的消息，在 Hbase 中转换和加载数据，我所有的传感器每 10 分钟通过一个API 通过 post 请求，我现在所做的是 JAVA 的服务，该服务侦听特定端口并执行所有 ETL 数据流，知道如何使用 Apache Nifi对于这个用例？
您的用例听起来像是 NiFi 旨在处理的数据流类型，并且 NiFi 具有您需要的特定功能。 NiFi 有几个处理器可以帮助您实现 HTTP 网络服务。
ListenHTTP - 通过 POST.
HandleHttpRequest and HandleHttpResponse - 处理器的组合，以便根据流文件的处理更好地控制 HTTP 动词和响应代码。
NiFi 也有用于处理 HBase 的处理器，特别是 PutHBaseJSON 用于将 JSON 源数据插入 HBase。
除了这些特定的处理器之外，NiFi 还有许多用于调整和路由数据的处理器。我建议查看一些 Example Dataflow Templates，其中一些与您的案例直接相关：
我是 Apache Nifi 的新手，我有一个用例，我需要解析和解码来自传感器的不同类型的消息，在 Hbase 中转换和加载数据，我所有的传感器每 10 分钟通过一个API 通过 post 请求，我现在所做的是 JAVA 的服务，该服务侦听特定端口并执行所有 ETL 数据流，知道如何使用 Apache Nifi对于这个用例？
您的用例听起来像是 NiFi 旨在处理的数据流类型，并且 NiFi 具有您需要的特定功能。 NiFi 有几个处理器可以帮助您实现 HTTP 网络服务。
ListenHTTP - 通过 POST.
从 HTTP 简单接收到流文件
HandleHttpRequest and HandleHttpResponse - 处理器的组合，以便根据流文件的处理更好地控制 HTTP 动词和响应代码。
NiFi 也有用于处理 HBase 的处理器，特别是 PutHBaseJSON 用于将 JSON 源数据插入 HBase。
除了这些特定的处理器之外，NiFi 还有许多用于调整和路由数据的处理器。我建议查看一些 Example Dataflow Templates，其中一些与您的案例直接相关：