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

• Şunlara uygulanır:

  ✅ NoSQL

• .NET
• Node.js
• Java
• Python
• Git

Bu hızlı başlangıçta Go 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. Go 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 | Paketi (Go) | Azure Geliştirici CLI

Önkoşullar

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

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 kullanarak azd auth loginAzure Geliştirici CLI'sinde kimlik doğrulamasından geçin. 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 kullanın azd init .

   azd init --template cosmos-db-nosql-go-quickstart
   

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

5. Kullanarak azd upAzure Cosmos DB hesabını dağıtın. Bicep şablonları ayrıca örnek bir web uygulaması 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 çıkışını gözlemleyin.

İ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, kullanarak paketini go installyükleyinazcosmos.

   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/azidentity girdilerinin her ikisinin de mevcut olduğunu github.com/Azure/azure-sdk-for-go/sdk/data/azcosmos doğrulayın.

Nesne modeli

Veri Akışı Adı	Açıklama
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

• İ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ı cosmicworks productskapsayı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 azcosmos.NewClient örneği CosmosClient oluşturur ve bir DefaultAzureCredential örneği 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

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

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

Kapsayıcı alma

kullanarak database.NewContainermevcut products kapsayıcıyı 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, zaten varsa öğeyi etkili bir şekilde değiştirerek öğeyi "upsert" eder.

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
}

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

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)

kullanarak pager.NextPageher sonuç sayfasında döngü yaparak sorgunun sayfalandırılmış sonuçlarını 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)
    }
}

Kaynakları temizleme

Ö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

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