Quickstart: Azure Cosmos DB voor Apache Cassandra-clientbibliotheek voor Python

2025-07-21
Van toepassing op: ✅ Apache Cassanda

Ga aan de slag met de Azure Cosmos DB voor Apache Cassandra-clientbibliotheek voor Python om ongestructureerde gegevens op te slaan, te beheren en er query's op uit te voeren. Volg de stappen in deze handleiding om een nieuw account te maken, een Python-clientbibliotheek te installeren, verbinding te maken met het account, algemene bewerkingen uit te voeren en uw uiteindelijke voorbeeldgegevens op te vragen.

API-referentiedocumentatie | Broncode van de bibliotheek | Pakket (PyPI)

Vereiste voorwaarden

Een Azure-abonnement
- Als je geen Azure-abonnement hebt, maak dan een gratis account aan voordat je begint.

De nieuwste versie van de Azure CLI in Azure Cloud Shell.
- Als u liever CLI-referentieopdrachten lokaal uitvoert, meldt u zich aan bij de Azure CLI met behulp van de az login opdracht.

Python 3.12 of hoger

Installeren

Stel eerst de account- en ontwikkelomgeving voor deze handleiding in. In deze sectie wordt u begeleid bij het maken van een account, het verkrijgen van de referenties en het voorbereiden van uw ontwikkelomgeving.

Een account maken

Begin met het maken van een API voor een Apache Cassandra-account. Zodra het account is gemaakt, maakt u de keyspace- en tabelbronnen.

Azure-CLI
Azure-portal

Als u nog geen doelresourcegroep hebt, gebruikt u de az group create opdracht om een nieuwe resourcegroep in uw abonnement te maken.
```
az group create \
    --name "<resource-group-name>" \
    --location "<location>"
```

Gebruik de az cosmosdb create opdracht om een nieuw Azure Cosmos DB voor Apache Cassandra-account te maken met standaardinstellingen.

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

Maak een nieuwe keyspace met az cosmosdb cassandra keyspace create en noem deze cosmicworks.

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

Maak een nieuw JSON-object om uw schema weer te geven met behulp van een Bash-opdracht met meerdere regels. Gebruik vervolgens de opdracht om een nieuwe tabel met de az cosmosdb cassandra table create naam productste maken.

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"

