Fonctionnalités Apache Cassandra prises en charge par Azure Cosmos DB for Apache Cassandra

S’APPLIQUE À : Cassandra

Azure Cosmos DB est le service de base de données multi-modèle de Microsoft distribué à l’échelle mondiale. Vous pouvez communiquer avec l’Azure Cosmos DB for Apache Cassandra par le biais des pilotes clients Cassandra open source et conformes au protocole de transmission CQL (Cassandra Query Language) Binary Protocol v4.

En utilisant l’Azure Cosmos DB for Apache Cassandra, vous pouvez bénéficier des avantages des API Cassandra Apache et des fonctionnalités d’entreprise fournies par Azure Cosmos DB. Parmi les fonctionnalités d’entreprise, citons la distribution mondiale, le partitionnement automatique de scale-out, des garanties de disponibilité et de latence, le chiffrement au repos, les sauvegardes et bien plus encore.

Protocole Cassandra

L’Azure Cosmos DB for Apache Cassandra est compatible avec l’API CQL (Cassandra Query Language) v3.11 (compatibilité descendante avec la version 2.x). Les commandes CQL, les outils, les limitations et les exceptions pris en charge sont listés ci-dessous. Les pilotes clients comprenant ces protocoles doivent pouvoir se connecter à Azure Cosmos DB for Apache Cassandra.

Azure Managed Instance pour Apache Cassandra

Pour certains clients, l’adaptation à l’API pour Cassandra peut s’avérer être un défi en raison de différences de comportement et/ou de configuration, en particulier pour des migrations lift-and-shift. Si une fonctionnalité critique pour votre application est répertoriée comme étant non prise en charge ci-dessous, envisagez d’utiliser Azure Managed Instance pour Apache Cassandra. Il s’agit d’un service Azure interne pour l’hébergement et la maintenance de clusters Apache Cassandra open source purs avec une compatibilité à 100 %.

Pilote Cassandra

Les versions suivantes des pilotes Cassandra sont prises en charge par Azure Cosmos DB for Apache Cassandra :

• Java 3.5+
• C# 3.5+
• Nodejs 3.5+
• Python 3.15+
• C++ 2.9
• PHP 1.3
• Gocql

Types de données CQL

Azure Cosmos DB for Apache Cassandra prend en charge les types de données CQL suivants :

Static est pris en charge pour la déclaration du type de données.

Fonctions CQL

Azure Cosmos DB for Apache Cassandra prend en charge les fonctions CQL suivants :

Fonctions d’agrégation :

Fonctions de conversion blob :

Fonctions UUID et timeuuid :

Commandes CQL

Azure Cosmos DB prend en charge les commandes de base de données suivantes sur les comptes d’API pour Cassandra.

Transactions légères (LWT)

Commandes de l’interpréteur de commandes CQL

Azure Cosmos DB prend en charge les commandes de base de données suivantes sur les comptes d’API pour Cassandra.

Prise en charge de JSON

Limites de l’API pour Cassandra

Azure Cosmos DB for Apache Cassandra n’a aucune limite sur la taille des données stockées dans une table. Des centaines de téraoctets ou pétaoctets de données peuvent être stockées tout en garantissant le respect des limites de clé de partition. De même, chaque entité ou ligne équivalente n’a aucune limite de nombre de colonnes. Toutefois, la taille totale de l’entité ne doit pas dépasser 2 Mo. Les données par clé de partition ne peuvent pas dépasser 20 Go, comme dans toutes les autres API.

Outils

Azure Cosmos DB for Apache Cassandra est une plateforme de service géré. La plateforme ne nécessite aucune surcharge de gestion ni aucun utilitaire, comme le Garbage Collector, Java Virtual Machine (JVM) et nodetool, pour gérer le cluster. Des outils tels que cqlsh, qui utilise la compatibilité de CQLv4 binaire, sont pris en charge.

