云原生多模数据库 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"
                  }
        }
    ]
}