Tair (Redis® OSS-Compatible):TS

Temel kavramlar

TairTS verileri üç seviyeli bir hiyerarşide düzenler:

• Pkey: İlişkili zaman çizelgelerinden (skey) oluşan bir grubun adlandırılmış kapsayıcısıdır. Her pkey birden fazla skey barındırabilir.

• Skey: Bir pkey içindeki tek bir zaman çizelgesidir. Bir skey, sabit kapasiteli birden çok parçadan (chunk) oluşur ve filtreleme amacıyla bir veya daha fazla etiket içerebilir.

• Chunk: Bir skey içindeki veri depolama birimidir. Her chunk birden fazla veri noktası saklar.

  • Varsayılan chunk kapasitesi 256'dır. Sıkıştırma olmadan bir chunk en fazla 256 veri noktası saklar. Sıkıştırma etkinleştirildiğinde, sıkıştırma oranına bağlı olarak bir chunk 256'dan fazla veri noktası saklayabilir.

  • Chunk'lar en küçük son kullanma birimidir. İçindeki tüm veri noktalarının süresi dolduğunda chunk silinir.

• Veri noktası: Tek bir zaman serisi ölçümüdür; Unix zaman damgasından (milisaniye cinsinden) ve DOUBLE türünde bir değerden oluşur.

Çok seviyeli yapı (pkey → skey → chunk → veri noktası), ilişkili zaman çizelgelerini gruplamanıza ve uygulama kodunuza toplu işlem mantığı gömmeden tek bir komutla birden fazla skey üzerinde toplu sorgular çalıştırmanıza olanak tanır.

Çoklu zaman çizelgesi toplu sorgularının yanı sıra TairTS aşağıdaki yetenekleri de sunar:

• Geçmiş zaman serisi verilerinin güncellenmesi ve biriktirilmesi.

• Zaman çizelgesi düzeyinde TTL ayarlama; bu sayede her zaman çizelgesi belirli bir zaman penceresine göre otomatik olarak kaydırılabilir.

• Özel depolama optimizasyonlarıyla donatılmış verimli Gorilla sıkıştırma algoritması; maliyetleri önemli ölçüde azaltır.

Kullanım senaryoları

• İzlenen verilerin depolanması ve işlenmesi

• Uygulama performans yönetimi (APM) için saniyelik izleme

• Nesnelerin İnterneti (IoT) için veri analitiği ve işleme

• Zaman pencereleri üzerinden veri analitiği

• Popüler haber akışlarının önbelleğe alınması

• Kısıtlama senaryolarında risk kontrolü

Ön koşullar

Başlamadan önce şunlara sahip olduğunuzdan emin olun:

• Bir Tair DRAM tabanlı örnek

• Örnek Redis 5.0 ile uyumluysa: küçük sürüm 1.7.20 veya üzeri

En iyi özellik desteği ve kararlılık için örneği en son küçük sürüme güncelleyin. Küme ve okuma/yazma ayrımı yapan örnekler için, tüm komutların beklendiği gibi çalışmasını sağlamak adına proxy düğümlerini de en son küçük sürüme güncelleyin. Daha fazla bilgi için bkz. Bir örneğin küçük sürümünü güncelleme.

Kullanım notları

• TairTS verileri Tair örneğinde depolanır.

• TairTS gerçek zamanlı, yüksek eşzamanlı yazma ve sorgulamaları destekler ancak depolama kapasitesi sınırlıdır. Süresi dolan verilerin hızla silinmesini sağlamak için TairTS verilerine bir TTL ayarlayın.

En iyi uygulamalar

Komut listesi

Komut sözdizimi kuralları:

BÜYÜK HARF ANAHTAR KELIME : komut anahtar kelimesi

_İtalik metin_ : değişken

[seçenekler] : isteğe bağlı parametre

A|B : birbirini dışlayan seçenekler

... : önceki parametre tekrarlanabilir

EXTS.P.CREATE

Örnek:

EXTS.P.CREATE foo

Çıktı:

OK

EXTS.S.CREATE

Parametreler:

Örnek:

EXTS.S.CREATE foo temperature DATA_ET 10000000 LABELS sensor_id 1

Çıktı:

OK

EXTS.S.ALTER

Parametreler:

Örnek:

EXTS.S.ALTER foo temperature DATA_ET 100000

Çıktı:

OK

EXTS.S.ADD

Parametreler:

Örnek:

EXTS.S.ADD foo temperature * 30.5 DATA_ET 1000000 LABELS sensor_id 1

Çıktı:

OK

EXTS.S.MADD

Parametreler:

Örnek:

EXTS.S.MADD foo 3 temperature * 30.2 pressure * 2.05 distance * 0.5

Çıktı:

1) OK
2) OK
3) OK

EXTS.S.INCRBY

Parametreler:

Örnek:

Önce bir başlangıç veri noktası ekleyin:

EXTS.S.ADD foo temperature 1644310456023 30.0

Ardından artırın:

EXTS.S.INCRBY foo temperature 1644372093031 2

Çıktı:

OK

Sonucu doğrulayın:

EXTS.S.GET foo temperature

Çıktı:

1) (integer) 1644372093031
2) "32"

EXTS.S.MINCRBY

Parametreler:

Örnek:

EXTS.S.MINCRBY foo 3 temperature * 0.2 pressure * -0.1 distance * 0.0

Çıktı:

1) OK
2) OK
3) OK

EXTS.S.DEL

