- Apache Cassandra : CLI, keyspaces et clusters

cassandra

Démarre le serveur Cassandra (foreground)

cassandra -f

Démarre en foreground (logs dans la console)

cassandra -p /var/run/cassandra.pid

Démarre avec fichier PID

cassandra -R

Démarre en tant que root (déconseillé)

nodetool

Outil d'administration Cassandra

nodetool status

Affiche l'état du cluster (nœuds, load, tokens)

nodetool info

Informations sur le nœud local

nodetool ring

Affiche l'anneau de tokens

nodetool describecluster

Décrit le cluster (name, snitch, partitioner)

nodetool version

Affiche la version de Cassandra

nodetool gossipinfo

Informations du protocole Gossip

nodetool tpstats

Statistiques des pools de threads

nodetool netstats

Statistiques réseau

nodetool cfstats

Statistiques des colonnes familles (tables)

nodetool cfstats -H mon_keyspace.ma_table

Statistiques d'une table spécifique (format lisible)

nodetool tablestats

Alias de cfstats (statistiques des tables)

nodetool compactionstats

Statut des compactions en cours

nodetool netstats

Statistiques des connexions réseau

nodetool proxyhistograms

Histogrammes des latences

nodetool tablehistograms mon_keyspace ma_table

Histogrammes de latence pour une table

nodetool flush

Flushe les memtables vers le disque

nodetool flush mon_keyspace ma_table

Flushe une table spécifique

nodetool compact

Force une compaction

nodetool compact mon_keyspace ma_table

Compacte une table spécifique

nodetool cleanup

Nettoie les données qui n'appartiennent plus au nœud

nodetool cleanup mon_keyspace ma_table

Nettoie une table spécifique

nodetool repair

Répare les données incohérentes

nodetool repair -pr mon_keyspace

Répare uniquement les ranges primaires

nodetool repair -full mon_keyspace ma_table

Répare complètement une table

nodetool repair -inc mon_keyspace

Répare de manière incrémentale

nodetool scrub

Nettoie les données corrompues

nodetool scrub -ns mon_keyspace ma_table

Scrub sans créer de snapshot

nodetool clearsnapshot

Supprime les snapshots

nodetool clearsnapshot -t mon_tag

Supprime un snapshot spécifique

nodetool snapshot

Prend un snapshot des données

nodetool snapshot -t backup_2024 mon_keyspace

Snapshot avec tag personnalisé

nodetool listsnapshots

Liste tous les snapshots

nodetool refresh

Recharge les SSTables nouvellement ajoutées

nodetool drain

Vide les memtables et arrête les écritures (avant arrêt)

nodetool stopdaemon

Arrête le démon Cassandra

nodetool decommission

Retire le nœud du cluster (streaming des données)

nodetool removenode

Force la suppression d'un nœud mort

nodetool removenode 12345678-1234-1234-1234-123456789abc

Supprime un nœud par son Host ID

nodetool removenode status

Affiche le statut des suppressions de nœuds

nodetool assassinate

Tue un nœud mort (sans streamer les données)

nodetool assassinate 192.168.1.10

Assassine le nœud à cette adresse

nodetool rebuild

Reconstruit les données d'un datacenter

nodetool rebuild -- datacenter2

Reconstruit depuis datacenter2

nodetool rebuild_index

Reconstruit les index secondaires

nodetool rebuild_index mon_keyspace ma_table idx_name

Reconstruit un index spécifique

nodetool setlogginglevel

Change le niveau de log dynamiquement

nodetool setlogginglevel org.apache.cassandra DEBUG

Met les logs Cassandra en DEBUG

nodetool getlogginglevels

Affiche les niveaux de log actuels

nodetool settraceprobability

Définit la probabilité de tracing

nodetool settraceprobability 0.1

Trace 10% des requêtes

nodetool gettraceprobability

Affiche la probabilité de tracing

nodetool setstreamthroughput

Définit le débit de streaming (Mb/s)

nodetool setstreamthroughput 200

Définit le streaming à 200 Mb/s

nodetool getstreamthroughput

Affiche le débit de streaming

nodetool setcompactionthroughput

Définit le débit de compaction (Mb/s)

nodetool setcompactionthroughput 64

Définit la compaction à 64 Mb/s

nodetool getcompactionthroughput

Affiche le débit de compaction

nodetool setconcurrentcompactors

Définit le nombre de compacteurs concurrents

nodetool getconcurrentcompactors

Affiche le nombre de compacteurs

nodetool enablebackup

Active la sauvegarde incrémentale

nodetool disablebackup

Désactive la sauvegarde incrémentale

