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

  • Şunlara uygulanır: ✅ Table

Important

99,999% kullanılabilirlik hizmet düzeyi sözleşmesi (SLA), anında otomatik ölçeklendirme ve birden çok bölgede otomatik yük devretme ile yüksek ölçekli senaryolar için bir veritabanı çözümü mü arıyorsunuz? NoSQL için Azure Cosmos DB'yi göz önünde bulundurun.

Bu hızlı başlangıçta, Java için Azure SDK'yı kullanarak tablo için temel bir 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. Java 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 | Paket (Maven) | Azure Geliştirici CLI

Prerequisites

  • Azure Geliştirici CLI'sı
  • Docker Desktop
  • Java 21

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

Projeyi başlatma

Tablo hesabı için Azure Cosmos DB oluşturmak ve kapsayıcılı örnek bir uygulama dağıtmak için Azure Geliştirici CLI'sini (azd) kullanın. Örnek uygulama örnek verileri yönetmek, oluşturmak, okumak ve sorgulamak için istemci kitaplığını kullanır.

  1. Boş bir dizinde bir terminal açın.

  2. Henüz kimlik doğrulaması yapmadıysanız, Azure Geliştirici CLI'sinde azd auth login kullanarak kimlik doğrulaması gerçekleştirin. Tercih ettiğiniz Azure kimlik bilgilerini kullanarak CLI'da kimlik doğrulaması yapmak için araç tarafından belirtilen adımları izleyin.

    azd auth login

  3. Projeyi başlatmak için azd init kullanın.

    azd init --template cosmos-db-table-java-quickstart

  4. Başlatma sırasında benzersiz bir ortam adı yapılandırın.

  5. azd up kullanarak Azure Cosmos DB hesabını dağıtın. Bicep şablonları ayrıca örnek bir web uygulamasını dağıtır.

    azd up

  6. Sağlama işlemi sırasında aboneliğinizi, istediğiniz konumu ve hedef kaynak grubunu seçin. Sağlama işleminin tamamlanmasını bekleyin. İşlem yaklaşık beş dakika sürebilir.

  7. Azure kaynaklarınızın sağlanması tamamlandıktan sonra, çalışan web uygulamasının URL'si çıktıya eklenir.

    Deploying services (azd deploy)

  (✓) Done: Deploying service web
- Endpoint: <https://[container-app-sub-domain].azurecontainerapps.io>

SUCCESS: Your application was provisioned and deployed to Azure in 5 minutes 0 seconds.

  8. Tarayıcıda web uygulamanıza gitmek için konsoldaki URL'yi kullanın. Çalışan uygulamanın çıktısını gözlemleyin.

Çalışan web uygulamasının ekran görüntüsü.

İstemci kitaplığını yükleme

İstemci kütüphanesi, azure-data-tables paket olarak Maven aracılığıyla kullanılabilir.

  1. Klasöre /src/web gidin ve pom.xml dosyasını açın.

    cd ./src

  2. Eğer henüz yoksa, azure-data-tables paketi için bir girdi ekleyin.

    <dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-data-tables</artifactId>
</dependency>

Kitaplıkları içeri aktarma

Gerekli ad alanlarının tümünü uygulama kodunuz içine aktarın.

import com.azure.core.http.rest.PagedFlux;
import com.azure.data.tables.TableAsyncClient;
import com.azure.data.tables.TableClientBuilder;
import com.azure.data.tables.models.ListEntitiesOptions;
import com.azure.data.tables.models.TableEntity;
import com.azure.identity.DefaultAzureCredential;
import com.azure.identity.DefaultAzureCredentialBuilder;

Nesne modeli

Name Description
TableServiceAsyncClient Bu tür birincil istemci türüdür ve hesap genelindeki meta verileri veya veritabanlarını yönetmek için kullanılır.
TableAsyncClient Bu tür, hesaptaki bir tablonun istemcisini temsil eder.

Kod örnekleri

Şablondaki örnek kod, cosmicworks-products adında bir tablo kullanır. Tabloda cosmicworks-products ad, kategori, miktar, fiyat, benzersiz tanımlayıcı ve her ürün için satış bayrağı gibi ayrıntılar yer alır. Kapsayıcı, satır anahtarı olarak benzersiz bir tanımlayıcı* ve bölüm anahtarı olarak kategori kullanır.

İstemcinin kimliğini doğrulama

Bu örnek, TableServiceAsyncClient sınıfının yeni bir örneğini oluşturur.

DefaultAzureCredential azureTokenCredential = new DefaultAzureCredentialBuilder()
    .build();

TableServiceAsyncClient client = new TableServiceClientBuilder()
    .endpoint("<azure-cosmos-db-table-account-endpoint>")
    .credential(credential)
    .buildAsyncClient();

Masa satın al

Bu örnek, TableAsyncClient sınıfının GetTableClient yöntemini kullanarak TableServiceClient sınıfının bir örneğini oluşturur.

TableAsyncClient table = client
    .getTableClient("<azure-cosmos-db-table-name>");

Varlık oluşturma

Tabloda yeni varlık oluşturmanın en kolay yolu kullanmaktır createEntity.

String rowKey = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb";
String partitionKey = "gear-surf-surfboards";

TableEntity entity = new TableEntity(partitionKey, rowKey)
        .addProperty("Name", "Yamba Surfboard")
        .addProperty("Quantity", 12)
        .addProperty("Price", 850.00)
        .addProperty("Sale", false);

kullanarak upsertEntitykoleksiyonda bir varlık oluşturun.

Mono<Void> response = table.upsertEntity(entity);

Bir varlık elde et

kullanarak getEntitybir tablodan belirli bir varlığı alabilirsiniz.

String rowKey = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb";
String partitionKey = "gear-surf-surfboards";

TableEntity entity = table.getEntity(partitionKey, rowKey);

Sorgu nesneleri

Bir varlık ekledikten sonra, ve listEntities sınıfını kullanarak ListEntitiesOptions belirli bir filtreyle eşleşen tüm varlıkları almak için bir sorgu da çalıştırabilirsiniz. setFilter yöntemini kullanarak bir OData dizesi filtresi belirtin.

ListEntitiesOptions options = new ListEntitiesOptions()
    .setFilter("PartitionKey eq 'gear-surf-surfboards'");

PagedFlux<TableEntity> tableEntities = table.listEntities(options, null, null);

Abonelik kullanarak sorgunun sayfalandırılmış sonuçlarını ayrıştırın.

tableEntities
    .DoOnNext(entity -> {
        // Do something
    });

Kaynakları temizle

Örnek uygulamaya veya kaynaklara artık ihtiyacınız kalmadığında, ilgili dağıtımı ve tüm kaynakları kaldırın.

azd down

İlgili içerik

  • Last updated on