Hızlı Başlangıç: Rust için Azure SDK ile NoSQL için Azure Cosmos DB kullanma

Bu hızlı başlangıçta, Rust için Azure SDK'sını kullanarak temel bir Tablo için Azure Cosmos DB uygulaması dağıtacaksınız. Tablo için Azure Cosmos DB, uygulamaların yapılandırılmış tablo verilerini bulutta depolamasına olanak sağlayan şemasız bir veri deposudur. Rust için Azure SDK'yı kullanarak Azure Cosmos DB kaynağınızda tablo, satır oluşturma ve temel görevleri gerçekleştirme hakkında bilgi edinirsiniz.

API başvuru belgeleri | Kitaplık kaynak kodu | Crate (Rust) | Azure Geliştirici CLI

Önkoşullar

• Docker Desktop
• Rust 1.80 veya üzeri

Azure hesabınız yoksa, başlamadan önce ücretsiz hesap oluşturun.

İstemci kitaplığını yükleme

İstemci kitaplığı, Rust aracılığıyla kasa olarak azure_data_cosmos kullanılabilir.

1. Henüz yüklü değilse kullanarak oluşturma cargo installişlemini azure_data_cosmos yükleyin.

   cargo install azure_data_cosmos
   

2. Ayrıca, henüz yüklü değilse kasayı azure_identity yükleyin.

   cargo install azure_identity
   

Nesne modeli

Kod örnekleri

• İstemcinin kimliğini doğrulama
• Veritabanı alma
• Kapsayıcı alma
• Öğe oluşturma
• Öğe alma
• Sorgu öğeleri

Şablondaki örnek kod adlı bir veritabanı ve adlı cosmicworksproductskapsayıcıyı kullanır. Kapsayıcı ad products , kategori, miktar, benzersiz tanımlayıcı ve her ürün için satış bayrağı gibi ayrıntıları içerir. Kapsayıcı, mantıksal bölüm anahtarı olarak özelliğini kullanır /category .

İstemcinin kimliğini doğrulama

Bu örnek, yeni bir kullanım CosmosClient::new örneği CosmosClient oluşturur ve bir DefaultAzureCredential örneği kullanarak kimlik doğrulaması yapar.

let credential = DefaultAzureCredential::new()?;

let client = CosmosClient::new(&endpoint, credential, None)?;

Veritabanı alma

adlı cosmicworksmevcut veritabanını almak için kullanınclient.database.

let database = client.database_client("cosmicworks");

Kapsayıcı alma

kullanarak database.containermevcut products kapsayıcıyı alın.

let container = database.container_client("products");

Öğe oluşturma

JSON'da seri hale getirmek istediğiniz tüm üyeleri içeren yeni bir tür oluşturun. Bu örnekte, türün benzersiz bir tanımlayıcısı ve kategori, ad, miktar, fiyat ve satış alanları vardır. Bu türdeki serde::Serialize özelliği türeterek JSON'a seri hale getirilebilir.

use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize)]
pub struct Item {
    pub id: String,
    pub category: String,
    pub name: String,
    pub quantity: i32,
    pub price: f64,
    pub clearance: bool,
}

kullanarak container.upsert_itemkapsayıcıda bir öğe oluşturun. Bu yöntem, zaten varsa öğeyi etkili bir şekilde değiştirerek öğeyi "upsert" eder.

let item = Item {
    id: "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb".to_string(),
    category: "gear-surf-surfboards".to_string(),
    name: "Yamba Surfboard".to_string(),
    quantity: 12,
    price: 850.00,
    clearance: false,
};

let partition_key = PartitionKey::from(item.category.clone());
        
let partition_key = PartitionKey::from(item.category.clone());

container.upsert_item(partition_key, item.clone(), None).await?;

Öğe okuma

Hem benzersiz tanımlayıcıyı (id) hem de bölüm anahtarı alanlarını kullanarak nokta okuma işlemi gerçekleştirin. Belirli bir öğeyi verimli bir şekilde almak için kullanın container.ReadItem .

let item_id = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb";
let item_partition_key = "gear-surf-surfboards";

let response = container.read_item(item_partition_key, item_id, None).await?;

let item: Item = response.into_json_body().await?;

Sorgu öğeleri

kullanarak container.NewQueryItemsPagerbir kapsayıcıdaki birden çok öğe üzerinde sorgu gerçekleştirin. Bu parametreli sorguyu kullanarak belirtilen kategorideki tüm öğeleri bulun:

SELECT * FROM products p WHERE p.category = @category

let item_partition_key = "gear-surf-surfboards";

let query = Query::from("SELECT * FROM c WHERE c.category = @category")
    .with_parameter("@category", item_partition_key)?;

let mut pager = container.query_items::<Item>(query, item_partition_key, None)?;

while let Some(page_response) = pager.next().await {

    let page = page_response?.into_body().await?;

    for item in page.items {
        // Do something
    }

}

Verilerinizi keşfetme

NoSQL verilerinizi keşfetmek için Azure Cosmos DB için Visual Studio Code uzantısını kullanın. Aşağıdakiler dahil ancak bunlarla sınırlı olmamak üzere temel veritabanı işlemleri gerçekleştirebilirsiniz:

• Yapıştırma defteri veya sorgu düzenleyicisi kullanarak sorgu gerçekleştirme
• Öğeleri değiştirme, güncelleştirme, oluşturma ve silme
• Diğer kaynaklardan toplu verileri içeri aktarma
• Veritabanlarını ve kapsayıcıları yönetme

Daha fazla bilgi için bkz . Visual Studio Code uzantısını kullanarak NoSQL için Azure Cosmos DB verilerini keşfetme.

İlgili içerik

• .NET Hızlı Başlangıcı
• hızlı başlangıcı Node.js
• Java Hızlı Başlangıcı
• Python Hızlı Başlangıcı
• Hızlı Başlangıç'a gidin

Sonraki adım