• L’Explorateur de données du portail Azure, les métriques, les diagnostics de journaux, PowerShell et CLI sont d’autres mécanismes pris en charge pour gérer le compte.

Interpréteur de commandes CQL

Vous pouvez vous connecter à l’API pour Cassandra dans Azure Cosmos DB à l’aide de l’interpréteur CQLSH installé sur un ordinateur local. Il est fourni avec Apache Cassandra 3.11 et prêt à fonctionner moyennant la définition des variables d’environnement. Les sections suivantes incluent les instructions d’installation, de configuration et de connexion à l’API pour Cassandra dans Azure Cosmos DB sur Windows ou Linux à l’aide de CQLSH.

Windows :

1. Installer Python 3
2. Installer PIP
   1. Avant d’installer PIP, téléchargez le fichier get-pip.py.
   2. Lancez une invite de commandes si elle n’est pas déjà ouverte. Pour ce faire, ouvrez la barre de recherche Windows, tapez cmd puis sélectionnez l’icône.
   3. Ensuite, exécutez la commande suivante pour télécharger le fichier get-pip.py :

   curl https://bootstrap.pypa.io/get-pip.py -o get-pip.py 
   

3. Installer PIP sur Windows

python get-pip.py

1. Vérifiez l’installation de PIP (recherchez un message de l’étape 3 pour voir dans quel dossier PIP a été installé, puis accédez à ce dossier et exécutez la commande pip help).
2. Installer CQLSH à l’aide de PIP

pip3 install cqlsh==5.0.3

4. Installer Python 2
5. Exécutez CQLSH à l’aide du mécanisme d’authentification.

Installer sur Unix/Linux/Mac :

# Install default-jre and default-jdk
sudo apt install default-jre
sudo apt-get update
sudo apt install default-jdk

# Import the Baltimore CyberTrust root certificate:
curl https://cacert.omniroot.com/bc2025.crt > bc2025.crt
keytool -importcert -alias bc2025ca -file bc2025.crt

# Install the Cassandra libraries in order to get CQLSH:
echo "deb https://downloads.apache.org/cassandra/debian 311x main" | sudo tee -a /etc/apt/sources.list.d/cassandra.sources.list
curl https://downloads.apache.org/cassandra/KEYS | sudo apt-key add -
sudo apt-get update
sudo apt-get install cassandra=3.11.13

Se connecter avec Unix/Linux/Mac :

# Export the SSL variables:
export SSL_VERSION=TLSv1_2
export SSL_VALIDATE=false

# Connect to Azure Cosmos DB for Apache Cassandra:
cqlsh <YOUR_ACCOUNT_NAME>.cassandra.cosmosdb.azure.com 10350 -u <YOUR_ACCOUNT_NAME> -p <YOUR_ACCOUNT_PASSWORD> --ssl --protocol-version=4

Se connecter avec Docker :

docker run -it --rm -e SSL_VALIDATE=false -e SSL_VERSION=TLSv1_2 cassandra:3.11 cqlsh <account_name>.cassandra.cosmos.azure.com 10350 -u <YOUR_ACCOUNT_NAME> -p <YOUR_ACCOUNT_PASSWORD> --ssl

Toutes les opérations CRUD exécutées par le biais d’un Kit de développement logiciel (SDK) compatible CQL v4 retournent des informations supplémentaires sur l’erreur et les unités de demande consommées. Les commandes DELETE et UPDATE doivent être gérées en tenant compte de la gouvernance des ressources, afin de garantir l’utilisation la plus efficace du débit approvisionné.

• Notez que la valeur gc_grace_seconds doit être égale à zéro si elle est spécifiée.

var tableInsertStatement = table.Insert(sampleEntity); 
var insertResult = await tableInsertStatement.ExecuteAsync(); 
 
foreach (string key in insertResult.Info.IncomingPayload) 
        { 
            byte[] valueInBytes = customPayload[key]; 
            double value = Encoding.UTF8.GetString(valueInBytes); 
            Console.WriteLine($"CustomPayload:  {key}: {value}"); 
        } 

