Démarrage rapide : Bibliothèque de client Azure Cosmos DB pour Apache Cassandra pour Python

S’applique à: ✅ Apache Cassanda

Prise en main de la bibliothèque cliente Azure Cosmos DB pour Apache Cassandra pour Python pour stocker, gérer et interroger des données non structurées. Suivez les étapes décrites dans ce guide pour créer un compte, installer une bibliothèque de client Python, vous connecter au compte, effectuer des opérations courantes et interroger vos exemples de données finaux.

Documentation de référence de l'API | Code source de la bibliothèque | Package (PyPI)

Conditions préalables

Un abonnement Azure
- Si vous n’avez pas d’abonnement Azure, créez un compte gratuit avant de commencer.

Dernière version d’Azure CLI dans Azure Cloud Shell.
- Si vous préférez exécuter des commandes de référence CLI localement, connectez-vous à Azure CLI à l’aide de la az login commande.

Python 3.12 ou version ultérieure

Configuration

Tout d’abord, configurez l’environnement de compte et de développement pour ce guide. Cette section vous guide tout au long du processus de création d’un compte, de l’obtention de ses informations d’identification, puis de la préparation de votre environnement de développement.

Créer un compte

Commencez par créer une API pour un compte Apache Cassandra. Après la création du compte, créez l’espace de clés et les ressources de table.

Azure CLI
portail Azure

Si vous n’avez pas encore de groupe de ressources cible, utilisez la az group create commande pour créer un groupe de ressources dans votre abonnement.
```
az group create \
    --name "<resource-group-name>" \
    --location "<location>"
```

Utilisez la az cosmosdb create commande pour créer un compte Azure Cosmos DB pour Apache Cassandra avec les paramètres par défaut.

az cosmosdb create \
    --resource-group "<resource-group-name>" \
    --name "<account-name>" \
    --locations "regionName=<location>" \
    --capabilities "EnableCassandra"

Créez un nouveau keyspace en utilisant az cosmosdb cassandra keyspace create nommé cosmicworks.

az cosmosdb cassandra keyspace create \
    --resource-group "<resource-group-name>" \
    --account-name "<account-name>" \
    --name "cosmicworks"

Créez un objet JSON pour représenter votre schéma à l’aide d’une commande Bash multiligne. Ensuite, utilisez la az cosmosdb cassandra table create commande pour créer une table nommée products.

schemaJson=$(cat <<EOF
{
  "columns": [
    {
      "name": "id",
      "type": "text"
    },
    {
      "name": "name",
      "type": "text"
    },
    {
      "name": "category",
      "type": "text"
    },
    {
      "name": "quantity",
      "type": "int"
    },
    {
      "name": "price",
      "type": "decimal"
    },
    {
      "name": "clearance",
      "type": "boolean"
    }
  ],
  "partitionKeys": [
    {
      "name": "id"
    }
  ]
}
EOF
)

az cosmosdb cassandra table create \
    --resource-group "<resource-group-name>" \
    --account-name "<account-name>" \
    --keyspace-name "cosmicworks" \
    --name "product" \
    --schema "$schemaJson"

