参考https://kafka.apachecn.org/quickstart.html 启动zookeeper服务器和kafka服务器,配置本地端口
pip3 install kafka-python
python producer.py
每秒生成一个1至1000的随机点,key为timestamp
后期会用kafka输出到flink进行进一步聚合计算,并将结果导入Redis中进行持久化操作。
利用Ray分布式计算对Redis中的结果进行机器学习拟合计算,输出各项指标。(练手项目)
参考https://kafka.apachecn.org/quickstart.html 启动zookeeper服务器和kafka服务器,配置本地端口
pip3 install kafka-python
python producer.py
每秒生成一个1至1000的随机点,key为timestamp
后期会用kafka输出到flink进行进一步聚合计算,并将结果导入Redis中进行持久化操作。
利用Ray分布式计算对Redis中的结果进行机器学习拟合计算,输出各项指标。(练手项目)