Lindorm：預降採樣

建立表層級的預降採樣規則（SQL方式）

樣本

• 設定預降採樣精度為1小時，並對預降採樣周期執行sum和max預計算。

  CREATE PREDOWNSAMPLE `1h` AGGREGATORS (`sum`, `max`) ON sensor;

• 設定預降採樣的資料有效期間（TTL）為90天。

  CREATE PREDOWNSAMPLE `1h` AGGREGATORS (`sum`, `max`) TTL `90d` ON sensor;

文法參考

CREATE PREDOWNSAMPLE

建立資料庫層級的預降採樣規則（API方式）

請求路徑和方法

請求參數

預降採樣規則參數

請求樣本

PUT /api/database

{
    "name": "default",
    "downsampleRules": {
        "rules": [
            {
                "aggregator": "sum",
                "intervals": [
                    "1m",
                    "1h"
                ]
            },
            {
                "aggregator": "max",
                "intervals": [
                    "1m",
                    "1h"
                ]
            }
        ]
    }
}

響應說明

響應狀態代碼為200。

查詢表層級的預降採樣規則（SQL方式）

樣本

• 查詢資料庫所有的預降採樣規則。

  SHOW PREDOWNSAMPLES;

• 查詢指定資料表sensor的預降採樣規則。

  SHOW PREDOWNSAMPLES ON sensor;

文法參考

SHOW PREDOWNSAMPLES

查詢資料庫層級的預降採樣規則（API方式）

請求路徑和方法

返回樣本

[{
    "name": "default",
    "downsampleRules": {
        "rules": [
            {
                "aggregator": "sum",
                "intervals": [
                    "1m",
                    "1h"
                ]
            },
            {
                "aggregator": "max",
                "intervals": [
                    "1m",
                    "1h"
                ]
            }
        ]
    }
}]

響應說明

響應狀態代碼為204。

刪除表層級的預降採樣規則（SQL方式）

樣本

DROP PREDOWNSAMPLE `1h` AGGREGATORS (`sum`, `max`) ON sensor;

文法參考

DROP PREDOWNSAMPLE

刪除資料庫層級的預降採樣規則（API方式）

刪除資料庫層級的預降採樣規則，請求路徑、要求方法、請求參數和響應說明，與建立資料庫層級的預降採樣規則相同，區別為需要將downsampleRules的值置為空白。請求路徑等詳細資料，請參見建立資料庫層級的預降採樣規則（API方式）。

請求樣本

PUT /api/database

{
    "name": "default",
    "downsampleRules": {
    }
}

SQL查詢預降採樣資料

預設情況下，降採樣查詢資料是從未經處理資料中進行查詢。如果要從預降採樣資料中查詢資料需要在查詢語句中使用Hint（/*+ PREDOWNSAMPLE */）。

SELECT /*+ PREDOWNSAMPLE */ sum(temperature) from sensor
WHERE time >= 1619074800000 AND time <= 1619085600000
SAMPLE BY 1h;

TSDB相容查詢預降採樣資料

相容時間序列資料庫TSDB的介面支援通過API多值查詢、API單值查詢、SDK查詢三種方式查詢預降採樣資料。

SDK多值查詢預降採樣資料

查詢降採樣資料時，需要在MultiFieldSubQuery Builder設定downsampleDataSource參數。

樣本

long startTime = 1619074800000L;
long endTime = 1619085600000L;
final String metric = "wind";
final String field = "speed";
MultiFieldSubQueryDetails fieldSubQueryDetails = MultiFieldSubQueryDetails
        .field(field)
        .aggregator(Aggregator.SUM)
        .downsample("1h-sum")
        .build();
MultiFieldSubQuery subQuery = MultiFieldSubQuery
        .metric(metric)
        .fieldsInfo(fieldSubQueryDetails)
        // 從預降採樣查詢
        .downsampleDataSource(DownsampleDataSource.DOWNSAMPLE)
        .build();
MultiFieldQuery query = MultiFieldQuery.
        start(startTime).
        end(endTime).
        sub(subQuery).
        build();
List<MultiFieldQueryResult> result = tsdb.multiFieldQuery(query); 

參數說明

DownsampleDataSource 參數的取值說明：

• DOWNSAMPLE：預降採樣資料查詢。

• RAW：未經處理資料查詢。如果參數沒有被指定，預設為RAW。

SDK多值的更多內容，請參見SDK多值讀取。

API多值查詢預降採樣資料

使用API進行多值查詢時，添加downsampleSource參數並定義參數為downsample，即可查詢預降採樣資料。具體操作，請參見多值資料查詢。

請求路徑和方法

請求參數

請求樣本

POST /api/mquery

{
  "start": 1346846400000, 
  "end": 1346846402000,
    "queries": [
        {
            "downsampleDataSource" : "downsample",
            "metric": "wind",
            "fields" : [
                {
                    "field" : "speed",
                    "aggregator" : "none",
                    "downsample" : "1h-sum"
                }
            ],
                      "tags":{
                    "sensor":"IOTE_8859_0002"
                  }
        }
    ]
}