InfluxDB Непрерывный запрос: хранение тегов - PullRequest
Новая
       5

InfluxDB Непрерывный запрос: хранение тегов

0 голосов
/ 02 февраля 2019

Я пытаюсь создать CQ и сохранить теги.

Мои данные выглядят так;значение - это число с плавающей точкой, и у меня много тегов. 

select * from single_measurements order by time desc limit 10
name: single_measurements
time                     clientId machineId sensorGroupId sensorId typeId value
----                     -------- --------- ------------- -------- ------ -----
2019-02-01T22:19:03.155Z 8219     31        31            1003     1      -5728.96875
2019-02-01T22:19:03.155Z 8219     31        31            1002     1      5435.63525390625
2019-02-01T22:19:03.155Z 8219     31        31            1001     1      1859.4556884765625
2019-02-01T22:19:03.155Z 8219     31        31            1000     1      13231.85546875
2019-02-01T22:19:02.155Z 8219     31        31            1003     1      -5728.91943359375
2019-02-01T22:19:02.155Z 8219     31        31            1002     1      5435.68115234375
2019-02-01T22:19:02.155Z 8219     31        31            1001     1      1859.562744140625
2019-02-01T22:19:02.155Z 8219     31        31            1000     1      13232.0205078125
2019-02-01T22:19:01.155Z 8219     31        31            1003     1      -5728.92138671875
2019-02-01T22:19:01.155Z 8219     31        31            1002     1      5435.7177734375

1) Я создаю политику: 

create retention policy "a_year" on "mydb" duration 52w replication 1

2) Создаю CQ 

create continuous query "cq_15s" on "mydb" 
BEGIN SELECT mean(*) into "a_year"."downsampled_value" from "single_measurements" GROUP BY time(15s),* 
end

3) ждать 15 секунд и выполнить этот запрос 

select * from "a_year"."downsampled_value" limit 10

результат пуст.Я также понял, что могу писать неправильные имена измерений и не получаю ошибку.

Кстати ... это возвращает мне непустой результат: 

SELECT mean(*) FROM single_measurements GROUP BY time(15s),*

Окружающая среда: 

Connected to http://localhost:8086 version 1.6.4
InfluxDB shell version: 1.6.4

показ непрерывных запросов: 

name: _internal
name query
---- -----

name: ketag
name    query
----    -----
cq_15s  CREATE CONTINUOUS QUERY cq_15s ON ketag BEGIN SELECT mean(*) INTO ketag.a_year.downsampled_value FROM ketag.autogen.single_measurements GROUP BY time(15s), * END
cq_15s2 CREATE CONTINUOUS QUERY cq_15s2 ON ketag BEGIN SELECT mean(*) INTO ketag.a_year.downsampled_value2 FROM ketag.autogen.single_measurements GROUP BY time(15s) END
...