Mulai cepat: Pustaka klien Azure Cosmos DB untuk Apache Cassandra untuk Python

Berlaku untuk: ✅ Apache Cassanda

Mulai menggunakan pustaka klien Azure Cosmos DB for Apache Cassandra agar Python menyimpan, mengelola, dan mengkueri data yang tidak terstruktur. Ikuti langkah-langkah dalam panduan ini untuk membuat akun baru, menginstal pustaka klien Python, menyambungkan ke akun, melakukan operasi umum, dan mengkueri data sampel akhir Anda.

Dokumentasi referensi API | Kode sumber pustaka | Paket (PyPI)

Prasyarat

Langganan Azure
- Jika Anda tidak memiliki langganan Azure, buatlah akun gratis sebelum Anda memulai.

Versi terbaru Azure CLI di Azure Cloud Shell.
- Jika Anda lebih suka menjalankan perintah referensi CLI secara lokal, masuk ke Azure CLI dengan menggunakan az login perintah .

Python 3.12 atau yang lebih baru

Persiapan

Pertama, siapkan akun dan lingkungan pengembangan untuk panduan ini. Bagian ini memandu Anda melalui proses pembuatan akun, mendapatkan kredensial akun, lalu menyiapkan lingkungan pengembangan Anda.

Buat akun

Mulailah dengan membuat API untuk akun Apache Cassandra. Setelah akun dibuat, buat keyspace dan sumber daya tabel.

Azure CLI
Portal Microsoft Azure

Jika Anda belum memiliki grup sumber daya target, gunakan az group create perintah untuk membuat grup sumber daya baru di langganan Anda.
```
az group create \
    --name "<resource-group-name>" \
    --location "<location>"
```

az cosmosdb create Gunakan perintah untuk membuat akun Azure Cosmos DB for Apache Cassandra baru dengan pengaturan default.

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

Buat keyspace baru menggunakan az cosmosdb cassandra keyspace create bernama cosmicworks.

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

Buat objek JSON baru untuk mewakili skema Anda menggunakan perintah Bash multibaris. Kemudian, gunakan az cosmosdb cassandra table create perintah untuk membuat tabel baru bernama 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"

