MQTT+Kafka+KSQL+Tensorflow

本平台的构建笔记：https://blog.csdn.net/qq_41094332/article/details/106223143

[1] mqtt_client中含有汽车传感器模拟数据文件和MQTT客户端的构建代码。 mqtt_client.py实现了创建三个MQTT客户端，读取sensor_data-Copy1.csv文件，发送数据给MQTT Broker。

[2] DataProcess中含有获取Kafka中数据到本地，转换数据文件格式，数据处理构建模型预测的代码。

• 首先，使用kafka-consumer.py从Kafka中获取数据保存至data-sensor.txt文件当中。
• 然后，使用txt2csv.py将数据转换成.csv格式，其中若所传输的数据为非字典的格式，则使用#not dict。若所传输的数据为字典格式，则使用#dict。
• 最后，使用ipython-lstm-train.ipynb来进行数据分析，构建模型，预测数据。