Aracılığıyla paylaş


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 NoSQL için temel bir Azure Cosmos DB uygulaması dağıtacaksınız. NoSQL için Azure Cosmos DB, uygulamaların yapılandırılmamış verileri bulutta depolamasına olanak sağlayan şemasız bir veri deposudur. Kapsayıcılarınızdaki verileri sorgulayın ve Rust için Azure SDK'sını kullanarak tek tek öğeler üzerinde ortak işlemler gerçekleştirin.

Önemli

Azure Cosmos DB için Rust SDK şu anda genel önizleme aşamasındadır. Bu önizleme, hizmet düzeyi sözleşmesi olmadan sağlanır ve üretim iş yükleri için önerilmez. Bazı özellikler desteklenmez veya sınırlı özelliklerle sınırlı desteğe sahiptir.

Daha fazla bilgi için bkz. Microsoft Azure Önizlemeleri için Ek Kullanım Koşulları.

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 azure_data_cosmosişlemini cargo install yükleyin.

    cargo add azure_data_cosmos
    
  2. Ayrıca, henüz yüklü değilse azure_identity paketini yükleyin.

    cargo add azure_identity
    

Kitaplıkları içeri aktarma

DefaultAzureCredential, CosmosClient, PartitionKeyve Query türlerini uygulama kodunuz içine aktarın.

use azure_data_cosmos::{CosmosClient, PartitionKey, Query};
use azure_identity::DefaultAzureCredential;

Nesne modeli

İsim Description
CosmosClient Bu tür birincil istemcidir ve hesap genelindeki meta verileri veya veritabanlarını yönetmek için kullanılır.
DatabaseClient Bu tür, hesaptaki bir veritabanını temsil eder.
ContainerClient Bu tür öncelikli olarak kapsayıcıda veya kapsayıcıda depolanan öğelerde okuma, güncelleştirme ve silme işlemleri gerçekleştirmek için kullanılır.

Kod örnekleri

Şablondaki örnek kod, cosmicworks adlı bir veritabanını ve products adlı bir kapsayı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, CosmosClient yardımıyla yeni bir CosmosClient::new örneği oluşturur ve DefaultAzureCredential örneğini kullanarak kimlik doğrulaması yapar.

let credential = DefaultAzureCredential::new()?;

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

Veritabanı alma

client.database kullanarak cosmicworks adlı mevcut veritabanını alın.

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

Bir konteyner al

Mevcut products kapsayıcıyı, database.container kullanarak 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, öğe zaten varsa onu değiştirecek şekilde etkili bir güncelleme/ekleme işlemi gerçekleştirir.

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?;

Öğeyi oku

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 Azure Cosmos DB'deki NoSQL verilerini keşfetmek için Visual Studio Code uzantısının nasıl kullanılacağı.

Sonraki adım