Как я могу отправить данные из influxdb в MQTT? ⇐ Python

[Anonymous]

Я новичок в influxdb и пытаюсь отправить данные из своей корзины в MQTT. Я уже пробовал это с помощью Telegraf, но это не сработало, поэтому я попробовал это с Flux и получил следующую ошибку.

Код: Выделить всё

could not execute task run: runtime error @9:8-22:6: map: failed to evaluate map function:  Dialer.Dial called on an error dependency

Это код, который я использую

Код: Выделить всё

import "experimental/mqtt"

option task = {name: "EnvioDataToMqtt", every: 1m, offset: 0m}

from(bucket: "recepcionDatos")
|> range(start: -1h)
|> filter(fn: (r) => r._measurement == "medida")
|> filter(fn: (r) => r._field == "value")
|> map(
fn: (r) =>
({r with sent:
mqtt.publish(
broker: "tcp://miservidor:18083",
topic: "dataInflux/prueba",
message: string(v: r._value),
clientid: "mqttx",
password: "02342321223113",
qos: 0,
username: "publicador",
),
}),
)

Если вы знаете другой способ отправки данных из influxdb в MQTT, я ценю ваше сотрудничество.
Найдите способ отправить мои данные influxdb в MQTT

Подробнее здесь: https://stackoverflow.com/questions/781 ... db-to-mqtt