Connectez-vous au portail Azure (https://portal.azure.com).
Entrez Azure Cosmos DB dans la barre de recherche globale.
Dans Services, sélectionnez Azure Cosmos DB.
Dans le volet Azure Cosmos DB , sélectionnez Créer, puis Azure Cosmos DB pour Apache Cassandra dans l’onglet Autres .
Sélectionnez le compte de base de données d’unité de requête (RU) pour le type de compte.

Dans le volet Informations de base, configurez les options suivantes, puis sélectionnez Avis+ créer :

	Valeur
Type de charge de travail	Apprentissage
Abonnement	Sélectionnez votre abonnement Azure.
Groupe de ressources	Créer un groupe de ressources ou en sélectionner un
Nom du compte	Fournir un nom globalement unique
Zones de disponibilité	Désactiver
Lieu	Sélectionnez une région Azure prise en charge pour votre abonnement

Conseil / Astuce

Vous pouvez laisser les options non spécifiées à leur valeur par défaut. Vous pouvez également configurer le compte pour limiter le débit total du compte à 1 000 unités de requête par seconde (RU/s) ou activer le niveau gratuit pour réduire vos coûts.

Dans le volet Avis+ créer, attendez que la validation de votre compte se termine avec succès, puis sélectionnez Créer.
Le portail accède automatiquement au panneau Déploiement. Attendez que le déploiement se termine.
Une fois le déploiement terminé, sélectionnez Accéder à la ressource pour accéder à la nouvelle API pour le compte Apache Cassandra.
Dans le menu de la ressource, sélectionnez l’option Explorateur de données .
Dans l’Explorateur de données, sélectionnez + Nouvelle table.

Dans la boîte de dialogue Ajouter un tableau , configurez les options suivantes, puis sélectionnez OK :

	Valeur
Keyspace	Créer
Nom de l’espace de clés	`cosmicworks`
Nom de la table	`product`
Schéma de table	`(id text, name text, category text, quantity int, price decimal, clearance boolean, PRIMARY KEY (id))`

Conseil / Astuce

Vous pouvez laisser les options non spécifiées à leur valeur par défaut.

Obtenir les informations d’identification

À présent, obtenez le mot de passe de la bibliothèque cliente à utiliser pour créer une connexion au compte récemment créé.

Azure CLI
portail Azure

Utilisez az cosmosdb show pour obtenir le point de contact et le nom d'utilisateur du compte.

az cosmosdb show \
    --resource-group "<resource-group-name>" \
    --name "<account-name>" \
    --query "{username:name,contactPoint:documentEndpoint}"

Enregistrez la valeur des propriétés contactPoint et username de la sortie des commandes précédentes. Ces valeurs de propriétés sont le point de contact et le nom d’utilisateur que vous utilisez plus loin dans ce guide pour vous connecter au compte avec la bibliothèque.

Utilisez az cosmosdb keys list pour obtenir les clés du compte.

az cosmosdb keys list \
    --resource-group "<resource-group-name>" \
    --name "<account-name>" \
    --type "keys"

Enregistrez la valeur de la primaryMasterKey propriété à partir de la sortie des commandes précédentes. La valeur de cette propriété est le mot de passe que vous utilisez plus loin dans ce guide pour vous connecter au compte avec la bibliothèque.

Préparer l’environnement de développement

Ensuite, configurez votre environnement de développement avec un nouveau projet et la bibliothèque cliente. Cette étape est la dernière condition requise avant de passer au reste de ce guide.

Démarrez dans un répertoire vide.
Importez le cassandra-driver package à partir de l’index de package Python (PyPI).
```
pip install cassandra-driver
```
Ouvrez le fichier app.py.

Modèle d'objet

	Descriptif
`Cluster`	Représente une connexion spécifique à un cluster

Authentifier le client

Commencez par authentifier le client à l’aide des informations d’identification collectées précédemment dans ce guide.

Ouvrez le fichier app.py dans votre environnement de développement intégré (IDE).
Importez les types suivants à partir du cassandra-driver module :
- cassandra.cluster.Cluster
- cassandra.auth.PlainTextAuthProvider
```
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
```
Importez les types suivants à partir du ssl module :
- ssl.PROTOCOL_TLS_CLIENT
- ssl.SSLContext
- ssl.CERT_NONE
```
from ssl import PROTOCOL_TLS_CLIENT, SSLContext, CERT_NONE
```
Créez des variables de chaîne pour les informations d’identification collectées précédemment dans ce guide. Nommez les variables username, passwordet contactPoint.
```
username = "<username>"
password = "<password>"
contactPoint = "<contact-point>"
```
Configurez l’option SSLContext en créant une variable nommée ssl_context, en définissant le protocole PROTOCOL_TLS_CLIENTsur , en désactivant la vérification du nom d’hôte et en définissant le mode CERT_NONEde vérification sur .
```
ssl_context = SSLContext(PROTOCOL_TLS_CLIENT)
ssl_context.check_hostname = False
ssl_context.verify_mode = CERT_NONE
```
Créez un PlainTextAuthProvider objet avec les informations d’identification spécifiées dans les étapes précédentes. Stockez le résultat dans une variable nommée auth_provider.
```
auth_provider = PlainTextAuthProvider(username=username, password=password)
```
Créez un Cluster objet à l’aide des informations d’identification et des variables de configuration créées dans les étapes précédentes. Stockez le résultat dans une variable nommée cluster.
```
cluster = Cluster([contactPoint], port=10350, auth_provider=auth_provider, ssl_context=ssl_context)
```

Connectez-vous au cluster.

session = cluster.connect("cosmicworks")

Avertissement

La validation TLS (Transport Layer Security) complète est désactivée dans ce guide pour simplifier l’authentification. Pour les déploiements de production, activez entièrement la validation.

Effectuer un upsert de données

Ensuite, insérer ou mettre à jour de nouvelles données dans une table. Upserting garantit que les données sont créées ou remplacées de manière appropriée selon que les mêmes données existent déjà dans la table.

Créez une variable de chaîne nommée insertQuery avec la requête CQL (Cassandra Query Language) pour insérer une nouvelle ligne.

insertQuery = """
INSERT INTO
    product (id, name, category, quantity, price, clearance)
VALUES
    (%(id)s, %(name)s, %(category)s, %(quantity)s, %(price)s, %(clearance)s)
"""

Créez un objet avec différentes propriétés d’un nouveau produit et stockez-le dans une variable nommée params.

params = {
    "id": "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
    "name": "Yamba Surfboard",
    "category": "gear-surf-surfboards",
    "quantity": 12,
    "price": 850.00,
    "clearance": False
}

Utilisez la execute fonction pour exécuter la requête avec les paramètres spécifiés.
```
session.execute(insertQuery, params)
```

Lire les données

Lisez ensuite les données qui ayant précédemment fait l’objet d’un upsert dans la table.

Créez une variable de chaîne nommée readQuery avec une requête CQL qui correspond aux éléments avec le même id champ.
```
readQuery = "SELECT * FROM product WHERE id = %s LIMIT 1"
```
Créez une variable de chaîne nommée id avec la même valeur que le produit créé précédemment dans ce guide.
```
id = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb"
```
Utilisez la fonction execute pour exécuter la requête stockée dans readQuery, en passant la variable id comme argument. Stockez le résultat dans une variable nommée readResults.
```
readResults = session.execute(readQuery, (id,))
```
Utilisez la one fonction pour obtenir le résultat unique attendu. Stockez ce résultat unique dans une variable nommée matchedProduct.
```
matchedProduct = readResults.one()
```

Rechercher des données

Enfin, utilisez une requête pour rechercher toutes les données qui correspondent à un filtre spécifique dans la table.

Créez des variables de chaîne nommées findQuery et category avec la requête CQL et le paramètre requis.

findQuery = "SELECT * FROM product WHERE category = %s ALLOW FILTERING"
category = "gear-surf-surfboards"

Utilisez les deux variables de chaîne et la execute fonction pour interroger plusieurs résultats. Stockez le résultat de cette requête dans une variable nommée findResults.
```
findResults = session.execute(findQuery, (category,))
```
Utilisez une for boucle pour itérer sur les résultats de la requête.
```
for row in findResults:
    # Do something here with each result
```

Exécuter le code

Exécutez l’application nouvellement créée à l’aide d’un terminal dans votre répertoire d’application.

python app.py

Nettoyer les ressources

Lorsque vous n’avez plus besoin du compte, supprimez le compte de votre abonnement Azure en supprimant la ressource.

Azure CLI
portail Azure

az cosmosdb delete \
    --resource-group "<resource-group-name>" \
    --name "<account-name>"

Étape suivante

Vue d’ensemble d’Azure Cosmos DB pour Apache Cassandra

Rétroaction

Cette page vous a-t-elle été utile ?

Last updated on 2025-07-23