Grafana: различия между версиями
(не показаны 34 промежуточные версии 4 участников) | |||
Строка 1: | Строка 1: | ||
{{ | {{Draft}} | ||
== Введение == | == Введение == | ||
'''Grafana''' — мультиплатформенное веб-приложение с открытым кодом, отображающее данные в виде графиков, диаграмм, индикаторов, а также другими способами. Конечные пользователи могут создавать сложные панели мониторинга с помощью интерактивного конструктора запросов. Умеет отправлять оповещения (alert). Расширяется с помощью системы плагинов. | '''Grafana''' — мультиплатформенное веб-приложение с открытым кодом, отображающее данные в виде графиков, диаграмм, индикаторов, а также другими способами. Конечные пользователи могут создавать сложные панели мониторинга с помощью интерактивного конструктора запросов. Умеет отправлять оповещения (alert). Расширяется с помощью системы плагинов. | ||
Строка 10: | Строка 9: | ||
== Grafana Cloud == | == Grafana Cloud == | ||
[[Image: Grafana Cloud.png |600px|thumb|right| Схема обмена данными при использовании Grafana Cloud]] | [[Image: Grafana Cloud.png |600px|thumb|right| Схема обмена данными при использовании Grafana Cloud]] | ||
В состав Grafana Cloud уже есть база данных, поэтому | В состав Grafana Cloud уже есть база данных, поэтому устанавливать и настраивать базу данных не нужно. | ||
Схема работы: | Схема работы: | ||
Строка 22: | Строка 21: | ||
# Найдите карточку '''Prometheus''' и нажмите кнопку '''Send Metrics'''. | # Найдите карточку '''Prometheus''' и нажмите кнопку '''Send Metrics'''. | ||
# На открывшейся странице найдите и сохраните данные из полей: | # На открывшейся странице найдите и сохраните данные из полей: | ||
#* | #* ''Remote Write Endpoint'' | ||
#* ''Username / Instance ID'' | |||
#* Username / Instance ID | #* ''Password / API Key'', для генерации ключа нажмите '''Generate now'''. | ||
#* Password / API Key, для генерации ключа нажмите '''Generate now'''. | |||
<gallery widths=322px heights=200px perrow=2> | <gallery widths=322px heights=200px perrow=2> | ||
Строка 35: | Строка 33: | ||
Telegraf — это сервис, который устанавливается на контроллер Wiren Board и отправляет данные в базу данных Grafana Cloud. Для выполнения команд, откройте консоль контроллера по [[SSH]]. | Telegraf — это сервис, который устанавливается на контроллер Wiren Board и отправляет данные в базу данных Grafana Cloud. Для выполнения команд, откройте консоль контроллера по [[SSH]]. | ||
Установка: | Установка Telegraf: | ||
# Установите дополнительные пакеты: | # Установите дополнительные пакеты: | ||
#:<syntaxhighlight lang="bash"> | #:<syntaxhighlight lang="bash"> | ||
apt update && apt install apt-transport-https | apt update && apt install apt-transport-https | ||
</syntaxhighlight> | </syntaxhighlight> | ||
# Добавьте ключ репозитория | # Добавьте ключ репозитория telegraf: | ||
#:<syntaxhighlight lang="bash"> | #:<syntaxhighlight lang="bash"> | ||
wget -qO- https://repos.influxdata.com/ | wget -qO- https://repos.influxdata.com/influxdb.key | apt-key add - | ||
</syntaxhighlight> | </syntaxhighlight> | ||
# Добавьте в список apt-репозиториев ссылку на репозиторий telegraf: | # Добавьте в список apt-репозиториев ссылку на репозиторий telegraf: | ||
Строка 49: | Строка 46: | ||
source /etc/os-release | source /etc/os-release | ||
</syntaxhighlight> | </syntaxhighlight> | ||
#* Здесь <code> | #* Здесь <code>$VERSION_ID = "9"</code> и <code>stretch</code> — версия ОС: | ||
#*:<syntaxhighlight lang="bash"> | #*:<syntaxhighlight lang="bash"> | ||
echo "deb https://repos.influxdata.com/debian | test $VERSION_ID = "9" && echo "deb https://repos.influxdata.com/debian stretch stable" | tee /etc/apt/sources.list.d/influxdb.list | ||
</syntaxhighlight> | </syntaxhighlight> | ||
# Обновите список пакетов и установите | # Обновите список пакетов и установите telegraf: | ||
#:<syntaxhighlight lang="bash"> | #:<syntaxhighlight lang="bash"> | ||
apt update && apt install telegraf | apt update && apt install telegraf | ||
</syntaxhighlight> | </syntaxhighlight> | ||
# | # Запустите установленный сервис: | ||
#:<syntaxhighlight lang="bash"> | #:<syntaxhighlight lang="bash"> | ||
service telegraf start | |||
</syntaxhighlight> | </syntaxhighlight> | ||
Теперь его нужно настроить: | |||
# Откройте файл настроек | # Откройте файл настроек telegraf: | ||
#: <syntaxhighlight lang="bash"> | #: <syntaxhighlight lang="bash"> | ||
mcedit /etc/telegraf/telegraf.conf | |||
</syntaxhighlight> | </syntaxhighlight> | ||
# Секция '''inputs.mqtt_consumer''', поля ''servers'', ''topics'', ''data_format'' и ''data_type'': | # Секция '''inputs.mqtt_consumer''', поля ''servers'', ''topics'', ''data_format'' и ''data_type'': | ||
Строка 154: | Строка 151: | ||
Content-Encoding = "snappy" | Content-Encoding = "snappy" | ||
X-Prometheus-Remote-Write-Version = "0.1.0" | X-Prometheus-Remote-Write-Version = "0.1.0" | ||
</syntaxhighlight> | </syntaxhighlight> | ||
# Сохраните файл и закройте редактор. | # Сохраните файл и закройте редактор. | ||
Проверьте, что Telegraf работает без ошибок: | |||
# Остановите сервис: | # Остановите сервис: | ||
#:<syntaxhighlight lang="bash"> | #:<syntaxhighlight lang="bash"> | ||
service telegraf stop | |||
</syntaxhighlight> | </syntaxhighlight> | ||
# Запустите сервис в режиме отладки и убедитесь, что данные отправляются: | # Запустите сервис в режиме отладки и убедитесь, что данные отправляются: | ||
Строка 267: | Строка 184: | ||
# Запустите сервис в автоматическом режиме: | # Запустите сервис в автоматическом режиме: | ||
#:<syntaxhighlight lang="bash"> | #:<syntaxhighlight lang="bash"> | ||
service telegraf start | |||
</syntaxhighlight> | </syntaxhighlight> | ||
=== Создание панели с данными от контроллера Wiren Board в Grafana === | |||
== Свой сервер Grafana == | == Свой сервер Grafana == | ||
Строка 362: | Строка 221: | ||
sudo apt update | sudo apt update | ||
</syntaxhighlight> | </syntaxhighlight> | ||
Установите необходимое ПО: | Установите необходимое ПО: | ||
Строка 409: | Строка 266: | ||
# Откройте браузер и введите в адресную строку <code>http://192.168.2.36:3000</code>, где '''192.168.2.36''' — IP-адрес вашего сервера с Grafana. | # Откройте браузер и введите в адресную строку <code>http://192.168.2.36:3000</code>, где '''192.168.2.36''' — IP-адрес вашего сервера с Grafana. | ||
# Введите логин/пароль '''admin'''/'''admin'''. После первого входа задайте новый пароль. | # Введите логин/пароль '''admin'''/'''admin'''. После первого входа задайте новый пароль. | ||
=== Установка MQTT-брокера === | === Установка MQTT-брокера === | ||
Строка 433: | Строка 278: | ||
# Создайте файл конфигурации <code>bridge1.conf</code>: | # Создайте файл конфигурации <code>bridge1.conf</code>: | ||
#: <syntaxhighlight lang="bash"> | #: <syntaxhighlight lang="bash"> | ||
mcedit /etc/mosquitto/conf.d/bridge1.conf | |||
</syntaxhighlight> | </syntaxhighlight> | ||
# Вставьте в него строки, в которых замените в двух местах '''AWQBNTYP''' на серийный номер контроллера, а '''192.168.2.36''' на IP-адрес брокера: | # Вставьте в него строки, в которых замените в двух местах '''AWQBNTYP''' на серийный номер контроллера, а '''192.168.2.36''' на IP-адрес брокера: | ||
Строка 450: | Строка 295: | ||
# Перезапустите mosquitto: | # Перезапустите mosquitto: | ||
#:<syntaxhighlight lang="bash"> | #:<syntaxhighlight lang="bash"> | ||
service mosquitto restart | |||
</syntaxhighlight> | </syntaxhighlight> | ||
Строка 554: | Строка 399: | ||
# Откройте веб-интерфейс Grafana. | # Откройте веб-интерфейс Grafana. | ||
# Слева на панели нажмите на «шестерёнку» и выберите пункт '''Data Sources'''. | # Слева на панели нажмите на «шестерёнку» и выберите пункт '''Data Sources'''. | ||
# Откроется страница со списком источников данных, который у нас будет пуст. Нажмите на кнопку '''Add | # Откроется страница со списком источников данных, который у нас будет пуст. Нажмите на кнопку '''Add sata source'''. | ||
# В открывшемся списке найдите '''InfluxDB''' и нажмите кнопку '''Select'''. | # В открывшемся списке найдите '''InfluxDB''' и нажмите кнопку '''Select'''. | ||
# На странице создания нового источника данных заполните: | # На странице создания нового источника данных заполните: | ||
Строка 604: | Строка 449: | ||
Image: Grafana - 5. WB Dashboard.png | Созданный дашборд с панелью | Image: Grafana - 5. WB Dashboard.png | Созданный дашборд с панелью | ||
</gallery> | </gallery> | ||
== Полезные ссылки == | == Полезные ссылки == | ||
* [https://grafana.com/docs/grafana/latest/installation/debian Оригинальная инструкция установки Grafana в Debian] | * [https://grafana.com/docs/grafana/latest/installation/debian Оригинальная инструкция установки Grafana в Debian] | ||
* [https://docs.influxdata.com/telegraf/v1.19/introduction/installation/ Оригинальная инструкция по установке Telegraf]. | * [https://docs.influxdata.com/telegraf/v1.19/introduction/installation/ Оригинальная инструкция по установке Telegraf]. | ||
Версия 19:59, 29 ноября 2021
Это черновик страницы. Последняя правка сделана 29.11.2021 пользователем A.Degtyarev.
Введение
Grafana — мультиплатформенное веб-приложение с открытым кодом, отображающее данные в виде графиков, диаграмм, индикаторов, а также другими способами. Конечные пользователи могут создавать сложные панели мониторинга с помощью интерактивного конструктора запросов. Умеет отправлять оповещения (alert). Расширяется с помощью системы плагинов.
Grafana подходит для отображения изменяющихся со временем параметров — например, показаний датчиков, подключенных к контроллеру Wiren Board. Так как Grafana сама по себе не является базой данных, для хранения данных используются time series databases, такие как InfluxDB и Prometheus.
Grafana можно установить на собственный сервер, либо использовать облачный сервис Grafana Cloud.
Grafana Cloud
В состав Grafana Cloud уже есть база данных, поэтому устанавливать и настраивать базу данных не нужно.
Схема работы:
- На контроллер устанавливается клиент Telegraf
- Telegraf отправляет данные в базу данных Prometheus.
- Grafana отображает содержимое базы данных.
Регистрация в Grafana Cloud
- Зарегистрируйтесь в Grafana Cloud.
- Перейдите в настройки аккаунта по ссылке My Account.
- Найдите карточку Prometheus и нажмите кнопку Send Metrics.
- На открывшейся странице найдите и сохраните данные из полей:
- Remote Write Endpoint
- Username / Instance ID
- Password / API Key, для генерации ключа нажмите Generate now.
Установка и настройка Telegraf
Telegraf — это сервис, который устанавливается на контроллер Wiren Board и отправляет данные в базу данных Grafana Cloud. Для выполнения команд, откройте консоль контроллера по SSH.
Установка Telegraf:
- Установите дополнительные пакеты:
apt update && apt install apt-transport-https
- Добавьте ключ репозитория telegraf:
wget -qO- https://repos.influxdata.com/influxdb.key | apt-key add -
- Добавьте в список apt-репозиториев ссылку на репозиторий telegraf:
source /etc/os-release
- Здесь
$VERSION_ID = "9"
иstretch
— версия ОС:test $VERSION_ID = "9" && echo "deb https://repos.influxdata.com/debian stretch stable" | tee /etc/apt/sources.list.d/influxdb.list
- Обновите список пакетов и установите telegraf:
apt update && apt install telegraf
- Запустите установленный сервис:
service telegraf start
Теперь его нужно настроить:
- Откройте файл настроек telegraf:
mcedit /etc/telegraf/telegraf.conf
- Секция inputs.mqtt_consumer, поля servers, topics, data_format и data_type:
[[inputs.mqtt_consumer]] ## Broker URLs for the MQTT server or cluster. To connect to multiple ## clusters or standalone servers, use a seperate plugin instance. ## example: servers = ["tcp://localhost:1883"] ## servers = ["ssl://localhost:1883"] ## servers = ["ws://localhost:1883"] servers = ["tcp://127.0.0.1:1883"] ## Topics that will be subscribed to. topics = [ "/devices/power_status/controls/Vin", ] ## The message topic will be stored in a tag specified by this value. If set ## to the empty string no topic tag will be created. # topic_tag = "topic" ## QoS policy for messages ## 0 = at most once ## 1 = at least once ## 2 = exactly once ## ## When using a QoS of 1 or 2, you should enable persistent_session to allow ## resuming unacknowledged messages. # qos = 0 ## Connection timeout for initial connection in seconds # connection_timeout = "30s" ## Maximum messages to read from the broker that have not been written by an ## output. For best throughput set based on the number of metrics within ## each message and the size of the output's metric_batch_size. ## ## For example, if each message from the queue contains 10 metrics and the ## output metric_batch_size is 1000, setting this to 100 will ensure that a ## full batch is collected and the write is triggered immediately without ## waiting until the next flush_interval. # max_undelivered_messages = 1000 ## Persistent session disables clearing of the client session on connection. ## In order for this option to work you must also set client_id to identify ## the client. To receive messages that arrived while the client is offline, ## also set the qos option to 1 or 2 and don't forget to also set the QoS when ## publishing. # persistent_session = false ## If unset, a random client ID will be generated. # client_id = "" ## Username and password to connect MQTT server. # username = "telegraf" # password = "metricsmetricsmetricsmetrics" ## Optional TLS Config # tls_ca = "/etc/telegraf/ca.pem" # tls_cert = "/etc/telegraf/cert.pem" # tls_key = "/etc/telegraf/key.pem" ## Use TLS but skip chain & host verification # insecure_skip_verify = false ## Data format to consume. ## Each data format has its own unique set of configuration options, read ## more about them here: ## https://github.com/influxdata/telegraf/blob/master/docs/DATA_FORMATS_INPUT.md data_format = "value" data_type = "float"
- Секция outputs.http, поля url, username, password, data_format и [outputs.http.headers]. Ссылку и логин с паролем мы сохраняли в разделе про регистрацию.
[[outputs.http]] ## URL is the address to send metrics to url = "https://prometheus-us-central1.grafana.net/api/prom/push" ## HTTP Basic Auth credentials username = "xxx" # Replace password = "yyy" # Replace ## Data format to output. data_format = "prometheusremotewrite" ## Additional HTTP headers [outputs.http.headers] Content-Type = "application/x-protobuf" Content-Encoding = "snappy" X-Prometheus-Remote-Write-Version = "0.1.0"
- Сохраните файл и закройте редактор.
Проверьте, что Telegraf работает без ошибок:
- Остановите сервис:
service telegraf stop
- Запустите сервис в режиме отладки и убедитесь, что данные отправляются:
# telegraf -debug 2021-11-29T16:47:13Z I! Starting Telegraf 1.20.4 2021-11-29T16:47:13Z I! Using config file: /etc/telegraf/telegraf.conf 2021-11-29T16:47:13Z I! Loaded inputs: cpu disk diskio kernel mem mqtt_consumer processes swap system 2021-11-29T16:47:13Z I! Loaded aggregators: 2021-11-29T16:47:13Z I! Loaded processors: 2021-11-29T16:47:13Z I! Loaded outputs: http 2021-11-29T16:47:13Z I! Tags enabled: host=wirenboard-AWQBNTYP 2021-11-29T16:47:13Z I! [agent] Config: Interval:10s, Quiet:false, Hostname:"wirenboard-AWQBNTYP", Flush Interval:10s 2021-11-29T16:47:13Z D! [agent] Initializing plugins 2021-11-29T16:47:13Z D! [agent] Connecting outputs 2021-11-29T16:47:13Z D! [agent] Attempting connection to [outputs.http] 2021-11-29T16:47:13Z D! [agent] Successfully connected to outputs.http 2021-11-29T16:47:13Z D! [agent] Starting service inputs 2021-11-29T16:47:13Z I! [inputs.mqtt_consumer] Connected [tcp://127.0.0.1:1883] 2021-11-29T16:47:24Z D! [outputs.http] Wrote batch of 31 metrics in 696.002545ms 2021-11-29T16:47:24Z D! [outputs.http] Buffer fullness: 1 / 10000 metrics 2021-11-29T16:47:33Z D! [outputs.http] Wrote batch of 34 metrics in 129.098071ms 2021-11-29T16:47:33Z D! [outputs.http] Buffer fullness: 0 / 10000 metrics
- Если ошибок нет, то остановите команду клавишами Ctrl+C.
- Запустите сервис в автоматическом режиме:
service telegraf start
Создание панели с данными от контроллера Wiren Board в Grafana
Свой сервер Grafana
Для установки Grafana нам потребуется выделенный сервер с IP-адресом, доступным с контроллера Wiren Board.
Схема работы:
- Один или несколько контроллеров передают значения MQTT топиков в MQTT-брокер, установленный на сервере Grafana.
- На сервере Grafana выполняется скрипт, который записывает MQTT-топики брокера в базу данных Influx.
- Grafana отображает содержимое базы данных Influx.
Grafana и MQTT-брокер можно установить на один сервер, или разнести на разные. Если вы используете два разных сервера, то IP-адрес MQTT-брокера должен быть доступен с контроллера Wiren Board и с сервера, на котором установлена Grafana.
Установка Grafana
В примере мы установим Grafana на сервер с Debian Linux 11.
Подготовьте сервер к установке:
- Установите пакеты:
sudo apt install -y apt-transport-https software-properties-common wget gnupg2 sudo python3-pip
- Добавьте ключ репозитория
packages.grafana.com
:wget -q -O - https://packages.grafana.com/gpg.key | sudo apt-key add -
- Добавьте ссылку на репозиторий
packages.grafana.com
:echo "deb https://packages.grafana.com/oss/deb stable main" | sudo tee -a /etc/apt/sources.list.d/grafana.list
- Обновите список пакетов:
sudo apt update
Установите необходимое ПО:
- grafana, python3 и БД influxdb:
sudo apt install -y grafana influxdb influxdb-client python3-pip
- и дополнительные модули python:
sudo pip3 install paho-mqtt python-etcd influxdb
Разрешите автозапуск сервиса и запустите его:
sudo systemctl enable grafana-server && sudo systemctl start grafana-server
Проверьте статус сервиса:
$ systemctl status grafana-server
● grafana-server.service - Grafana instance
Loaded: loaded (/lib/systemd/system/grafana-server.service; enabled; vendor preset: enabled)
Active: active (running) since Thu 2021-11-25 13:56:19 +04; 2min 33s ago
Docs: http://docs.grafana.org
Main PID: 3237 (grafana-server)
Tasks: 9 (limit: 4663)
Memory: 35.2M
CPU: 1.371s
Если статус Active: active (running)
— переходите к следующим шагам.
Создайте базу данных Influxdb с именем mqtt_data:
$ echo "CREATE DATABASE mqtt_data; show databases;" | influx
name: databases
name
----
_internal
mqtt_data
Перейдите в веб-интерфейс Grafana:
- Откройте браузер и введите в адресную строку
http://192.168.2.36:3000
, где 192.168.2.36 — IP-адрес вашего сервера с Grafana. - Введите логин/пароль admin/admin. После первого входа задайте новый пароль.
Установка MQTT-брокера
Теперь настроим MQTT-брокер, куда контроллер Wiren Board будет отправлять данные.
Установите на сервер с Grafana mosquitto по инструкции Установка брокера.
Настройка моста на контроллере
Настройте на контроллере Wiren Board подключение к внешнему MQTT-брокеру:
- Подключитесь к контроллеру по SSH.
- Создайте файл конфигурации
bridge1.conf
:mcedit /etc/mosquitto/conf.d/bridge1.conf
- Вставьте в него строки, в которых замените в двух местах AWQBNTYP на серийный номер контроллера, а 192.168.2.36 на IP-адрес брокера:
connection bridge1 #address of server address 192.168.2.36 notifications true notification_topic /client/AWQBNTYP/bridge1_status remote_username test remote_password wbpassword topic /hwmon/# both 2 /devices /client/AWQBNTYP/devices
- в конфигурации выше мы отправляем в MQTT-брокер все подтопики устройства hwmon, чтобы передать все топики контроллера, замените путь
/hwmon/#
на/#
- Сохраните изменения и закройте файл.
- Перезапустите mosquitto:
service mosquitto restart
Теперь проверим, что контроллер отправляет данные во внешний MQTT-брокер:
- Выполните в консоли контроллера команду, в которой замените 192.168.2.36 на IP-адрес брокера, AWQBNTYP на серийный номер контроллера, а test и wbpassword на логин и пароль от MQTT-брокера:
# mosquitto_sub -v -h 192.168.2.36 -u test -P wbpassword -t /client/AWQBNTYP/devices/# /client/AWQBNTYP/devices/hwmon/meta/driver wb-rules /client/AWQBNTYP/devices/hwmon/meta/name HW Monitor /client/AWQBNTYP/devices/hwmon/controls/Board Temperature 35.875 /client/AWQBNTYP/devices/hwmon/controls/Board Temperature/meta/type temperature /client/AWQBNTYP/devices/hwmon/controls/Board Temperature/meta/order 1 /client/AWQBNTYP/devices/hwmon/controls/Board Temperature/meta/readonly 1 /client/AWQBNTYP/devices/hwmon/controls/CPU Temperature 66.917 /client/AWQBNTYP/devices/hwmon/controls/CPU Temperature/meta/type temperature /client/AWQBNTYP/devices/hwmon/controls/CPU Temperature/meta/order 2 /client/AWQBNTYP/devices/hwmon/controls/CPU Temperature/meta/readonly 1 /client/AWQBNTYP/devices/hwmon/controls/CPU Temperature 66.917 /client/AWQBNTYP/devices/hwmon/controls/Board Temperature 35.875
- Если после выполнения команды вы получите список топиков — контролер успешно отправляет данные во внешний брокер.
- Завершите команду клавишами Ctrl+C.
Скрипт на сервере Grafana
Теперь скачаем на сервер с Grafana скрипт, который будет отправлять данные из MQTT-брокера в базу данных Influx:
- Перейдите на сервере в папку
/usr/local/bin
cd /usr/local/bin
- Скачайте в эту папку скрипт:
sudo wget https://raw.githubusercontent.com/wirenboard/wbmqtt2influx/master/mqtt_to_influxdb.py
- Разрешите выполнение скрипта командой:
sudo chmod +x mqtt_to_influxdb.py
- Создайте сервис, который будет автоматически запускать скрипт:
sudo systemctl edit --force --full mqtt_to_influxdb.service
- В открывшийся редактор вставьте строки, в которых замените test и wbpassword на логин и пароль от MQTT-брокера.:
[Unit] Description=Mqtt to Influxdb script After=multi-user.target Requires=influxd.service [Service] Type=idle User=mosquitto ExecStart=/usr/bin/python3 /usr/local/bin/mqtt_to_influxdb.py -h localhost "/#" -u "test" -P "wbpassword" Restart=always TimeoutStartSec=10 RestartSec=10 [Install] WantedBy=multi-user.target
- Если MQTT-брокер стоит на отдельном от Grafana сервере, укажите его IP-адрес вместо localhost.
- Сохраните файл, для этого нажмите клавиши Ctrl+O, затем Enter и Ctrl+X.
- Настройте автозапуск и запустите сервис:
sudo systemctl enable mqtt_to_influxdb.service && sudo systemctl start mqtt_to_influxdb.service
- Проверьте статус сервиса:
$ systemctl status mqtt_to_influxdb.service ● mqtt_to_influxdb.service - Mqtt to Influxdb script Loaded: loaded (/etc/systemd/system/mqtt_to_influxdb.service; enabled; vendor preset: enabled) Active: active (running) since Thu 2021-11-25 21:38:32 +04; 4s ago Main PID: 5440 (python3) Tasks: 2 (limit: 4663) Memory: 17.1M CPU: 206ms CGroup: /system.slice/mqtt_to_influxdb.service └─5440 /usr/bin/python3 /usr/local/bin/mqtt_to_influxdb.py -h localhost /# -u test -P wbpassword
- Если в выводе команды есть строчка
Active: active (running)
— сервис создан и настроен верно.
Теперь проверьте, записывается ли что-то в influxDB. Для этого выполните на сервере команду:
$ influx -database 'mqtt_data' -execute 'SELECT * FROM /.*/ LIMIT 10' name: mqtt_data time channel client value_f ---- ------- ------ ------- 1637861917526049562 hwmon/CPU Temperature AWQBNTYP 67.516 1637861917615599448 hwmon/Board Temperature AWQBNTYP 35.875 1637861927519510484 hwmon/CPU Temperature AWQBNTYP 66.917 1637861927586856127 hwmon/Board Temperature AWQBNTYP 35.875 1637861937592362349 hwmon/Board Temperature AWQBNTYP 35.875 1637861937592362349 hwmon/CPU Temperature AWQBNTYP 66.917 1637861947498698295 hwmon/CPU Temperature AWQBNTYP 67.516 1637861947570297085 hwmon/Board Temperature AWQBNTYP 35.875 1637861957523243600 hwmon/CPU Temperature AWQBNTYP 66.917 1637861957593339293 hwmon/Board Temperature AWQBNTYP 35.875
- если в выводе команды есть информация с топиков — можно переходить к настройке Grafana через веб-интерфейс.
Настройка в Grafana источника данных
Чтобы Grafana могла отобразить данные из базы данных Influx, нужно в её веб-интерфейсе добавить источник данных:
- Откройте веб-интерфейс Grafana.
- Слева на панели нажмите на «шестерёнку» и выберите пункт Data Sources.
- Откроется страница со списком источников данных, который у нас будет пуст. Нажмите на кнопку Add sata source.
- В открывшемся списке найдите InfluxDB и нажмите кнопку Select.
- На странице создания нового источника данных заполните:
- Наименование, можно оставить по умолчанию.
- URL — http://localhost:8086
- Database — mqtt_data
- Чтобы сохранить настройки, нажмите Save & Test, при успешном подключении появится сообщение Data source is working.
Если после сохранения настроек нет ошибок, то переходите к созданию дашборда.
Создание дашборда в Grafana
После того как мы создали источник данных — добавьте новый дашборд и создайте запрос на выборку данных:
- Откройте веб-интерфейс Grafana.
- Выберите на панели слева «плюсик» и пункт Dashboard.
- В открывшейся странице New dashboard, нажмите на плитку Add a empty panel. Откроется страница создания запроса.
- В поле Data source выберите созданный ранее источник данных, у нас это InfluxDB.
- В строке FROM:
- укажите имя БД mqtt_data;
- выберите вид запрашиваемых данных, например, channel — это аналог MQTT-топика;
- теперь выберите, значение какого топика выводить, например, hwmon/Board Temperature.
- Если мы хотим вывести числовые значение, то в строке SELECT выберите value_f, получится field(value_f). Сразу после этого на панели сверху должен появиться график.
- Задайте панели имя в поле Panel options → Title.
- Сохраните дашборд, для этого нажмите кнопку Save, в появившемся окне введите имя и нажмите кнопку Save.
Настройка дашборда завершена.
Запрос из примера в текстовом виде:
SELECT mean("value_f") FROM "mqtt_data" WHERE ("channel" = 'hwmon/Board Temperature') AND $timeFilter GROUP BY time($__interval) fill(null)