Error with mqtt.to and mqtt.publish

InfluxDB 2
1

Hi,
I installed oss 2.11 and rabbitmq (mqtt enabled) with docker (influxdb:latest and influxdb:alpine).
I tried to use the experimental api
mqtt.to

but I have the following error

 runtime error @8:6-15:4: map: failed to evaluate map function: Dialer.Dial called on an error dependency

this is the query that I use

import "array"
import "experimental/mqtt"
array.from(rows: [
  {_measurement: "foo", _time: 2020-01-01T00:00:11Z, _field: "temp", _value: 1.0, loc: "eu"},
  {_measurement: "foo", _time: 2020-01-01T00:00:11Z, _field: "temp", _value: 2.0, loc: "us"},
])
  |> group(columns: ["_measurement", "field", "loc"])
  |> map(fn: (r) => ({ r with sent: 
  mqtt.publish(
  broker: "tcp:localhost:1883", 
  username: "rabbitmq",
  password: "rabbitmq",
  topic: "test", 
  message: "message") })
  )

and with mqtt.to the message is not published

import "array"
import "experimental/mqtt"
array.from(rows: [
  {_measurement: "foo", _time: 2020-01-01T00:00:11Z, _field: "temp", _value: 2.0, loc: "us"},
  {_measurement: "foo", _time: 2020-01-01T00:00:21Z, _field: "temp", _value: 1.0, loc: "us"},
  {_measurement: "foo", _time: 2020-01-01T00:00:31Z, _field: "temp", _value: 3.0, loc: "us"},
  {_measurement: "foo", _time: 2020-01-01T00:00:41Z, _field: "temp", _value: 4.0, loc: "us"},
])
  |> group(columns: ["_measurement", "field", "loc"])
  |> last()
  |> mqtt.to(
      broker: "tcp://localhost:1883", 
      topic: "test", 
      username:"rabbitmq", 
      password:"rabbitmq", 
      retain: true)

New Info
I tried influxdb on windows and the two method work.

Any ideas what I’m doing wrong here?
Thanks,
Benjamin

2

Same here, I run:

InfluxDB v2.2.0
Server: a2f8538
Frontend: cc65325

as an docker container on debian.

mqtt.publish() from package “experimental/mqtt” throws a “Dialer.Dial called on an error dependency”

I also tried the mqtt.to(), did not work as well.

Could it be a network-thing related with docker?

3

Exactly same here, I run:

InfluxDB v2.3.0
Server: 090f681
Frontend: a2bd1f3

run influxdb in docker container and check the network and have correct ping from inside container to mqtt-broker machine.

But have same above problems.