- BunkerM: recreated with port 1883 (external) -> 1900 (internal) - BunkerM: disabled dynsec plugin, using password_file auth (bunker/bunker) - Simulator: ENABLE_BUNKER=1, BUNKERM_PORT=1900 - Telegraf: reactivated BunkerM consumer on port 1900 - Telegraf: recreated container (3 MQTT consumers connected) - Grafana: dashboard v4 with corrected Flux queries - Grafana: datasource fixed (bucket=smartcity, token=my-super-token) Verified: - Simulator publishes to EMQX ✅, Mosquitto ✅, BunkerM ✅ - Telegraf receives from all 3 brokers ✅ - InfluxDB has data from all brokers ✅ - Grafana dashboard displays data ✅
68 lines
1.3 KiB
Plaintext
68 lines
1.3 KiB
Plaintext
[global_tags]
|
|
|
|
[agent]
|
|
interval = "10s"
|
|
round_interval = true
|
|
metric_batch_size = 1000
|
|
metric_buffer_limit = 10000
|
|
collection_jitter = "0s"
|
|
flush_interval = "10s"
|
|
flush_jitter = "0s"
|
|
|
|
# Input: MQTT Consumer - EMQX
|
|
[[inputs.mqtt_consumer]]
|
|
servers = ["tcp://emqx_emqx_1:1883"]
|
|
topics = [
|
|
"airquality/#",
|
|
"traffic/#",
|
|
"parking/#",
|
|
"noise/#",
|
|
"weather/#",
|
|
"light/#",
|
|
"sensor/#",
|
|
"smartcity/#"
|
|
]
|
|
data_format = "json"
|
|
qos = 0
|
|
|
|
# Input: MQTT Consumer - Mosquitto
|
|
[[inputs.mqtt_consumer]]
|
|
servers = ["tcp://smart-city-digital-twin-martinique-mosquitto-1:1883"]
|
|
topics = [
|
|
"airquality/#",
|
|
"traffic/#",
|
|
"parking/#",
|
|
"noise/#",
|
|
"weather/#",
|
|
"light/#",
|
|
"sensor/#",
|
|
"smartcity/#"
|
|
]
|
|
data_format = "json"
|
|
qos = 0
|
|
|
|
# Input: MQTT Consumer - BunkerM
|
|
[[inputs.mqtt_consumer]]
|
|
servers = ["tcp://bunkerm-bunkerm-1:1900"]
|
|
topics = [
|
|
"airquality/#",
|
|
"traffic/#",
|
|
"parking/#",
|
|
"noise/#",
|
|
"weather/#",
|
|
"light/#",
|
|
"sensor/#",
|
|
"smartcity/#"
|
|
]
|
|
data_format = "json"
|
|
qos = 0
|
|
username = "bunker"
|
|
password = "bunker"
|
|
|
|
# Output: InfluxDB v2
|
|
[[outputs.influxdb_v2]]
|
|
urls = ["http://smart-city-influxdb:8086"]
|
|
token = "my-super-token"
|
|
organization = "digitribe"
|
|
bucket = "smartcity"
|