flink-kafka-influx-grafana-framework:该应用程序是基本的Flink-Kafka-InfluxDB工作流程的示例-源码

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