Cassandra activer le traçage des requêtes

La journalisation est une fonctionnalité fantastique qui nous permet de retracer rapidement et facilement tous les problèmes sur le serveur. Malheureusement, bien que Cassandra offre des fonctionnalités de journalisation approfondies, il ne enregistre pas les requêtes exécutées sur les nœuds par défaut.

Grâce à ce post, vous découvrirez comment activer et désactiver le traçage des requêtes dans les nœuds de Cassandra.

Commande de traçage de Cassandra

Cassandra nous fournit la commande de traçage, qui peut être exécutée dans le shell CQL. Cette commande vous permet d'activer ou de désactiver le traçage pour toutes les requêtes exécutées dans les nœuds d'un cluster donné.

Le traçage vous permet de collecter des journaux de toute transaction effectuée sur le serveur. Les journaux de trace sont ensuite stockés dans les espaces System_traces, qui expireront après une durée TTL donnée. Par défaut, les traces sont stockées dans le tableau pendant 24 heures. Cependant, vous pouvez modifier la valeur TTL ou déplacer les traces vers un autre espace clé.

De plus, l'espace System_traces contient des tableaux tels que la session, qui contient des informations de session, et le tableau des événements, qui a des informations détaillées sur les requêtes.

La syntaxe de commande de traçage est comme indiqué:

Traçage [sur | DÉSACTIVÉ]

Exemple

L'exemple suivant montre comment activer le traçage dans un cluster à quatre nœuds. Nous testerons ensuite les capacités de traçage en créant des données d'échantillons.

Pour activer le traçage, exécutez la commande:

CQLSH> TRACTACE SUR;

Maintenant le traçage est activé

CQLSH>

Ensuite, créons un espace de cale et une table d'échantillonnage.

CQLSH> Créer un magasin Keyspace avec réplication = 'class': 'Simplestrategy', 'réplication_factor': 4;

Une fois que nous exécutons la commande ci-dessus, le shell CQL doit renvoyer des messages de traçage de la commande comme indiqué ci-dessous:

Session de traçage: 0de9b970-3407-11ed-9723-61bf090829c9
Activité | Timestamp | Source | source_elapsed | client
---------------------------------------------------------------------------------------------------------------------------------------+----------------------------+-----------+----------------+-----------
Exécuter la requête CQL3 | 2022-09-14 11:27:22.119000 | 127.0.0.1 | 0 | 127.0.0.1
Parsing Create Keyspace Store avec réplication = 'class': 'Simplestrategy', 'réplication_factor': 4; [Native-Transport-Requests-1] | 2022-09-14 11:27:22.119000 | 127.0.0.1 | 657 | 127.0.0.1
Préparation de la déclaration [Native-Transport-Requests-1] | 2022-09-14 11:27:22.121000 | 127.0.0.1 | 2168 | 127.0.0.1
Ajout de commitlog [migrationstage: 1] | 2022-09-14 11:27:22.132000 | 127.0.0.1 | 13136 | 127.0.0.1
Ajout à Keyspaces MemTable [migrationstage: 1] | 2022-09-14 11:27:22.133000 | 127.0.0.1 | 13941 | 127.0.0.1
Ajout de commitlog [compactexecutor: 3] | 2022-09-14 11:27:22.400000 | 127.0.0.1 | 280829 | 127.0.0.1
Ajout à compact_history memTable [compactexecutor: 3] | 2022-09-14 11:27:22.400000 | 127.0.0.1 | 281512 | 127.0.0.1
Ajout de commitlog [CompactExecutor: 4] | 2022-09-14 11:27:22.498000 | 127.0.0.1 | 379253 | 127.0.0.1
Ajout à compact_history memTable [compactExecutor: 4] | 2022-09-14 11:27:22.498000 | 127.0.0.1 | 379782 | 127.0.0.1
Ajout de commitlog [compactexecutor: 3] | 2022-09-14 11:27:22.627000 | 127.0.0.1 | 508643 | 127.0.0.1
Ajout à compact_history memTable [compactexecutor: 3] | 2022-09-14 11:27:22.628000 | 127.0.0.1 | 509209 | 127.0.0.1
Ajout de commitlog [CompactExecutor: 4] | 2022-09-14 11:27:22.778000 | 127.0.0.1 | 659647 | 127.0.0.1
Ajout à compact_history memTable [compactExecutor: 4] | 2022-09-14 11:27:22.779000 | 127.0.0.1 | 660218 | 127.0.0.1
Exécution du scan SEQ sur 2 sstables pour (min (-9223372036854775808), min (-9223372036854775808)] [MigrationStage: 1] | 2022-09-14 11:27:22.846000 | 127.0.0.1 | 726928 | 127.0.0.1
Lire 66 lignes vivantes et 0 cellules de pierre tombale [Migration Stage: 1] | 2022-09-14 11:27:22.851000 | 127.0.0.1 | 732009 | 127.0.0.1
Ajout de commitlog [compactexecutor: 3] | 2022-09-14 11:27:22.852000 | 127.0.0.1 | 733610 | 127.0.0.1
-----------------Sortie tronquée-------------------

Nous pouvons ensuite créer une table et effectuer une opération d'écriture comme indiqué:

CQLSH> Créer un magasin de table.Inventaire (id int, Product_name Text, prix int, clé primaire (id));

De même, la commande doit renvoyer le journal de traçage comme:

Nous pouvons insérer des exemples de données comme:

CQLSH> Insérer dans le magasin.Inventaire (id, product_name, prix) Valeurs (1, «Product1», 10);

La demande d'écriture produit la trace comme indiqué:

Enfin, nous pouvons sélectionner les éléments de la table qui doivent renvoyer la trace pour une analyse séquentielle comme indiqué:

CQLSH> Sélectionner * dans le magasin.inventaire;

Sortie de trace:

Conclusion

Cet article a expliqué comment vous pouviez permettre le traçage des requêtes dans votre cluster Cassandra en utilisant la commande de traçage.