Tair (Redis® OSS-Compatible):TS

Concepts clés

TairTS organise les données selon une hiérarchie à trois niveaux :

• Pkey : conteneur nommé regroupant un ensemble de chronologies associées (skeys). Chaque pkey peut contenir plusieurs skeys.

• Skey : chronologie unique au sein d'un pkey. Un skey est composé de plusieurs chunks de capacité fixe et peut comporter un ou plusieurs labels pour le filtrage.

• Chunk : unité de stockage des données au sein d'un skey. Chaque chunk stocke plusieurs points de données.

  • La capacité par défaut d'un chunk est de 256. Sans compression, un chunk stocke jusqu'à 256 points de données. Avec la compression activée, un chunk stocke plus de 256 points de données, selon le taux de compression.

  • Les chunks constituent la plus petite unité d'expiration. Un chunk est supprimé lorsque tous ses points de données ont expiré.

• Point de données : mesure unique de série temporelle, composée d'un horodatage Unix (en millisecondes) et d'une valeur de type DOUBLE.

Cette structure multiniveau (pkey → skey → chunk → point de données) vous permet de regrouper des chronologies associées et d'exécuter des requêtes d'agrégation sur plusieurs skeys en une seule commande, sans intégrer de logique d'agrégation dans votre code applicatif.

Outre les requêtes d'agrégation multi-chronologies, TairTS offre les fonctionnalités suivantes :

• Mise à jour et accumulation des données de séries temporelles historiques.

• Définition du TTL au niveau de la chronologie, garantissant que chaque chronologie peut effectuer un défilement automatique selon une fenêtre de temps.

• Algorithme de compression Gorilla efficace avec des optimisations de stockage spécifiques pour réduire significativement les coûts.

Cas d'utilisation

• Stockage et traitement des données de supervision

• Supervision à la seconde pour la gestion des performances applicatives (APM)

• Analyse et traitement des données pour l’Internet des objets (IoT)

• Analyse des données sur des fenêtres temporelles

• Mise en cache des flux d’actualités les plus consultés

• Contrôle des risques dans les scénarios de limitation de débit

Prérequis

Avant de commencer, assurez-vous de disposer des éléments suivants :

• Une instance Tair basée sur DRAM

• Si l'instance est compatible avec Redis 5.0 : version mineure 1.7.20 ou ultérieure

Mettez à jour l'instance vers la dernière version mineure pour bénéficier d'une prise en charge optimale des fonctionnalités et d'une stabilité accrue. Pour les instances en cluster et celles utilisant la séparation lecture/écriture, mettez également à jour les nœuds proxy vers la dernière version mineure afin que toutes les commandes s'exécutent comme prévu. Pour plus d'informations, consultez la rubrique Mettre à jour la version mineure d'une instance.

Remarques sur l'utilisation

• Les données TairTS sont stockées sur l'instance Tair.

• TairTS prend en charge les écritures et les requêtes en temps réel avec une forte concurrence, mais sa capacité de stockage est limitée. Définissez une durée de vie (TTL) pour les données TairTS afin que les données expirées soient supprimées rapidement.

Bonnes pratiques

Liste des commandes

Conventions de syntaxe des commandes :

MOT_CLÉ_EN_MAJUSCULE : mot clé de commande

_Texte en italique_ : variable

[options] : paramètre facultatif

A|B : options mutuellement exclusives

... : le paramètre précédent peut être répété

EXTS.P.CREATE

Exemple :

EXTS.P.CREATE foo

Résultat :

OK

EXTS.S.CREATE

Paramètres :

Exemple :

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

Résultat :

OK

EXTS.S.ALTER

Paramètres :

Exemple :

EXTS.S.ALTER foo temperature DATA_ET 100000

Résultat :

OK

EXTS.S.ADD

Paramètres :

Exemple :

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

Sortie :

OK

EXTS.S.MADD

Paramètres :

Exemple :

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

Sortie :

1) OK
2) OK
3) OK

EXTS.S.INCRBY

Paramètres :

Exemple :

Commencez par ajouter un point de données initial :

EXTS.S.ADD foo temperature 1644310456023 30.0

Ensuite, incrémentez-le :

EXTS.S.INCRBY foo temperature 1644372093031 2

Résultat :

OK

Vérifiez le résultat :

EXTS.S.GET foo temperature

Résultat :

1) (integer) 1644372093031
2) "32"

EXTS.S.MINCRBY

Paramètres :

Exemple :

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

Sortie :

1) OK
2) OK
3) OK

EXTS.S.DEL

Exemple :

EXTS.S.DEL foo temperature

Résultat :

OK

EXTS.S.GET

Exemple :

EXTS.S.GET foo temperature

Résultat :

1) (integer) 1644372730150
2) "32.2"

EXTS.S.INFO

Exemple :

EXTS.S.INFO foo temperature

Sortie :

 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

Paramètres :

Exemple :

EXTS.S.QUERYINDEX foo sensor_id=1

Résultat :

1) "temperature"

EXTS.S.RANGE

Paramètres :

La réponse inclut un jeton de continuation en tant que dernier élément :

• 0 : tous les points de données correspondants sont renvoyés

• 1 : certains points de données ne sont pas inclus. Utilisez l'horodatage du dernier point de données renvoyé comme prochain fromTs pour récupérer les données restantes.

Exemple :

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

Cette commande renvoie la valeur moyenne par compartiment de 10 secondes, limitée à 2 résultats.

Sortie :

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

Le jeton 1 indique qu'il existe d'autres points de données au-delà de ces 2 résultats.

EXTS.S.MRANGE

Paramètres :

Exemple :

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

Sortie :

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

Paramètres :

Exemple :

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

Sortie :

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

Paramètres :

Exemple :

EXTS.S.RAW_MODIFY foo temperature 1644310456023 31.5

Résultat :

OK

EXTS.S.RAW_MMODIFY

Paramètres :

Exemple :

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

Sortie :

1) OK
2) OK
3) OK

EXTS.S.RAW_INCRBY

Paramètres :

Exemple :

Tout d'abord, ajoutez un point de données initial :

EXTS.S.ADD foo temperature 1644310456 30.0

Appliquez ensuite un incrément au même horodatage :

EXTS.S.RAW_INCRBY foo temperature 1644310456 3.3

Résultat :

OK

Vérifiez le résultat :

EXTS.S.GET foo temperature

Résultat :

1) (integer) 1644310456
2) "33.3"

EXTS.S.RAW_MINCRBY

Paramètres :

Exemple :

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

Résultat :

1) OK
2) OK
3) OK

Syntaxe de filtrage d'index

Utilisez des filtres de libellé pour sélectionner les skeys dans EXTS.S.QUERYINDEX, EXTS.S.MRANGE et EXTS.P.RANGE. Au moins une condition EQ, CONTAINS ou LIST_MATCH est requise.

Syntaxe d'agrégation

L'agrégation regroupe les points de données au sein de chaque intervalle temporel défini par timeBucket et calcule une valeur unique pour chaque intervalle. Les types d'agrégation suivants sont pris en charge :

FAQ

Pourquoi la valeur par défaut de CHUNK_SIZE est-elle faible sur certaines instances Tair basées sur DRAM compatibles avec Redis 5.0 ?

À partir de la version 25.2.0.0, la valeur par défaut de CHUNK_SIZE est 256. Dans les versions antérieures, elle est définie par défaut à 32.

Étapes suivantes

• Mettre en œuvre une surveillance à la seconde près avec TairTS