Masuk ke portal Azure (https://portal.azure.com).
Masukkan Azure Cosmos DB di bilah pencarian global.
Dalam Layanan, pilih Azure Cosmos DB.
Di panel Azure Cosmos DB , pilih Buat, lalu Azure Cosmos DB untuk Apache Cassandra dalam tab Lainnya .
Pilih tipe akun Akun database unit permintaan (RU).

Dalam panel Dasar , konfigurasikan opsi berikut, lalu pilih Tinjau + buat:

	Nilai
Jenis Beban Kerja	Belajar
Abonemen	Pilih langganan Azure Anda
Grup Sumber Daya	Membuat grup sumber daya baru atau memilih grup sumber daya yang sudah ada
Nama Akun	Berikan nama yang unik secara global
Zona Ketersediaan	Nonaktifkan
Tempat	Pilih wilayah Azure yang didukung untuk langganan Anda

Tip

Anda dapat membiarkan opsi yang tidak ditentukan pada nilai default. Anda juga dapat mengonfigurasi akun untuk membatasi total throughput akun hingga 1.000 unit permintaan per detik (RU/dtk) atau mengaktifkan lapisan gratis untuk meminimalkan biaya Anda.

Pada panel Tinjau + buat , tunggu validasi akun Anda berhasil diselesaikan, lalu pilih Buat.
Portal secara otomatis menavigasi ke panel Penyebaran. Tunggu hingga penerapan selesai.
Setelah penyebaran selesai, pilih Buka sumber daya untuk menavigasi ke API baru untuk akun Apache Cassandra.
Di menu sumber daya, pilih opsi Data Explorer .
Di Data Explorer, pilih + Tabel Baru.

Dalam dialog Tambahkan Tabel , konfigurasikan opsi berikut, lalu pilih OK:

	Nilai
Keyspace	Buat baru
Nama ruang kunci	`cosmicworks`
Nama tabel	`product`
Skema tabel	`(id text, name text, category text, quantity int, price decimal, clearance boolean, PRIMARY KEY (id))`

Tip

Anda dapat membiarkan opsi yang tidak ditentukan pada nilai default.

Mendapatkan kredensial

Sekarang, dapatkan kata sandi untuk pustaka klien yang akan digunakan guna membuat koneksi ke akun yang baru saja dibuat.

Azure CLI
Portal Microsoft Azure

Gunakan az cosmosdb show untuk mendapatkan titik kontak dan nama pengguna untuk akun tersebut.

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

Catat nilai contactPoint dan username properti dari keluaran perintah sebelumnya. Nilai properti ini adalah titik kontak dan nama pengguna yang Anda gunakan nanti dalam panduan ini untuk menyambungkan ke akun dengan pustaka.

Gunakan az cosmosdb keys list untuk mendapatkan kunci untuk akun tersebut.

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

Catat nilai primaryMasterKey properti dari output perintah sebelumnya. Nilai properti ini adalah kata sandi yang Anda gunakan nanti dalam panduan ini untuk menyambungkan ke akun dengan pustaka.

Menyiapkan lingkungan pengembangan

Kemudian, konfigurasikan lingkungan pengembangan Anda dengan proyek baru dan pustaka klien. Langkah ini adalah prasyarat terakhir yang diperlukan sebelum beralih ke sisa panduan ini.

Mulai di direktori kosong.
cassandra-driver Impor paket dari Indeks Paket Python (PyPI).
```
pip install cassandra-driver
```
Buat file app.py.

Model objek

	Deskripsi
`Cluster`	Mewakili koneksi tertentu ke kluster

Mengautentikasi klien

Mulailah dengan mengautentikasi klien menggunakan kredensial yang dikumpulkan sebelumnya dalam panduan ini.

Buka file app.py di lingkungan pengembangan terintegrasi (IDE) Anda.
Impor jenis berikut dari cassandra-driver modul:
- cassandra.cluster.Cluster
- cassandra.auth.PlainTextAuthProvider
```
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
```
Impor jenis berikut dari ssl modul:
- ssl.PROTOCOL_TLS_CLIENT
- ssl.SSLContext
- ssl.CERT_NONE
```
from ssl import PROTOCOL_TLS_CLIENT, SSLContext, CERT_NONE
```
Buat variabel string untuk kredensial yang dikumpulkan sebelumnya dalam panduan ini. Beri nama variabel username, , passworddan contactPoint.
```
username = "<username>"
password = "<password>"
contactPoint = "<contact-point>"
```
SSLContext Konfigurasikan dengan membuat variabel baru bernama ssl_context, mengatur protokol ke PROTOCOL_TLS_CLIENT, menonaktifkan pemeriksaan nama host, dan mengatur mode verifikasi ke CERT_NONE.
```
ssl_context = SSLContext(PROTOCOL_TLS_CLIENT)
ssl_context.check_hostname = False
ssl_context.verify_mode = CERT_NONE
```
Buat objek baru PlainTextAuthProvider dengan kredensial yang ditentukan di langkah sebelumnya. Simpan hasilnya di variabel bernama auth_provider.
```
auth_provider = PlainTextAuthProvider(username=username, password=password)
```
Buat Cluster objek menggunakan variabel kredensial dan konfigurasi yang dibuat di langkah-langkah sebelumnya. Simpan hasilnya di variabel bernama cluster.
```
cluster = Cluster([contactPoint], port=10350, auth_provider=auth_provider, ssl_context=ssl_context)
```

Sambungkan ke kluster.

session = cluster.connect("cosmicworks")

Peringatan

Validasi keamanan lapisan transportasi (TLS) lengkap dinonaktifkan dalam panduan ini untuk menyederhanakan autentikasi. Untuk penyebaran produksi, aktifkan validasi sepenuhnya.

Memasukkan atau memperbarui data

Selanjutnya, upsert data baru ke dalam tabel. Upserting memastikan bahwa data dibuat atau diganti dengan tepat tergantung pada apakah data yang sama sudah ada dalam tabel.

Buat variabel string baru bernama insertQuery dengan kueri Cassandra Query Language (CQL) untuk menyisipkan baris baru.

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

Buat objek baru dengan berbagai properti produk baru dan simpan dalam variabel bernama params.

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

execute Gunakan fungsi untuk menjalankan kueri dengan parameter yang ditentukan.
```
session.execute(insertQuery, params)
```

Baca data

Kemudian, baca data yang sebelumnya diupsert ke dalam tabel.

Buat variabel string baru bernama readQuery dengan kueri CQL yang cocok dengan item dengan bidang yang sama id .
```
readQuery = "SELECT * FROM product WHERE id = %s LIMIT 1"
```
Buat variabel string bernama id dengan nilai yang sama dengan produk yang dibuat sebelumnya dalam panduan ini.
```
id = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb"
```
Gunakan fungsi execute untuk menjalankan kueri yang disimpan dalam readQuery dengan meneruskan variabel id sebagai argumen. Simpan hasilnya di variabel bernama readResults.
```
readResults = session.execute(readQuery, (id,))
```
Gunakan fungsi one untuk mendapatkan hasil tunggal yang diharapkan. Simpan satu hasil ini dalam variabel bernama matchedProduct.
```
matchedProduct = readResults.one()
```

Mencari data

Terakhir, gunakan kueri untuk menemukan semua data yang cocok dengan filter tertentu dalam tabel.

Buat variabel string bernama findQuery dan category dengan kueri CQL dan parameter yang diperlukan.

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

Gunakan dua variabel string dan execute fungsi untuk mengkueri beberapa hasil. Simpan hasil kueri ini dalam variabel bernama findResults.
```
findResults = session.execute(findQuery, (category,))
```

Gunakan perulangan for untuk melakukan iterasi atas hasil kueri.

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

Menjalankan kode

Jalankan aplikasi yang baru dibuat menggunakan terminal di direktori aplikasi Anda.

python app.py

Membersihkan sumber daya

Saat Anda tidak lagi memerlukan akun, hapus akun dari langganan Azure Anda dengan menghapus sumber daya.

Azure CLI
Portal Microsoft Azure

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

Langkah selanjutnya

Ringkasan Azure Cosmos DB untuk Apache Cassandra

Saran dan Komentar

Apakah halaman ini membantu?

Last updated on 2025-07-21