nodetool statusbackup

Affiche l'état de la sauvegarde incrémentale

nodetool enableauditlog

Active l'audit log

nodetool disableauditlog

Désactive l'audit log

nodetool enablefullquerylog

Active le full query log

nodetool disablefullquerylog

Désactive le full query log

nodetool enablegossip

Active le protocole Gossip

nodetool disablegossip

Désactive le protocole Gossip

nodetool enablethrift

Active le serveur Thrift (déprécié)

nodetool disablethrift

Désactive le serveur Thrift

nodetool enablebinary

Active le protocole binaire natif (CQL)

nodetool disablebinary

Désactive le protocole binaire natif

nodetool enablehandoff

Active le hinted handoff

nodetool disablehandoff

Désactive le hinted handoff

nodetool statushandoff

Affiche l'état du hinted handoff

nodetool pausehandoff

Met en pause le hinted handoff

nodetool resumehandoff

Reprend le hinted handoff

nodetool failuredetector

Affiche les informations du détecteur de pannes

nodetool toppartitions

Affiche les partitions les plus actives

nodetool toppartitions -k mon_keyspace -t ma_table -d 10000 -s 5

Top 5 partitions sur 10 secondes

nodetool sjk

Swiss Java Knife - outils de diagnostic JVM

nodetool sjk mx

Affiche les informations MBeans

nodetool sjk gc

Informations sur le Garbage Collector

nodetool verify

Vérifie les checksums des SSTables

nodetool verify -e mon_keyspace ma_table

Vérification étendue d'une table

nodetool upgradesstables

Met à niveau les SSTables vers le format actuel

nodetool upgradesstables -a mon_keyspace

Met à niveau toutes les SSTables

nodetool resetlocalschema

Réinitialise le schéma local et le resynchronise

nodetool reloadlocalschema

Recharge le schéma local depuis le disque

nodetool reloadseeds

Recharge la liste des seeds depuis la config

nodetool reloadtriggers

Recharge les triggers

nodetool move

Déplace le token du nœud

nodetool move 3074457345618258602

Déplace vers un nouveau token

nodetool setcachecapacity

Définit la capacité du cache

nodetool setcachecapacity -k mon_keyspace -t ma_table 100 200

Définit key cache à 100 MB, row cache à 200 MB

nodetool getcachecapacity

Affiche la capacité des caches

nodetool setcachekeystosave

Définit le nombre de clés de cache à sauvegarder

nodetool getcachekeystosave

Affiche les paramètres de sauvegarde des caches

nodetool invalidatekeycache

Invalide le key cache

nodetool invalidaterowcache

Invalide le row cache

nodetool invalidatecountercache

Invalide le counter cache

nodetool viewbuildstatus

Statut de construction des vues matérialisées

nodetool stop

Arrête la compaction, le repair ou le cleanup

nodetool stop COMPACTION

Arrête toutes les compactions

nodetool stop REPAIR

Arrête toutes les réparations

cqlsh

Shell interactif CQL (Cassandra Query Language)

cqlsh -h localhost -p 9042 -u cassandra -p cassandra

Connexion avec authentification

cqlsh -k mon_keyspace

Connexion directe à un keyspace

cqlsh -e "SELECT * FROM ma_table"

Exécute une commande et quitte

cqlsh -f script.cql

Exécute un fichier CQL

cqlsh --ssl

Connexion SSL

DESCRIBE CLUSTER

[CQL] Décrit le cluster

DESCRIBE KEYSPACES

[CQL] Liste tous les keyspaces

DESCRIBE KEYSPACE mon_keyspace

[CQL] Décrit un keyspace

DESCRIBE TABLES

[CQL] Liste les tables du keyspace courant

DESCRIBE TABLE ma_table

[CQL] Décrit une table

DESCRIBE TYPES

[CQL] Liste les types définis par l'utilisateur

DESCRIBE FUNCTIONS

[CQL] Liste les fonctions définies par l'utilisateur

DESCRIBE AGGREGATES

[CQL] Liste les agrégats définis par l'utilisateur

DESCRIBE MATERIALIZED VIEWS

[CQL] Liste les vues matérialisées

DESCRIBE INDEX

[CQL] Liste les index secondaires

DESC

[CQL] Alias de DESCRIBE

SHOW VERSION

[CQL] Affiche la version de Cassandra

SHOW HOST

[CQL] Affiche l'hôte de connexion

SHOW SESSION

[CQL] Affiche les informations de session

USE mon_keyspace

[CQL] Change de keyspace

CREATE KEYSPACE mon_keyspace WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 3}

