流处理方案

Question

我们有几千个IoT设备，每秒钟都会把它们的温度传给我们。输入源可以是MQTT或JSON (如果需要的话也可以是队列)。

我们的目标是接近连续处理每一个设备的数据，并计算最后一个小时的平均值等。最后，我们希望它发送一个通知，如果它超过一定的水平。

有哪些好的替代流处理工具是灵活的和可伸缩的？卡夫卡是该走的路，还是有其他选择？

Answer 1

您看过IBM的IoT基金会吗？

https://www.ibm.com/cloud/internet-of-things

IBM还提供了基于kafka的事件流。https://www.ibm.com/cloud/event-streams

Answer 2

你可以使用一个叫做Quix的新平台。https://quix.ai/

他们有一个MQTT连接器- hiveMQ我相信。它们还为空闲或twillio提供了连接器来发送通知。你只需要为你想要的任何计算写出你的逻辑。虽然他们确实提供了一些预先建立的改造，如滚动，平均等。

我相信它是在卡夫卡上运行的，但是你不需要知道所有这些设置的细节。

我在那里做了一些类似的东西，而且效果很好。