Lindorm：連續查詢

連續查詢的管理

Lindorm時序引擎提供SQL能力用於管理資料庫中的連續查詢。

• 連續查詢的建立

  在指定的Database下建立一個連續查詢。SQL文法可參見CREATE CONTINUOUS QUERY。

  說明

  • 連續查詢歸屬於指定的資料庫， 當資料庫刪除時，該資料庫下的所有連續查詢也將被自動刪除。

  • 如果不指定資料庫， 則在當前資料庫（對應USE DATABASE語句指定的資料庫）下建立連續查詢。

• 連續查詢的刪除

  從指定的Database下刪除一個已存在的連續查詢。SQL文法可參見DROP CONTINUOUS QUERY。

• 連續查詢資訊的展示

  查詢已有的連續查詢中繼資料。SQL文法可參見SHOW CONTINUOUS QUERIES。

資料降精度與長期儲存

對於資料量較大的情境，儲存成本會成為使用者關心的問題。Lindorm時序引擎支援設定每個資料庫的保資料有效期間（TTL），您可以結合連續查詢，將資料降精度後寫入到有效期間更長的資料庫中。以下樣本介紹了如何通過連續查詢與資料庫TTL設定來實現資料降精度與長期儲存。

樣本

假設，未經處理資料採樣周期為1秒，資料量較大，只能儲存最近一個月的資料。降採樣到分鐘精度後，資料可以儲存一年。

1. 建立資料庫db_sensor_month，將未經處理資料儲存在db_sensor_month中，資料有效期間為30天。

   CREATE DATABASE db_sensor_month WITH (ttl=30);

2. 在資料庫db_sensor_month中建立表sensor。

   USE db_sensor_month；
   
   CREATE TABLE sensor (
       device_id VARCHAR TAG,
       region VARCHAR TAG,
       time TIMESTAMP,
       temperature DOUBLE,
       humidity BIGINT);

3. 建立另一個資料庫db_sensor_year，儲存降精度後的資料，資料有效期間為365天。

   CREATE DATABASE db_sensor_year WITH (ttl=365);

4. 建立用於儲存計算結果的表db_sensor_year.sensor。

   USE db_sensor_year；
   
   CREATE TABLE sensor (
       device_id VARCHAR TAG,
       region VARCHAR TAG,
       time TIMESTAMP,
       temperature DOUBLE,
       humidity BIGINT);

5. 建立連續查詢，執行降採樣查詢，並將查詢結果寫入db_sensor_year.sensor。

   CREATE CONTINUOUS QUERY db_sensor_year.my_cq WITH(`interval`='1m')
   AS
     INSERT into db_sensor_year.sensor(time, temperature, humidity, device_id,region)
     SELECT time, avg(temperature) as temperature, avg(humidity) humidity, device_id, region
     FROM db_sensor_month.sensor
     sample by 60s;

6. 向原始表db_sensor_month.sensor寫入資料。

   insert into db_sensor_month.sensor(region,device_id,time,temperature,humidity) values ('hz', 'id123', current_timestamp, 37, 70);
   insert into db_sensor_month.sensor(region,device_id,time,temperature,humidity) values ('hz', 'id123', current_timestamp, 38, 67);

7. 查詢結果表db_sensor_year.sensor中降精度後的資料。

   select * from db_sensor_year.sensor;

   返回結果如下。

   +-----------+--------+---------------------------+-------------+----------+
   | device_id | region |           time            | temperature | humidity |
   +-----------+--------+---------------------------+-------------+----------+
   | id123     | hz     | 2023-10-08T19:54:00+08:00 | 37.500000   | 68.5     |
   +-----------+--------+---------------------------+-------------+----------+