[CQL] Crée un keyspace avec SimpleStrategy

CREATE KEYSPACE mon_keyspace WITH replication = {'class': 'NetworkTopologyStrategy', 'DC1': 3, 'DC2': 2}

[CQL] Crée un keyspace avec NetworkTopologyStrategy

ALTER KEYSPACE mon_keyspace WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}

[CQL] Modifie un keyspace

DROP KEYSPACE mon_keyspace

[CQL] Supprime un keyspace

CREATE TABLE ma_table (id UUID PRIMARY KEY, name text, age int, email text)

[CQL] Crée une table

CREATE TABLE ma_table (id UUID, created_at timestamp, name text, PRIMARY KEY (id, created_at)) WITH CLUSTERING ORDER BY (created_at DESC)

[CQL] Table avec clé composite et ordre de clustering

CREATE TABLE ma_table (id UUID PRIMARY KEY, name text) WITH compaction = {'class': 'LeveledCompactionStrategy'}

[CQL] Table avec LeveledCompactionStrategy

CREATE TABLE ma_table (id UUID PRIMARY KEY, name text) WITH compression = {'sstable_compression': 'LZ4Compressor'}

[CQL] Table avec compression LZ4

CREATE TABLE ma_table (id UUID PRIMARY KEY, name text) WITH default_time_to_live = 86400

[CQL] Table avec TTL par défaut (24h)

ALTER TABLE ma_table ADD email text

[CQL] Ajoute une colonne

ALTER TABLE ma_table DROP email

[CQL] Supprime une colonne

ALTER TABLE ma_table RENAME name TO full_name

[CQL] Renomme une colonne (clé primaire non modifiable)

ALTER TABLE ma_table WITH compaction = {'class': 'SizeTieredCompactionStrategy'}

[CQL] Modifie la stratégie de compaction

ALTER TABLE ma_table WITH gc_grace_seconds = 864000

[CQL] Modifie le gc_grace_seconds (10 jours)

DROP TABLE ma_table

[CQL] Supprime une table

TRUNCATE TABLE ma_table

[CQL] Vide une table

CREATE INDEX ON ma_table (email)

[CQL] Crée un index secondaire

CREATE INDEX idx_email ON ma_table (email)

[CQL] Crée un index avec nom personnalisé

CREATE CUSTOM INDEX ON ma_table (email) USING 'org.apache.cassandra.index.sasi.SASIIndex' WITH OPTIONS = {'mode': 'CONTAINS'}

[CQL] Crée un index SASI (recherche full-text)

DROP INDEX idx_email

[CQL] Supprime un index

CREATE MATERIALIZED VIEW mv_users_by_email AS SELECT email, id, name FROM ma_table WHERE email IS NOT NULL PRIMARY KEY (email, id)

[CQL] Crée une vue matérialisée

ALTER MATERIALIZED VIEW mv_users_by_email WITH compaction = {'class': 'LeveledCompactionStrategy'}

[CQL] Modifie une vue matérialisée

DROP MATERIALIZED VIEW mv_users_by_email

[CQL] Supprime une vue matérialisée

CREATE TYPE address (street text, city text, zip text)

[CQL] Crée un type défini par l'utilisateur (UDT)

ALTER TYPE address ADD country text

[CQL] Ajoute un champ à un UDT

DROP TYPE address

[CQL] Supprime un UDT

CREATE TABLE users (id UUID PRIMARY KEY, addr frozen<address>)

[CQL] Table utilisant un UDT

CREATE FUNCTION avg_state (state tuple<int, int>, val int) RETURNS NULL ON NULL INPUT RETURNS tuple<int, int> LANGUAGE java AS '...'

[CQL] Crée une fonction définie par l'utilisateur (UDF)

DROP FUNCTION avg_state

[CQL] Supprime une UDF

CREATE AGGREGATE average(int) SFUNC avg_state STYPE tuple<int, int> FINALFUNC avg_final INITCOND (0, 0)

[CQL] Crée un agrégat défini par l'utilisateur (UDA)

DROP AGGREGATE average

[CQL] Supprime un UDA

CREATE TRIGGER mon_trigger ON ma_table USING 'org.apache.cassandra.triggers.AuditTrigger'

[CQL] Crée un trigger

DROP TRIGGER mon_trigger ON ma_table

[CQL] Supprime un trigger

INSERT INTO ma_table (id, name, age) VALUES (uuid(), 'John', 30)

[CQL] Insère un document

INSERT INTO ma_table (id, name, age) VALUES (uuid(), 'John', 30) USING TTL 86400

[CQL] Insère avec TTL de 24h

