Чтение данных из Monitoring с помощью соединений в Query
Эта функциональность находится на стадии Preview.
Monitoring — сервис для сбора и хранения метрик, а также их отображения на дашбордах. Данные в Monitoring содержат значения измеряемых величин — метрики — и описывающие их метки.
Например, чтобы отслеживать количество сбоев приложения, в качестве метрики можно использовать число сбоев за интервал времени. Название хоста и версия приложения при сбое являются метками. В интерфейсе Monitoring можно выполнять агрегацию метрик по меткам.
Пример чтения метрик из Monitoring:
SELECT
*
FROM
monitoring.ydb
WITH (
program = @@max{method="DescribeTable"}@@,
from = "2025-03-12T14:00:00Z",
to = "2025-03-12T15:00:00Z"
);
Настройка соединения
Чтобы настроить чтение метрик из Monitoring:
-
Перейдите в сервис Yandex Query.
-
На панели слева выберите Соединения.
-
Нажмите Создать.
-
В открывшемся окне в поле Имя укажите название соединения с Monitoring.
-
В поле Тип выберите
Monitoring. -
В поле Сервисный аккаунт выберите сервисный аккаунт для чтения метрик или создайте новый и назначьте ему на облако роль
monitoring.viewer.Чтобы использовать сервисный аккаунт, пользователю нужна роль
iam.serviceAccounts.user. -
Нажмите Создать.
Модель данных
Чтение метрик из Monitoring выполняется с помощью SQL-выражения:
SELECT
*
FROM
<соединение>.<сервис>
WITH (
(selectors|program) = "<запрос>",
labels = "<метки>",
from = "<время_от>",
to = "<время_до>",
<параметры прореживания>
)
Где:
<соединение>— название соединения с Monitoring, созданного в предыдущем пункте.<сервис>— сервис Monitoring.<запрос>— запрос на языке запросов Monitoring.<метки>— список имен меток, значения которых нужно получить в отдельных столбцах.<время_от>— левая граница искомого временного интервала в формате ISO 8601.<время_до>— правая граница искомого временного интервала в формате ISO 8601.
Такой запрос вернет все точки всех метрик сервиса <сервис>, удовлетворяющих <запросу> и находящихся во временном интервале [<время_от>, <время_до>). Результат запроса будет содержать колонки:
| Имя | Тип данных | Описание |
|---|---|---|
ts |
Datetime |
Время точки метрики |
value |
Double? |
Значение точки метрики, соответствующее времени в столбце ts |
type |
String |
Тип метрики, содержащей точку |
labels |
YQL Dict |
Метки метрики, содержащей точку. Если в запросе указан параметр labels, данный столбец будет отсутствовать |
<label> |
String |
Значение метки <label> метрики, содержащей точку |
Примечание
Запрос с параметром selectors работает без ограничений на количество метрик, но принимает на вход только набор селекторов. Если вам нужно использовать функции языка запросов — используйте параметр program.
Примечание
Метки folderId и service в наборе селекторов можно не указывать.
Формат параметров запроса
| Имя параметра | Формат | Пример |
|---|---|---|
selectors |
["sensor_name"]{[label_name1 = "label_value1", label_name2 = "label_value2", ...]} |
{name = "api.grpc.request.bytes", method="DescribeTable"} |
program |
Запрос на языке запросов Monitoring | series_sum{method="DescribeTable"} |
labels |
"label1 [as alias1], label2 [as alias2], ..." |
"database.dedicated as db, database_path, api_service as api" |
from / to |
Время в формате ISO 8601 | "2025-05-20T12:00:00Z" |
Параметры прореживания
В Yandex Query поддерживаются следующие параметры прореживания:
| Имя параметра | Описание | Принимаемые значения | Значение по умолчанию |
|---|---|---|---|
downsampling.disabled |
В случае значения true указывает, что данные в ответе на запрос будут получены без прореживания. |
true, false |
false |
downsampling.aggregation |
Функция агрегации, которая используется для прореживания. | MAX, MIN, SUM, AVG, LAST, COUNT |
AVG |
downsampling.fill |
Параметры заполнения пропусков в данных. | NULL, NONE, PREVIOUS |
PREVIOUS |
downsampling.grid_interval |
Ширина временного окна (сетки) в секундах, используемая для прореживания. | Целое число | 15 |
Пример чтения метрик
Пример запроса для чтения метрик из Monitoring:
SELECT
*
FROM
monitoring.compute
WITH (
selectors = @@"cpu_utilization"{resource_type="vm"}@@,
labels = "cpu_name as cpu, resource_id",
from = "2025-03-12T14:00:00Z",
to = "2025-03-12T15:00:00Z",
`downsampling.aggregation` = "AVG",
`downsampling.fill` = "PREVIOUS",
`downsampling.grid_interval` = "15"
);
Где:
monitoring— название соединения с Monitoring.compute— сервис, по которому проводится поиск.cpu_name as cpu, resource_id— список меток, значения которых вернутся в отдельных столбцах. Значение меткиcpu_nameбудет возвращено в столбцеcpu,resource_id— в столбцеresource_id.[2025-03-12T14:00:00Z – 2025-03-12T15:00:00Z)— временной интервал, по которому проводится поиск.