Mappage de cohérence

Azure Cosmos DB for Apache Cassandra offre un choix de cohérence pour les opérations de lecture. Le mappage de cohérence est détaillé ici.

Gestion des rôles et des autorisations

Azure Cosmos DB prend en charge le contrôle d’accès en fonction du rôle Azure (Azure RBAC) pour le provisionnement, la rotation de clés, l’affichage des métriques et les mots de passe/clés en lecture-écriture et en lecture seule, qui peuvent être obtenus via le portail Azure. Azure Cosmos DB ne prend pas en charge les rôles pour les activités CRUD.

Options d’espace de clé et de table

Les options pour le nom de région, la classe, replication_factor et le centre de centres dans la commande « CREATE KEYSPACE » sont actuellement ignorées. Le système utilise la méthode de réplication par distribution globale d’Azure Cosmos DB sous-jacente pour ajouter les régions. Si vous avez besoin de la présence de données inter-régions, vous pouvez l’activer au niveau du compte avec PowerShell, CLI ou le portail. Pour en savoir plus, consultez l’article expliquant comment ajouter des régions. Durable_writes ne peut pas être désactivé, car Azure Cosmos DB garantit la durabilité de chaque écriture. Dans chaque région, Azure Cosmos DB réplique les données dans le jeu de réplicas composé de 4 réplicas, et cette configuration de jeu de réplicas ne peut pas être modifiée.

Toutes les options sont ignorées lors de la création de la table, sauf gc_grace_seconds, qui doit être définie sur zéro. L’espace de clé et la table ont une option supplémentaire nommée « cosmosdb_provisioned_throughput » avec une valeur minimale de 400 RU/s. Le débit d’espace de clé permet de partager le débit entre plusieurs tables, et il est utile dans les scénarios où toutes les tables n’utilisent pas le débit provisionné. La commande ALTER TABLE permet de modifier le débit provisionné dans les régions.

CREATE  KEYSPACE  sampleks WITH REPLICATION = {  'class' : 'SimpleStrategy'}   AND cosmosdb_provisioned_throughput=2000;  

CREATE TABLE sampleks.t1(user_id int PRIMARY KEY, lastname text) WITH cosmosdb_provisioned_throughput=2000; 

ALTER TABLE gks1.t1 WITH cosmosdb_provisioned_throughput=10000 ;

Index secondaire

L’API pour Cassandra prend en charge les index secondaires sur tous les types de données, à l’exception des types de collections figés, et des types decimal et variant.

Utilisation de la stratégie de connexion de nouvelle tentative Cassandra

Azure Cosmos DB est un système régi par les ressources. Vous pouvez effectuer un certain nombre d’opérations durant une seconde donnée, en fonction des unités de requête consommées par les opérations. Si une application dépasse cette limite durant une seconde donnée, le taux des requêtes est limité et des exceptions sont levées. L’API pour Cassandra dans Azure Cosmos DB traduit ces exceptions en erreurs surchargées sur le protocole natif Cassandra. Pour vous assurer que votre application peut intercepter et effectuer de nouvelles tentatives de requête en cas de limitation du taux, les extensions spark et Java sont fournies. Consultez également les exemples de code Java pour les pilotes Datastax version 3 et version 4 lors de la connexion à l’API pour Cassandra dans Azure Cosmos DB. Si vous utilisez d’autres kits SDK pour accéder à l’API pour Cassandra dans Azure Cosmos DB, créez une stratégie de nouvelle tentative pour effectuer une nouvelle tentative quand ces exceptions se produisent. En guise d’alternative, activez les nouvelles tentatives côté serveur pour l’API pour Cassandra.

Étapes suivantes

• Prise en main de la création d’un compte API pour Cassandra, d’une base de données et d’une table à l’aide d’une application Java