物联网（IoT）描述了嵌入传感器，软件和其他技术的物理对象（“物”）网络，目的是通过 Internet 与其他设备和系统进行数据连接和交换。物联网是一张很大的网，它比互联网更大，更为广泛。随着物联网的发展，大量的数据可以上传到 Elasticsearch 中，并作为理想的存储空间。Elasticsearch 可以存储 PB 级的数据并实时分析数据。Elasticsearch 可以用甚至运用机器学习对数据进行异常分析，并作出异常报警。 MQTT 协议被广泛使用于物联网中。使用 MQTT 输入读取用于小型和移动设备的，使用轻量级消息传递协议传输的数据，该协议针对高延迟或不可靠的网络进行了优化。那么我们该如果把 MQTT 的数据传入到 Elasticsearch 中呢？

在 Elastic Stack 中的 filebeat 已经对这种协议进行了支持。我们可以使用 MQTT input 来作为 filebeat 的输入。此输入连接到 MQTT 代理，订阅选定的主题并将数据解析为公共消息行。 一切都发生在行过滤，多行和 JSON 解码之前，因此此输入可以与这些设置结合使用。
 
详细阅读，请参阅 https://elasticstack.blog.csdn ... 77596