DBPRO IoT框架
物联网框架的开发,用于基于流的传感器数据分析。 DBPRO,柏林工业大学,2018年夏季学期。
(原始项目主页: : )
特征
该应用程序是基本的Flink-Kafka-InfluxDB工作流程的示例。
该程序执行以下步骤:
生成时间戳流并将数据附加到时间戳流(之前从传感器捕获)。
将流数据下沉到InfluxDB和Kafka主题
使用来自Kafka主题的数据(在另一个线程中),并将其也下沉到InfluxDB
在窗口中拆分无限流并计算“动态时间扭曲”距离,以便识别输入
通过HTTP请求将包含已识别字符的注释添加到Grafana
如何使用
只需在jobs / App.java中运行main()方法
为了实际获得任何可观察到的输出,您必须运行必要的实例(Kafka,InfluxDB,Grafana)并在相应的Java类中设置其地址。
建于
分布式流媒体平台
2021-12-11 15:53:47
853KB
Java
1