INSERT INTO ma_table (id, name, age) VALUES (uuid(), 'John', 30) IF NOT EXISTS

[CQL] Insère seulement si n'existe pas (lightweight transaction)

UPDATE ma_table SET age = 31 WHERE id = 123e4567-e89b-12d3-a456-426614174000

[CQL] Met à jour un document

UPDATE ma_table SET age = 31 WHERE id = ... IF age = 30

[CQL] Mise à jour conditionnelle (LWT)

UPDATE ma_table SET emails = emails + {'new@example.com'} WHERE id = ...

[CQL] Ajoute à une collection (set)

UPDATE ma_table SET phones = phones - {'old'} WHERE id = ...

[CQL] Retire d'une collection (set)

UPDATE ma_table SET counters = counters + 1 WHERE id = ...

[CQL] Incrémente un compteur

DELETE FROM ma_table WHERE id = ...

[CQL] Supprime une ligne

DELETE age FROM ma_table WHERE id = ...

[CQL] Supprime une colonne spécifique

DELETE emails['old@example.com'] FROM ma_table WHERE id = ...

[CQL] Supprime un élément d'une map

BATCH BEGIN INSERT INTO ma_table (id, name) VALUES (uuid(), 'John') INSERT INTO ma_table (id, name) VALUES (uuid(), 'Jane') APPLY BATCH

[CQL] Exécute un batch d'opérations

SELECT * FROM ma_table

[CQL] Sélectionne toutes les colonnes

SELECT name, age FROM ma_table WHERE id = ...

[CQL] Sélectionne des colonnes spécifiques

SELECT * FROM ma_table WHERE id IN (uuid1, uuid2, uuid3)

[CQL] Sélectionne par liste d'IDs

SELECT * FROM ma_table WHERE id = ... AND created_at > '2024-01-01'

[CQL] Requête sur clé de partition et clustering

SELECT * FROM ma_table WHERE name = 'John' ALLOW FILTERING

[CQL] Requête sur colonne non indexée (à éviter)

SELECT * FROM ma_table WHERE email CONTAINS 'example.com' ALLOW FILTERING

[CQL] Requête CONTAINS sur collection

SELECT * FROM ma_table LIMIT 10

[CQL] Limite le nombre de résultats

SELECT * FROM ma_table PER PARTITION LIMIT 1

[CQL] Limite par partition

SELECT token(id) FROM ma_table

[CQL] Affiche le token d'une clé de partition

SELECT * FROM ma_table WHERE token(id) > token(uuid()) LIMIT 100

[CQL] Pagination par token

SELECT JSON * FROM ma_table

[CQL] Retourne les résultats en JSON

INSERT INTO ma_table JSON '{"id": "...", "name": "John"}'

[CQL] Insère depuis JSON

SELECT COUNT(*) FROM ma_table

[CQL] Compte les lignes

SELECT WRITETIME(name) FROM ma_table WHERE id = ...

[CQL] Affiche le timestamp d'écriture

SELECT TTL(name) FROM ma_table WHERE id = ...

[CQL] Affiche le TTL restant

TRACING ON

[CQL] Active le tracing des requêtes

TRACING OFF

[CQL] Désactive le tracing

PAGING ON

[CQL] Active la pagination

PAGING OFF

[CQL] Désactive la pagination

PAGING 100

[CQL] Définit la taille de page à 100

EXPAND ON

[CQL] Affiche les résultats verticalement

EXPAND OFF

[CQL] Affiche les résultats en tableau

CONSISTENCY

[CQL] Affiche le niveau de cohérence courant

CONSISTENCY QUORUM

[CQL] Définit la cohérence à QUORUM

SERIAL CONSISTENCY

[CQL] Affiche la cohérence série

SERIAL CONSISTENCY LOCAL_SERIAL

[CQL] Définit la cohérence série

LOGIN cassandra

[CQL] Se connecter avec un autre utilisateur

LIST USERS

[CQL] Liste les utilisateurs

CREATE USER monuser WITH PASSWORD 'monmotdepasse'

[CQL] Crée un utilisateur

CREATE USER monuser WITH PASSWORD 'monmotdepasse' SUPERUSER

[CQL] Crée un superutilisateur

ALTER USER monuser WITH PASSWORD 'nouveau'

[CQL] Change le mot de passe

DROP USER monuser

[CQL] Supprime un utilisateur

LIST ROLES

[CQL] Liste les rôles

CREATE ROLE monrole

[CQL] Crée un rôle

GRANT SELECT ON KEYSPACE mon_keyspace TO monrole

[CQL] Donne le droit SELECT sur un keyspace

