Telegraf Error running agent: starting input inputs.mqtt_consumer: network Error: dial tcp 127.0.0.1:1883: connect: connection refused

Question

我有一个通过 mqtt 协议 (Hivemq) 发送数据的 python 脚本，我想通过电报将数据发送到 influx db。我有 7 个（非空）变量的 json 文件，我希望它们全部放在一个桶中，这样每个变量都有自己的图形，稍后我想在 grafana 中将它们可视化。问题是脚本会每小时运行一次，所以我需要电报等待它接收数据。

此刻，我被困在这里：

` 2023-0302T16:48:50Z 我！启动 Telegraf 1.25.3

2023-0302T16:48:50Z 我！可用插件：213 个输入、9 个聚合器、26 个处理器、21 个解析器、57 个输出、2 个秘密存储

2023-0302T16:48:50Z 我！加载的输入：mqtt_consumer

2023-0302T16:48:50Z 我！加载聚合器：

2023-0302T16:48:50Z 我！加载的处理器：

2023-0302T16:48:50Z 我！加载的秘密库：

2023-0302T16:48:50Z 我！加载的输出：influxdb_v2

2023-0302T16:48:50Z 我！启用标签：host=Daniels-MBP.home

2023-0302T16:48:50Z 我！ [agent] 配置：间隔：10s，安静：false，主机名：“Daniels-MBP.home”，刷新间隔：10s

2023-0302T16:48:50Z 电子！ [telegraf] 运行代理时出错：启动输入 inputs.mqtt_consumer：网络错误：拨打 tcp 127.0.0.1:1883：连接：连接被拒绝`

我的电报会议是这样的：

`[[inputs.mqtt_consumer]]

  servers = ["broker.hivemq.com"]

  topics = ["DP_test"] `

python脚本：

import json
import paho.mqtt.publish as publish

x = 12.1
y = 2
z = 3
a = 55
b = 9
c = 2.5
d = 12.4

data = {
    "x": "xd",
    "y": "yf",
    "z": "zd",
    "a": "ass",
    "b": "sb",
    "c": "sc",
    "d": "da"
}

json_data = json.dumps(data)


topic = "DP_test"
broker = "broker.hivemq.com"
publish.single(topic, json_data, hostname=broker)