处理IOT事件流
本案例包含以下内容：
- 需求说明
- 代码实现-Scala
- 代码实现-Java
- 项目打包
- 项目部署执行
需求说明
假设一台机器上安装了传感器，我们希望从这些传感器收集数据，并每5分钟计算每个传感器的平均温度。
其架构如下图所示:
在这个场景中，我们假设传感器将信息发送给Kafka主题temp，信息为（传感器id、时间戳、温度）。这里假设以字符串的形式接收Kafka主题中的事件，部分数据如下所示。
sensortemp.csv：
sensor_1,1629943899014,51.087254019871054
sensor_9,1629943899014,70.44743245583899
sensor_7,1629943899014,65.53215956486392
sensor_0,1629943899014,53.210570822216546
sensor_8,1629943899014,93.12876931817556
sensor_3,1629943899014,57.55153052162809
sensor_2,1629943899014,107.61249366604993
sensor_5,1629943899014,92.02083744773739
sensor_4,162994389901 ......
......
抱歉，只有登录会员才可浏览！会员登录
