Mqtt публикует сообщения на localhost. А телеграф отслеживает localhost, но не может отправить его на приток. что может быть не так?
Здесь, если подключение telegraf к infxdb успешно, потому что, когда я перезапускаю telegraf, он создает базу данных, которую я упомянул в файле конфигурации. Но сообщения, которые публикуются mqtt, не принимаются телеграфом. Я даже пытался поместить его в файл, но он пуст. так что-то не так.
import paho.mqtt.client as mqtt
from influxdb import InfluxDBClient
import json
influxclient = InfluxDBClient(host='localhost', port=8086)
# This is the Publisher
dict_msg={"temperature":"20.5"}
msg = json.dumps(dict_msg)
MQTT_HOST = "127.0.0.1"
MQTT_PORT = 1883
MQTT_KEEPALIVE_INTERVAL = 45
MQTT_TOPIC = "sensors"
count = 0
# Define on_publish event function
def on_publish(client, userdata, mid):
print("Message Published..")
# Initiate MQTT Client
mqttc = mqtt.Client()
mqttc.on_publish = on_publish
# Connect with MQTT Broker
mqttc.connect(MQTT_HOST, MQTT_PORT, MQTT_KEEPALIVE_INTERVAL)
x = 0
while x <= 100000:
# Publish message to MQTT Broker
mqttc.publish(MQTT_TOPIC,msg)
# influx_line_protocol = ("published,counts" = count)
# print(count)
x += 1
mqttc.loop(30)
# Disconnect from MQTT_Broker
mqttc.disconnect()`
Вот конфиг телеграфа и мой код издателя mqtt. Я хочу, чтобы мои опубликованные сообщения были сохранены в файле infxdb.
Телеграф говорит, что подключен, как указано ниже, но не отправляет никаких сообщений от издателя. замерзает здесь
2019-02-07T11:02:18Z I! [agent] Config: Interval:10s, Quiet:false, Hostname:"shekhar-Inspiron-3441", Flush Interval:10s
2019-02-07T11:02:18Z I! [inputs.mqtt_consumer] Connected [tcp://127.0.0.1:1883]
и конфиг mqtt имеет
[[inputs.mqtt_consumer]]
## MQTT broker URLs to be used. The format should be
scheme://host:port,
## schema can be tcp, ssl, or ws.
servers = ["tcp://127.0.0.1:1883"]
## Topics to subscribe to
topics = [
"telegraf/sensors/#",
]
data_format = "influx"
пробовал с JSON также. неудачно.
любая помощь приветствуется.
1 ответ
Были 2 вещи неправильно:
- Вы не сконфигурировали свой вывод InfluxDB в telegraf.conf
- Ваше показание температуры - это строка, а не тип числа
Я предоставил вам рабочий пример использования плагина MQTT:
https://github.com/rawkode/influxdb-examples/tree/master/telegraf/mqtt
PS: кросс-пост от Шекхар. Копирование моего ответа здесь, с демонстрацией; в случае, если кто-то еще сталкивается с подобной проблемой.