如何将 MQTT 数据存储到 QuestDB？答案

【问题标题】：How can I store MQTT data into QuestDB?如何将 MQTT 数据存储到 QuestDB？
【发布时间】：2021-08-30 12:14:22
【问题描述】：

我正在构建一个使用 Mosquitto 代理 IoT 传感器数据的解决方案。物联网传感器正在发布到 MQTT 主题，我想将有效负载数据存储在 QuestDB 中进行分析，有哪些选项可以将其用作存储。

【问题讨论】：

【解决方案1】：

将 MQTT 主题中的数据提取到 QuestDB 中的最简单、最快的方法之一是使用 Telegraf 通过 InfluxDB 线路协议流式传输记录。 Telegraf 的配置如下所示：

# Configuration for Telegraf agent
[agent]
  ## Default data collection interval for all inputs
  interval = "5s"
  hostname = "qdb"

[[outputs.socket_writer]]
  # Write metrics to a local QuestDB instance over TCP
  address = "tcp://127.0.0.1:9009"

[[inputs.mqtt_consumer]]
  ## The MQTT broker
  servers = ["tcp://127.0.0.1:1883"]

  ## Topics that will be subscribed to.
  topics = [
    "telegraf/host01/cpu",
    "telegraf/+/mem",
    "sensors/#",
  ]

有关 Telegraf 的 MQTT 消费者的更多信息，请参阅plugin's README which has usage info（与 SSL 等一起使用）

另外，我要指出的是，有一些工具，例如 this example stack，它具有 MQTT 代理、Telegraf 和 QuestDB 定义为网络服务。

【讨论】：