GRANT ALL PERMISSIONS ON KEYSPACE mon_keyspace TO monrole

[CQL] Donne tous les droits sur un keyspace

GRANT MODIFY ON TABLE ma_table TO monrole

[CQL] Donne le droit MODIFY sur une table

REVOKE SELECT ON KEYSPACE mon_keyspace FROM monrole

[CQL] Révoque un droit

LIST PERMISSIONS OF monrole

[CQL] Liste les permissions d'un rôle

GRANT monrole TO monuser

[CQL] Assigne un rôle à un utilisateur

REVOKE monrole FROM monuser

[CQL] Retire un rôle

LIST ROLES OF monuser

[CQL] Liste les rôles d'un utilisateur

CREATE ROLE IF NOT EXISTS monrole WITH LOGIN = true AND PASSWORD = 'secret'

[CQL] Crée un rôle avec login

COPY ma_table (id, name, age) TO 'export.csv' WITH HEADER = true

[CQL] Exporte une table en CSV

COPY ma_table (id, name, age) FROM 'import.csv' WITH HEADER = true

[CQL] Importe un CSV dans une table

COPY ma_table TO STDOUT

[CQL] Exporte vers la sortie standard

COPY ma_table FROM STDIN

[CQL] Importe depuis l'entrée standard

SOURCE 'script.cql'

[CQL] Exécute un fichier CQL

CAPTURE 'output.txt'

[CQL] Capture la sortie dans un fichier

CAPTURE OFF

[CQL] Arrête la capture

CLEAR

[CQL] Efface l'écran

EXIT

[CQL] Quitte cqlsh

QUIT

[CQL] Alias de EXIT

HELP

[CQL] Affiche l'aide

sstableloader

Charge des SSTables dans un cluster

sstableloader -d 192.168.1.10,192.168.1.11 /path/to/sstables

Charge des SSTables vers les nœuds spécifiés

sstableloader -d localhost -u cassandra -pw cassandra /data/sstables

Charge avec authentification

sstableutil

Utilitaire de manipulation des SSTables

sstableutil list /var/lib/cassandra/data/mon_keyspace/ma_table

Liste les SSTables d'une table

sstableutil verify /var/lib/cassandra/data/mon_keyspace/ma_table

Vérifie l'intégrité des SSTables

sstabledump

Affiche le contenu d'une SSTable

sstabledump /path/to/sstable.db

Affiche le contenu d'une SSTable

sstabledump -f json /path/to/sstable.db > dump.json

Exporte en JSON

sstabledump -e /path/to/sstable.db

Énumère toutes les clés

sstablemetadata

Affiche les métadonnées d'une SSTable

sstablemetadata /path/to/sstable.db

Affiche les métadonnées

sstablemetadata -u /path/to/sstable.db

Affiche avec tailles en unités lisibles

sstablelevelreset

Réinitialise les niveaux de compaction (LCS)

sstablelevelreset --really-silent mon_keyspace ma_table

Réinitialise silencieusement

sstableofflinerelevel

Re-nivelle les SSTables pour LCS (offline)

sstableverify

Vérifie les checksums des SSTables

sstableverify -v mon_keyspace ma_table

Vérifie avec logs verbeux

sstableexpiredblockers

Trouve les SSTables bloquant l'expiration

auditlogviewer

Visualise les logs d'audit Cassandra

auditlogviewer -f /var/log/cassandra/audit.log

Affiche les logs d'audit

auditlogviewer -f audit.log -u monuser

Filtre par utilisateur

fqltool

Full Query Log tool - analyse les logs de requêtes

fqltool dump /var/lib/cassandra/fql.log

Affiche le contenu du FQL

fqltool replay --keyspace mon_keyspace --target localhost /var/lib/cassandra/fql.log

Rejoue les requêtes FQL

fqltool compare fql1.log fql2.log

Compare deux fichiers FQL

cassandra-stress

Outil de benchmark Cassandra

cassandra-stress write n=100000 -rate threads=50

Test d'écriture (100k écritures, 50 threads)

cassandra-stress read n=100000 -rate threads=100

Test de lecture (100k lectures, 100 threads)

cassandra-stress mixed ratio(write=1,read=3) n=100000 -rate threads=50

Test mixte (25% écriture, 75% lecture)

cassandra-stress user profile=/path/to/profile.yaml ops(insert=1,query1=3) n=100000

Test avec profil personnalisé

cassandra-stress write -schema replication(factor=3) -pop seq=1..1000000

Test avec population séquentielle

cassandra-stress write -graph file=graph.html title=MonTest

Génère un graphique des résultats