AWS 将数据从 IOT 流式传输到仪表板图

Question

我们需要从 1000 多个 IOT 设备（温度、压力、RPM 等总共 50 多个参数）中获取数据，并在没有太多处理的情况下将其显示在仪表板上（只需检查数字是否在范围内，否则会发出警报）但实时显示。 我审查并测试了许多 AWS 博客资源，例如 Kinesis Storm ClickStream App

但是我认为使用storm对于这样一个简单的任务来说太过分了。我要做的就是将数据保存在数据库中并显示图表（30 分钟、1 小时或自定义日期）。这是我目前想到的

Device -> AWS IOT(mqtt) -> Kinesis -> x -> dynamoDB -> Presenter Web APP (Laravel) 我可能必须使用 ClickStream 示例中提到的 Node.js 和 Redis Pub/Sub 来实时更新图表和警报。

我不想使用 Apache Storm，因为它是 Java 语言并且有学习曲线（并且找不到任何好的资源）。我知道我可以使用Lambda，但不确定它会如何扩展。

• 对解决方案有什么想法吗？
• AWS 没有适用于 PHP 的 KCL、替代方案或解决方案？因为我熟悉 PHP 而不是 Java。

Answer 1

Apache Storm 是一个分布式事件处理框架。在您的用例中，您似乎没有对事件执行任何计算。基本上，您的应用程序正在执行三个任务：

1. 将数据引入系统。
2. 读取周期 X 到 Y 的数据。
3. 在 Web 前端绘制图表。

摄取部分由 AWS-IOT 负责。您应该做的第一步是创建一个 SNS 主题并将所有 IoT 数据发布到 SNS 主题。在这里，您可以灵活地为每种数据类型创建一个主题（例如：温度、压力），并将消费者 SQS 队列附加到主题以将消息累积到其中。对于持久数据库，一个消费者可以是DynamoDB 表，另一个消费者可以是Lambda 函数，它执行某种过滤和数据转换并更新您的缓存。如果您需要对数据执行某种OLAP/Analytical 查询，请考虑使用Redshift 作为消费者之一。您必须了解具体要求才能最终确定您的设计。

Answer 2

在 IoT Core 中收到 mqtt 消息后，您是否考虑过将数据路由到 AWS IoT Analytics？通过这种方式，您可以摆脱 kinesis、Dynamo 和您的表示层的所有繁重的基础架构工作。

AWS IoT Analytics 为您提供摄取、数据准备和查询功能。将数据存储在已处理的数据存储中后，您可以使用 AWS QuickSight 对其进行可视化。