Örnek:

EXTS.S.DEL foo temperature

Çıktı:

OK

EXTS.S.GET

Örnek:

EXTS.S.GET foo temperature

Çıktı:

1) (integer) 1644372730150
2) "32.2"

EXTS.S.INFO

Örnek:

EXTS.S.INFO foo temperature

Çıktı:

 1) totalDataPoints            // Number of data points
 2) (integer) 1
 3) maxDataPoints              // Maximum data points the skey can hold (0 = no limit)
 4) (integer) 0
 5) maxDataPointsPerChunk      // Data points per chunk
 6) (integer) 32
 7) dataPointsExpireTime       // Relative expiration time in milliseconds (0 = no expiration)
 8) (integer) 0
 9) lastTimestamp              // Timestamp of the latest data point
10) (integer) 1644389400996
11) chunkCount                 // Number of chunks in the skey
12) (integer) 1
13) lastValue                  // Value of the latest data point
14) (integer) 28
15) labels                     // Label information
16) 1) 1) "sensor_id"
       2) "1"

EXTS.S.QUERYINDEX

Parametreler:

Örnek:

EXTS.S.QUERYINDEX foo sensor_id=1

Çıktı:

1) "temperature"

EXTS.S.RANGE

Parametreler:

Yanıt, son öğe olarak bir devam belirteci içerir:

• 0: eşleşen tüm veri noktaları döndürüldü

• 1: bazı veri noktaları dahil edilmedi. Kalan verileri almak için sonraki fromTs olarak son döndürülen veri noktasının zaman damgasını kullanın.

Örnek:

EXTS.S.RANGE foo test 1644459031662 * AGGREGATION AVG 10000 MAXCOUNT 2

Bu komut, 10 saniyelik kova başına ortalama değeri döndürür ve sonucu 2 ile sınırlar.

Çıktı:

1) 1) 1) (integer) 1644459730000
      2) "20.6"
   2) 1) (integer) 1644459790000
      2) "21.2"
2) (integer) 1

1 belirteci, bu 2 sonucun ötesinde daha fazla veri noktası olduğunu gösterir.

EXTS.S.MRANGE

Parametreler:

Örnek:

EXTS.S.MRANGE foo 1644451031662 * AGGREGATION MAX 10000 WITHLABELS FILTER sensor_id=1

Çıktı:

1) 1) "temperature"
   2) 1) 1) "sensor_id"
         2) "1"
   3) 1) 1) (integer) 1644481000000
         2) "30"
   4) (integer) 0
2) 1) "test"
   2) 1) 1) "sensor_id"
         2) "1"
   3) 1) 1) (integer) 1644459730000
         2) "20"
      2) 1) (integer) 1644459790000
         2) "20"
      3) 1) (integer) 1644460620000
         2) "29"
   4) (integer) 0

EXTS.P.RANGE

Parametreler:

Örnek:

EXTS.P.RANGE foo 1644451031662 * SUM 500000 AGGREGATION SUM 10000 FILTER sensor_id=1

Çıktı:

1) 1) 1) (integer) 1644459500000
      2) "40"
   2) 1) (integer) 1644460500000
      2) "29"
   3) 1) (integer) 1644481000000
      2) "30"
2) (integer) 0

EXTS.S.RAW_MODIFY

Parametreler:

Örnek:

EXTS.S.RAW_MODIFY foo temperature 1644310456023 31.5

Çıktı:

OK

EXTS.S.RAW_MMODIFY

Parametreler:

Örnek:

EXTS.S.RAW_MMODIFY foo 3 temperature 1644565954814 30.2 pressure 1644565954814 2.05 distance 1644565954814 0.5

Çıktı:

1) OK
2) OK
3) OK

EXTS.S.RAW_INCRBY

Parametreler:

Örnek:

Önce bir başlangıç veri noktası ekleyin:

EXTS.S.ADD foo temperature 1644310456 30.0

Ardından aynı zaman damgasına bir artış uygulayın:

EXTS.S.RAW_INCRBY foo temperature 1644310456 3.3

Çıktı:

OK

Sonucu doğrulayın:

EXTS.S.GET foo temperature

Çıktı:

1) (integer) 1644310456
2) "33.3"

EXTS.S.RAW_MINCRBY

Parametreler:

Örnek:

EXTS.S.RAW_MINCRBY foo 3 temperature 1644565954814 30.2 pressure 1644565954814 2.05 distance 1644565954814 0.5

Çıktı:

1) OK
2) OK
3) OK

Dizin filtreleme sözdizimi

EXTS.S.QUERYINDEX, EXTS.S.MRANGE ve EXTS.P.RANGE komutlarında skey seçmek için etiket filtrelerini kullanın. En az bir EQ, CONTAINS veya LIST_MATCH koşulu gereklidir.

Toplu işlem sözdizimi

Toplu işlem, timeBucket ile tanımlanan her zaman kovası içindeki veri noktalarını gruplar ve kova başına tek bir değer hesaplar. Aşağıdaki toplu işlem türleri desteklenir:

SSS

Redis 5.0 ile uyumlu bazı Tair DRAM tabanlı örneklerde varsayılan CHUNK_SIZE neden küçüktür?

25.2.0.0 sürümünden itibaren CHUNK_SIZE varsayılan olarak 256'dır. Önceki sürümlerde varsayılan değer 32'dir.

Sonraki adımlar

• TairTS kullanarak saniyelik izleme uygulama