文件名称：pytexas2015:我的照明演讲中的代码
文件大小：1.58MB
文件格式：ZIP
更新时间：2024-05-26 09:00:59
Ruby
这是我在PyTexas 2015照明演讲中的代码。 目前，docker部署已损坏，将很快修复。 情况是您经营一家玩具工厂。 每当玩具制作完成时，您的玩具制造机就会向数据收集API（Flask）发送一条消息。 数据收集API将消息放入名为“ sensor_temp”的Kafka主题中。 有一个Storm Spout消耗掉Kafka主题，反序列化消息，并将机器ID和机器温度发送给Storm Bolt。 螺栓会增加机器的生产数量并更新温度值，该温度值存储在MongoDB中。 一个非常简单的Meteor.js应用程序显示了计算机统计信息的仪表板。 玩具机消息数据是由Simulator / simulation.py生成的。 Parse.ly的Streamparse库用于用Python编写Apache Storm拓扑。