Aracılığıyla paylaş


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

Bu hızlı başlangıçta Go 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 Go için Azure SDK'sını kullanarak tek tek öğelerde ortak işlemler gerçekleştirin.

API başvuru belgesi | Kitaplık kaynak kodu | Paket (Go) | Azure Developer CLI

Önkoşullar

  • Azure Geliştirici CLI'sı
  • Docker Desktop
  • Go 1.21 veya üzeri

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

Projeyi başlatma

Azure Geliştirici CLI'sını (azd) kullanarak NoSQL için Azure Cosmos DB hesabı oluşturun ve kapsayıcılı örnek bir uygulama dağıtı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-nosql-go-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 kitaplığı, paket olarak azcosmos Go aracılığıyla kullanılabilir.

  1. Bir terminal açın ve klasöre /src gidin.

    cd ./src
    
  2. Henüz yüklü değilse, azcosmos paketini go install kullanarak yükleyin.

    go install github.com/Azure/azure-sdk-for-go/sdk/data/azcosmos
    
  3. Ayrıca, henüz yüklü değilse paketi yükleyin azidentity .

    go install github.com/Azure/azure-sdk-for-go/sdk/azidentity
    
  4. src/go.mod dosyasını açıp gözden geçirerek ve github.com/Azure/azure-sdk-for-go/sdk/data/azcosmos girdilerinin her ikisinin de mevcut olduğunu github.com/Azure/azure-sdk-for-go/sdk/azidentity doğrulayın.

Kitaplıkları içeri aktarma

github.com/Azure/azure-sdk-for-go/sdk/azidentity ve github.com/Azure/azure-sdk-for-go/sdk/data/azcosmos paketlerini uygulama kodunuz içine aktarın.

import (
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/data/azcosmos"
)

Nesne modeli

İsim Description
CosmosClient Bu sınıf birincil istemci sınıfıdır ve hesap genelindeki meta verileri veya veritabanlarını yönetmek için kullanılır.
CosmosDatabase Bu sınıf, hesaptaki bir veritabanını temsil eder.
CosmosContainer Bu sınıf ö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.
PartitionKey Bu sınıf mantıksal bölüm anahtarını temsil eder. Bu sınıf birçok yaygın işlem ve sorgu için gereklidir.

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 azcosmos.NewClient örneği oluşturur ve DefaultAzureCredential örneğini kullanarak kimlik doğrulaması yapar.

credential, err := azidentity.NewDefaultAzureCredential(nil)
if err != nil {
    return err
}

clientOptions := azcosmos.ClientOptions{
    EnableContentResponseOnWrite: true,
}

client, err := azcosmos.NewClient("<azure-cosmos-db-nosql-account-endpoint>", credential, &clientOptions)
if err != nil {
    return err
}

Veritabanı alma

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

database, err := client.NewDatabase("cosmicworks")
if err != nil {
    return err
}

Bir konteyner al

Mevcut products kapsayıcıyı, database.NewContainer kullanarak alın.

container, err := database.NewContainer("products")
if err != nil {
    return err
}

Öğe oluşturma

JSON'da seri hale getirmek istediğiniz tüm üyeleri içeren bir Go 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.

type Item struct {
  Id        string  `json:"id"`
  Category  string  `json:"category"`
  Name      string  `json:"name"`
  Quantity  int     `json:"quantity"`
  Price     float32 `json:"price"`
  Clearance bool    `json:"clearance"`
}

kullanarak container.UpsertItemkapsayı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.

item := Item {
    Id:        "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
    Category:  "gear-surf-surfboards",
    Name:      "Yamba Surfboard",
    Quantity:  12,
    Price:     850.00,
    Clearance: false,
}

partitionKey := azcosmos.NewPartitionKeyString("gear-surf-surfboards")

context := context.TODO()

bytes, err := json.Marshal(item)
if err != nil {
    return err
}

response, err := container.UpsertItem(context, partitionKey, bytes, nil)
if err != nil {
    return err
}

Öğ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 .

partitionKey := azcosmos.NewPartitionKeyString("gear-surf-surfboards")

context := context.TODO()

itemId := "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb"

response, err := container.ReadItem(context, partitionKey, itemId, nil)
if err != nil {
    return err
}

if response.RawResponse.StatusCode == 200 {
    read_item := Item{}
    err := json.Unmarshal(response.Value, &read_item)
    if err != nil {
        return err
    }
}

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
partitionKey := azcosmos.NewPartitionKeyString("gear-surf-surfboards")

query := "SELECT * FROM products p WHERE p.category = @category"

queryOptions := azcosmos.QueryOptions{
    QueryParameters: []azcosmos.QueryParameter{
        {Name: "@category", Value: "gear-surf-surfboards"},
    },
}

pager := container.NewQueryItemsPager(query, partitionKey, &queryOptions)

sorgunun sayfalandırılmış sonuçlarını, her sonuç sayfasında döngü yaparak pager.NextPage kullanarak ayrıştırın. Her döngünün başında herhangi bir sonuç olup olmadığını belirlemek için kullanın pager.More .

items := []Item{}

for pager.More() {
    response, err := pager.NextPage(context.TODO())
    if err != nil {
        return err
    }

    for _, bytes := range response.Items {
        item := Item{}
        err := json.Unmarshal(bytes, &item)
        if err != nil {
            return err
        }
        items = append(items, item)
    }
}

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ğı.

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