Lindorm:事前ダウンサンプリング

SQL ステートメントを使用してテーブルに事前ダウンサンプリングルールを作成する

例

• 事前ダウンサンプリング比率が 1 時間に設定され、事前ダウンサンプリングされたデータに対して sum および max 操作が実行される事前ダウンサンプリングルールを設定します。

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

• 事前ダウンサンプリング比率が 1 時間に設定され、事前ダウンサンプリングされたデータに対して sum および max 操作が実行され、事前ダウンサンプリングされたデータの 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"
                ]
            }
        ]
    }
}

レスポンスの説明

リクエストが成功すると、HTTP ステータスコード 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"
                ]
            }
        ]
    }
}]

レスポンスの説明

リクエストが成功すると、HTTP ステータスコード 204 が返されます。

SQL ステートメントを使用してテーブルに設定された事前ダウンサンプリングルールを削除する

例

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

構文リファレンス

DROP PREDOWNSAMPLE

API 操作を使用してデータベースに設定された事前ダウンサンプリングルールを削除する

データベースの事前ダウンサンプリングルールを削除するために設定する必要があるリクエストパス、リクエストメソッド、およびリクエストパラメータは、データベースの事前ダウンサンプリングルールを作成する場合と同じです。ただし、downsampleRules フィールドを空に設定する必要があります。レスポンスで返される HTTP ステータスコードも、データベースの事前ダウンサンプリングルールを作成する場合と同じです。詳細については、API 操作を使用してデータベースに事前ダウンサンプリングルールを作成するをご参照ください。

リクエストの例

PUT /api/database

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

SQL ステートメントを使用して事前ダウンサンプリングされたデータをクエリする

デフォルトでは、事前ダウンサンプリングされたデータをクエリすると、事前ダウンサンプリング前の生データがクエリされます。事前ダウンサンプリングされたデータのみをクエリするには、クエリステートメントに /*+ PREDOWNSAMPLE */ ヒントを追加する必要があります。

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

TSDB 互換メソッドを使用して事前ダウンサンプリングされたデータをクエリする

API ベースの複数値クエリ、API ベースの単一値クエリ、および SDK を使用して、事前ダウンサンプリングされたデータをクエリできます。

SDK を使用して事前ダウンサンプリングされたデータをクエリする

SDK を使用して事前ダウンサンプリングされたデータをクエリする場合は、MultiFieldSubQuery ビルダーで 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"
                  }
        }
    ]
}