Hızlı Başlangıç: Go için NoSQL için Azure Cosmos DB kitaplığı
UYGULANANLAR: NoSQL
Kapsayıcılarınızdaki verileri sorgulamaya gidin ve tek tek öğeler üzerinde ortak işlemler gerçekleştirmek için NoSQL için Azure Cosmos DB istemci kitaplığını kullanmaya başlayın. Azure Geliştirici CLI'sını kullanarak ortamınıza en düşük çözümü dağıtmak için bu adımları izleyin.
API başvuru belgeleri | Kitaplık kaynak kodu | Paketi (Go) | Azure Geliştirici CLI
Önkoşullar
- Etkin aboneliği olan bir Azure hesabı. Ücretsiz hesap oluşturun.
- GitHub hesabı
- Etkin aboneliği olan bir Azure hesabı. Ücretsiz hesap oluşturun.
- Azure Geliştirici CLI'sı
- Docker Desktop
Ayarlama
Bu projenin geliştirme kapsayıcısını ortamınıza dağıtın. Ardından 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.
Önemli
GitHub hesapları, hiçbir ücret ödemeden depolama ve çekirdek saat yetkilendirmesi içerir. Daha fazla bilgi için bkz . GitHub hesapları için dahil edilen depolama ve çekirdek saatler.
Projenin kök dizininde bir terminal açın.
kullanarak
azd auth login
Azure Geliştirici CLI'sinde kimlik doğrulaması 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
Projeyi başlatmak için kullanın
azd init
.azd init --template cosmos-db-nosql-go-quickstart
Not
Bu hızlı başlangıçta azure-samples/cosmos-db-nosql-go-quickstart şablonu GitHub deposu kullanılmaktadır. Azure Geliştirici CLI'sı, henüz orada değilse bu projeyi otomatik olarak makinenize klonlar.
Başlatma sırasında benzersiz bir ortam adı yapılandırın.
İpucu
Ortam adı, hedef kaynak grubu adı olarak da kullanılır. Bu hızlı başlangıç için kullanmayı
msdocs-cosmos-db
göz önünde bulundurun.Kullanarak
azd up
Azure Cosmos DB hesabını dağıtın. Bicep şablonları ayrıca örnek bir web uygulaması dağıtır.azd up
Sağlama işlemi sırasında aboneliğinizi ve istediğiniz konumu seçin. Sağlama işleminin tamamlanmasını bekleyin. İşlem yaklaşık beş dakika sürebilir.
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.
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.
Bir terminal açın ve klasöre
/src
gidin.cd ./src
Henüz yüklü değilse, kullanarak paketini
go install
yükleyinazcosmos
.go install github.com/Azure/azure-sdk-for-go/sdk/data/azcosmos
Ayrıca, henüz yüklü değilse paketi yükleyin
azidentity
.go install github.com/Azure/azure-sdk-for-go/sdk/azidentity
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ğunugithub.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
Şablondaki örnek kod adlı bir veritabanı ve adlı cosmicworks
products
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
Çoğu Azure hizmeti için uygulama istekleri yetkilendirilmelidir. DefaultAzureCredential
Uygulamalarınız ile NoSQL için Azure Cosmos DB arasında parolasız bağlantı uygulamak için tercih edilen yol olarak türünü kullanın. DefaultAzureCredential
birden çok kimlik doğrulama yöntemini destekler ve çalışma zamanında hangi yöntemin kullanılacağını belirler.
Önemli
Ayrıca parolaları, bağlantı dizesi veya diğer kimlik bilgilerini kullanarak Azure hizmetlerine yönelik istekleri doğrudan yetkilendirilebilirsiniz. Ancak bu yaklaşım dikkatli kullanılmalıdır. Geliştiriciler bu gizli dizileri güvenli olmayan bir konumda asla açığa çıkarmamak için dikkatli olmalıdır. Parolaya veya gizli anahtara erişim kazanan herkes veritabanı hizmetinde kimlik doğrulaması yapabilir. DefaultAzureCredential
, anahtarları depolama riski olmadan parolasız kimlik doğrulamasına izin vermek için hesap anahtarına göre gelişmiş yönetim ve güvenlik avantajları sunar.
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(endpoint, credential, &clientOptions)
if err != nil {
return err
}
Veritabanı alma
adlı cosmicworks
mevcut veritabanını almak için kullanınclient.NewDatabase
.
database, err := client.NewDatabase("cosmicworks")
if err != nil {
return err
}
Kapsayıcı alma
kullanarak database.NewContainer
mevcut 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.UpsertItem
kapsayıcıda bir öğe oluşturun. Bu yöntem, zaten varsa öğeyi etkili bir şekilde değiştirerek öğeyi "upsert" eder.
item := Item {
Id: "70b63682-b93a-4c77-aad2-65501347265f",
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 := "70b63682-b93a-4c77-aad2-65501347265f"
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.NewQueryItemsPager
bir 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.NextPage
her 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
.
context := context.TODO()
items := []Item{}
requestCharge := float32(0)
for pager.More() {
response, err := pager.NextPage(context)
if err != nil {
return err
}
requestCharge += response.RequestCharge
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
GitHub Codespaces'ta, depolama alanınızı ve çekirdek yetkilendirmelerinizi en üst düzeye çıkarmak için çalışan kod alanını silin.
İlgili içerik
- .NET Hızlı Başlangıcı
- JavaScript/Node.js Hızlı Başlangıç
- Java Hızlı Başlangıcı
- Python Hızlı Başlangıcı
Sonraki adım
Geri Bildirim
https://aka.ms/ContentUserFeedback.
Çok yakında: 2024 boyunca, içerik için geri bildirim mekanizması olarak GitHub Sorunları’nı kullanımdan kaldıracak ve yeni bir geri bildirim sistemiyle değiştireceğiz. Daha fazla bilgi için bkz.Gönderin ve geri bildirimi görüntüleyin