Meld u aan bij Azure Portal (https://portal.azure.com).
Voer Azure Cosmos DB in de algemene zoekbalk in.
Binnen Services, selecteer Azure Cosmos DB.
Selecteer Maken in het deelvenster Azure Cosmos DB, en selecteer vervolgens Azure Cosmos DB voor Apache Cassandra onder het tabblad Overige.
Kies RU-gegevensbankaccount aanvragen voor het accounttype.

Configureer in het deelvenster Basisbeginselen de volgende opties en selecteer vervolgens Beoordelen en maken:

	Waarde
Workloadtype	Leren
Abonnement	Selecteer uw Azure-abonnement
Resourcegroep	Een nieuwe resourcegroep maken of een bestaande resourcegroep selecteren
Accountnaam	Geef een wereldwijd unieke naam op
Beschikbaarheidszones	Uitschakelen
Plaats	Selecteer een ondersteunde Azure-regio voor uw abonnement

Aanbeveling

U kunt alle niet-opgegeven opties op de standaardwaarden laten staan. U kunt het account ook configureren om de totale doorvoer van accounts te beperken tot 1000 aanvraageenheden per seconde (RU/s) of om de gratis laag in te schakelen om uw kosten te minimaliseren.

Wacht in het deelvenster Controleren en maken tot de validatie van uw account is voltooid, en selecteer vervolgens Maken.
De portal gaat automatisch naar het deelvenster Implementatie . Wacht tot de implementatie is voltooid.
Zodra de implementatie is voltooid, selecteert u Ga naar de resource om naar de nieuwe API voor het Apache Cassandra-account te navigeren.
Selecteer in het resourcemenu de optie Data Explorer .
Selecteer + Nieuwe tabel in Data Explorer.

Configureer in het dialoogvenster Tabel toevoegen de volgende opties en selecteer VERVOLGENS OK:

	Waarde
Keyspace	Nieuwe maken
Keyspace-naam	`cosmicworks`
Tabelnaam	`product`
Tabelschema	`(id text, name text, category text, quantity int, price decimal, clearance boolean, PRIMARY KEY (id))`

Aanbeveling

U kunt alle niet-opgegeven opties op de standaardwaarden laten staan.

Referenties ophalen

Haal nu het wachtwoord op dat de clientbibliotheek moet gebruiken om een verbinding te maken met het onlangs gemaakte account.

Azure-CLI
Azure-portal

Gebruik az cosmosdb show dit om het contactpunt en de gebruikersnaam voor het account op te halen.

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

Noteer de waarde van de contactPoint en username eigenschappen uit de uitvoer van de vorige opdrachten. De waarden van deze eigenschappen zijn het contactpunt en de gebruikersnaam die u verderop in deze handleiding gebruikt om verbinding te maken met het account met de bibliotheek.

Gebruik az cosmosdb keys list om de sleutels op te halen voor het account.

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

Noteer de waarde van de primaryMasterKey eigenschap uit de uitvoer van de vorige opdrachten. De waarde van deze eigenschap is het wachtwoord dat u verderop in deze handleiding gebruikt om verbinding te maken met het account met de bibliotheek.

Ontwikkelomgeving voorbereiden

Configureer vervolgens uw ontwikkelomgeving met een nieuw project en de clientbibliotheek. Deze stap is het laatste vereiste voordat u verdergaat met de rest van deze handleiding.

Begin in een lege map.
Importeer het cassandra-driver pakket uit de Python Package Index (PyPI).
```
pip install cassandra-driver
```
Maak het bestand app.py .

Objectmodel

	Beschrijving
`Cluster`	Vertegenwoordigt een specifieke verbinding met een cluster

Client verifiëren

Begin met het authentificeren van de client met behulp van de inloggegevens die eerder in deze handleiding zijn verzameld.

Open het bestand app.py in uw IDE (Integrated Development Environment).
Importeer de volgende typen uit de cassandra-driver module:
- cassandra.cluster.Cluster
- cassandra.auth.PlainTextAuthProvider
```
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
```
Importeer de volgende typen uit de ssl module:
- ssl.PROTOCOL_TLS_CLIENT
- ssl.SSLContext
- ssl.CERT_NONE
```
from ssl import PROTOCOL_TLS_CLIENT, SSLContext, CERT_NONE
```
Maak stringvariabelen voor de in deze handleiding eerder verzamelde inloggegevens. Geef de variabelen usernameeen naam en passwordcontactPoint.
```
username = "<username>"
password = "<password>"
contactPoint = "<contact-point>"
```
Configureer de SSLContext door een nieuwe variabele met de naam ssl_context te maken, het protocol op PROTOCOL_TLS_CLIENT in te stellen, de hostnaamcontrole uit te schakelen en de verificatiemodus in te stellen op CERT_NONE.
```
ssl_context = SSLContext(PROTOCOL_TLS_CLIENT)
ssl_context.check_hostname = False
ssl_context.verify_mode = CERT_NONE
```
Maak een nieuw PlainTextAuthProvider object met de referenties die zijn opgegeven in de vorige stappen. Sla het resultaat op in een variabele met de naam auth_provider.
```
auth_provider = PlainTextAuthProvider(username=username, password=password)
```
Maak een Cluster object met behulp van de referenties en configuratievariabelen die in de vorige stappen zijn gemaakt. Sla het resultaat op in een variabele met de naam cluster.
```
cluster = Cluster([contactPoint], port=10350, auth_provider=auth_provider, ssl_context=ssl_context)
```

Maak verbinding met het cluster.

session = cluster.connect("cosmicworks")

Waarschuwing

Volledige TLS-validatie (Transport Layer Security) is uitgeschakeld in deze handleiding om verificatie te vereenvoudigen. Voor productie-implementaties schakelt u validatie volledig in.

Gegevens bijwerken of toevoegen

Vervolgens worden nieuwe gegevens in een tabel geplaatst. Upserting zorgt ervoor dat de gegevens op de juiste wijze worden gemaakt of vervangen, afhankelijk van of dezelfde gegevens al in de tabel aanwezig zijn.

Maak een nieuwe tekenreeksvariabele insertQuery met de CQL-query (Cassandra Query Language) voor het invoegen van een nieuwe rij.

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

Maak een nieuw object met verschillende eigenschappen van een nieuw product en sla het op in een variabele met de naam params.

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

Gebruik de execute functie om de query uit te voeren met de opgegeven parameters.
```
session.execute(insertQuery, params)
```

Gegevens lezen

Lees vervolgens gegevens die eerder in de tabel zijn geplaatst.

Maak een nieuwe tekenreeksvariabele genaamd readQuery, met een CQL-query die overeenkomt met items met hetzelfde id-veld.
```
readQuery = "SELECT * FROM product WHERE id = %s LIMIT 1"
```
Maak een tekenreeksvariabele id met dezelfde waarde als het product dat eerder in deze handleiding is gemaakt.
```
id = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb"
```
Gebruik de execute functie om de query uit te voeren die is opgeslagen bij readQuery het doorgeven van de id variabele als argument. Sla het resultaat op in een variabele met de naam readResults.
```
readResults = session.execute(readQuery, (id,))
```
Gebruik de one functie om het verwachte enkelvoudige resultaat op te halen. Sla dit enkele resultaat op in een variabele met de naam matchedProduct.
```
matchedProduct = readResults.one()
```

Gegevens opvragen

Gebruik ten slotte een query om alle gegevens te vinden die overeenkomen met een specifiek filter in de tabel.

Maak tekenreeksvariabelen met de naam findQuery en category met de CQL-query en de vereiste parameter.

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

Gebruik de twee tekenreeksvariabelen en de execute functie om meerdere resultaten op te vragen. Sla het resultaat van deze query op in een variabele met de naam findResults.
```
findResults = session.execute(findQuery, (category,))
```

Gebruik een for lus om de queryresultaten te herhalen.

for row in findResults:
    # Do something here with each result

De code uitvoeren

Voer de zojuist gemaakte toepassing uit met behulp van een terminal in uw toepassingsmap.

python app.py

De hulpbronnen opschonen

Wanneer u het account niet meer nodig hebt, verwijdert u het account uit uw Azure-abonnement door de resource te verwijderen .

Azure-CLI
Azure-portal

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

Volgende stap

Overzicht van Azure Cosmos DB voor Apache Cassandra

Feedback

Is deze pagina nuttig?