Lindorm：Pra-pengambilan sampel

Buat aturan pra-pengambilan sampel untuk tabel menggunakan pernyataan SQL

Contoh

• Konfigurasikan aturan pra-pengambilan sampel di mana rasio pra-pengambilan sampel diatur menjadi satu jam dan operasi sum dan max dilakukan pada data yang telah di-pra-pengambilan sampel.

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

• Konfigurasikan aturan pra-pengambilan sampel di mana rasio pra-pengambilan sampel diatur menjadi satu jam, operasi sum dan max dilakukan pada data yang telah di-pra-pengambilan sampel, dan TTL data yang telah di-pra-pengambilan sampel diatur menjadi 90 hari.

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

Referensi sintaksis

CREATE PREDOWNSAMPLE

Buat aturan pra-pengambilan sampel untuk database menggunakan operasi API

Jalur permintaan dan metode

Parameter permintaan

Parameter untuk satu aturan pra-pengambilan sampel

Permintaan contoh

PUT /api/database

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

Deskripsi respons

Jika permintaan berhasil, kode status HTTP 200 dikembalikan.

Kueri aturan pra-pengambilan sampel yang dikonfigurasikan untuk tabel menggunakan pernyataan SQL

Contoh

• Kueri semua aturan pra-pengambilan sampel yang dikonfigurasikan untuk semua tabel dalam database.

  SHOW PREDOWNSAMPLES;

• Kueri semua aturan pra-pengambilan sampel yang dikonfigurasikan untuk tabel bernama sensor.

  SHOW PREDOWNSAMPLES ON sensor;

Referensi sintaksis

SHOW PREDOWNSAMPLES

Kueri aturan pra-pengambilan sampel yang dikonfigurasikan untuk database menggunakan operasi API

Jalur permintaan dan metode

Respons contoh

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

Deskripsi respons

Jika permintaan berhasil, kode status HTTP 204 dikembalikan.

Hapus aturan pra-pengambilan sampel yang dikonfigurasikan untuk tabel menggunakan pernyataan SQL

Contoh

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

Referensi sintaksis

DROP PREDOWNSAMPLE

Hapus aturan pra-pengambilan sampel yang dikonfigurasikan untuk database menggunakan operasi API

Jalur permintaan, metode permintaan, dan parameter permintaan yang perlu Anda konfigurasikan untuk menghapus aturan pra-pengambilan sampel untuk database sama dengan saat Anda membuat aturan pra-pengambilan sampel untuk database. Namun, Anda perlu mengatur bidang downsampleRules menjadi kosong. Kode status HTTP yang dikembalikan dalam respons juga sama dengan saat Anda membuat aturan pra-pengambilan sampel untuk database. Untuk informasi lebih lanjut, lihat Buat Aturan Pra-pengambilan Sampel untuk Database Menggunakan Operasi API.

Permintaan contoh

PUT /api/database

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

Gunakan pernyataan SQL untuk mengkueri data pra-pengambilan sampel

Secara default, saat Anda mengkueri data pra-pengambilan sampel, data mentah sebelum pra-pengambilan sampel dikueri. Untuk hanya mengkueri data pra-pengambilan sampel, Anda harus menambahkan hint /*+ PREDOWNSAMPLE */ dalam pernyataan kueri.

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

Gunakan metode yang kompatibel dengan TSDB untuk mengkueri data pra-pengambilan sampel

Anda dapat menggunakan kueri multi-nilai berbasis API, kueri single-nilai berbasis API, dan SDK untuk mengkueri data pra-pengambilan sampel.

Gunakan SDK untuk mengkueri data pra-pengambilan sampel

Saat Anda menggunakan SDK untuk mengkueri data pra-pengambilan sampel, Anda harus mengonfigurasi parameter DownsampleDataSource dalam builder MultiFieldSubQuery.

Contoh

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)
        // Kueri data pra-pengambilan sampel.
        .downsampleDataSource(DownsampleDataSource.DOWNSAMPLE)
        .build();
MultiFieldQuery query = MultiFieldQuery.
        start(startTime).
        end(endTime).
        sub(subQuery).
        build();
List<MultiFieldQueryResult> result = tsdb.multiFieldQuery(query); 

Parameter

Anda dapat mengatur parameter DownsampleDataSource ke salah satu nilai berikut:

• DOWNSAMPLE: Kueri data pra-pengambilan sampel.

• RAW: Kueri data mentah. Nilai default parameter ini adalah RAW.

Untuk informasi lebih lanjut tentang cara menggunakan model data multi-nilai SDK untuk mengkueri data pra-pengambilan sampel, lihat Gunakan Model Data Multi-nilai SDK untuk Membaca Data.

Kueri data pra-pengambilan sampel menggunakan kueri multi-nilai berbasis API

Saat Anda menggunakan kueri multi-nilai berbasis API untuk mengkueri data pra-pengambilan sampel, Anda harus menambahkan parameter downsampleSource dan mengaturnya ke downsample. Untuk informasi lebih lanjut, lihat Kueri Titik Data Multivariat.

Jalur Permintaan dan Metode

Parameter Permintaan

Permintaan Contoh

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"
                  }
        }
    ]
}