Udostępnij za pomocą

Szybki start: używanie usługi Azure Cosmos DB dla tabel z zestawem Azure SDK dla języka Go

  • Dotyczy: ✅ Table

W tym przewodniku szybkiego startu wdrażasz podstawową aplikację Azure Cosmos DB dla tabel przy użyciu pakietu Azure SDK dla języka Go. Usługa Azure Cosmos DB do obsługi tabel to magazyn danych bez schematu, który umożliwia aplikacjom przechowywanie strukturalnych danych tabeli w chmurze. Dowiesz się, jak tworzyć tabele, wiersze i wykonywać podstawowe zadania w ramach zasobu usługi Azure Cosmos DB przy użyciu zestawu Azure SDK dla języka Go.

Kod źródłowy biblioteki | Pakiet (Go) | Konsola dewelopera platformy Azure

Prerequisites

  • Azure Developer CLI
  • Docker Desktop
  • Go 1.21 lub nowszy

Jeśli nie masz jeszcze konta platformy Azure, przed rozpoczęciem utwórz bezpłatne konto.

Inicjowanie projektu

Użyj interfejsu wiersza polecenia dla deweloperów platformy Azure (azd), aby utworzyć usługę Azure Cosmos DB dla konta tabeli i wdrożyć konteneryzowaną przykładową aplikację. Przykładowa aplikacja używa biblioteki klienta do zarządzania, tworzenia, odczytywania i wykonywania zapytań dotyczących przykładowych danych.

  1. Otwórz terminal w pustym katalogu.

  2. Jeśli jeszcze nie jesteś uwierzytelniony, uwierzytelnij się za pomocą Azure Developer CLI przy użyciu polecenia azd auth login. Wykonaj kroki określone przez narzędzie, aby uwierzytelnić się w interfejsie wiersza polecenia przy użyciu preferowanych poświadczeń platformy Azure.

    azd auth login

  3. Użyj azd init do zainicjowania projektu.

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

  4. Podczas inicjowania skonfiguruj unikatową nazwę środowiska.

  5. Wdróż konto usługi Azure Cosmos DB przy użyciu polecenia azd up. Szablony Bicep wdrażają również przykładową aplikację internetową.

    azd up

  6. Podczas procesu aprowizacji wybierz subskrypcję, żądaną lokalizację i docelową grupę zasobów. Poczekaj na zakończenie procesu konfiguracji. Proces może potrwać około pięciu minut.

  7. Po zakończeniu aprowizacji zasobów platformy Azure adres URL uruchomionej aplikacji internetowej zostanie uwzględniony w danych wyjściowych.

    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. Użyj adresu URL w konsoli, aby przejść do aplikacji internetowej w przeglądarce. Obserwuj dane wyjściowe uruchomionej aplikacji.

Zrzut ekranu przedstawiający uruchomioną aplikację internetową.

Instalowanie biblioteki klienta

Biblioteka klienta jest dostępna w języku Go jako pakiet aztables.

  1. Otwórz terminal i przejdź do /src folderu.

    cd ./src

  2. Jeśli pakiet nie został jeszcze zainstalowany, zainstaluj go aztables przy użyciu polecenia go install.

    go install github.com/Azure/azure-sdk-for-go/sdk/data/aztables

  3. Otwórz i przejrzyj plik src/go.mod , aby sprawdzić, czy github.com/Azure/azure-sdk-for-go/sdk/data/aztables wpis istnieje.

Importowanie bibliotek

Zaimportuj pakiety github.com/Azure/azure-sdk-for-go/sdk/azidentity i github.com/Azure/azure-sdk-for-go/sdk/data/aztables do kodu aplikacji.

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

Model obiektów

Name Description
ServiceClient Ten typ jest podstawowym typem klienta i służy do zarządzania metadanymi lub bazami danych dla całego konta.
Client Ten typ reprezentuje klienta dla tabeli w ramach konta.

Przykłady kodu

Przykładowy kod w szablonie używa tabeli o nazwie cosmicworks-products. Tabela cosmicworks-products zawiera szczegółowe informacje, takie jak nazwa, kategoria, ilość, cena, unikatowy identyfikator i flaga sprzedaży dla każdego produktu. Kontener używa unikatowego identyfikatora jako klucza wiersza i kategorii jako klucza partycji.

Uwierzytelnianie klienta

Ten przykład tworzy nowe wystąpienie ServiceClient typu.

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

client, err := aztables.NewServiceClient("<azure-cosmos-db-table-account-endpoint>", credential)
if err != nil {
    log.Fatal(err)
}

Pobieranie tabeli

Ten przykład tworzy wystąpienie typu Client przy użyciu funkcji typu NewClient.

table, err := client.NewClient("<azure-cosmos-db-table-name>")
if err != nil {
    log.Fatal(err)
}

Tworzenie encji

Najprostszym sposobem utworzenia nowej jednostki w tabeli jest utworzenie wystąpienia typu aztables.EDMEntity. Ustaw właściwości RowKey i PartitionKey przy użyciu typu aztables.Entity, a następnie ustaw wszelkie dodatkowe właściwości przy użyciu mapy stringów.

entity := aztables.EDMEntity{
    Entity: aztables.Entity{
        RowKey:       "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
        PartitionKey: "gear-surf-surfboards",
    },
    Properties: map[string]any{
        "Name":      "Yamba Surfboard",
        "Quantity":  12,
        "Price":     850.00,
        "Clearance": false,
    },
}

Konweruj jednostkę do tablicy bajtów przy użyciu metody json.Marshal , a następnie utwórz jednostkę w tabeli przy użyciu polecenia UpsertEntity.

bytes, err := json.Marshal(entity)
if err != nil {
    panic(err)
}

_, err = table.UpsertEntity(context.TODO(), bytes, nil)
if err != nil {
    panic(err)
}

Pobierz encję

Określoną jednostkę można pobrać z tabeli przy użyciu polecenia GetEntity. Następnie możesz użyć json.Unmarshal do przeanalizowania go za pomocą typu aztables.EDMEntity.

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

response, err := table.GetEntity(context.TODO(), partitionKey, rowKey, nil)
if err != nil {
    panic(err)
}

var entity aztables.EDMEntity
err = json.Unmarshal(response.Value, &entity)
if err != nil {
    panic(err)
}

Wykonywanie zapytań o jednostki

Po wstawieniu jednostki można również uruchomić zapytanie, aby pobrać wszystkie jednostki pasujące do określonego filtru, używając polecenia NewListEntitiesPager wraz z filtrem ciągu.

category := "gear-surf-surfboards"
// Ensure the value is OData-compliant by escaping single quotes
safeCategory := strings.ReplaceAll(category, "'", "''")
filter := fmt.Sprintf("PartitionKey eq '%s'", safeCategory)

options := &aztables.ListEntitiesOptions{
    Filter: &filter,
}

pager := table.NewListEntitiesPager(options)

Przeanalizuj wyniki zapytania podzielonego na strony przy użyciu funkcji More pagera, aby sprawdzić, czy są kolejne strony, a następnie funkcji NextPage w celu uzyskania następnej strony wyników.

for pager.More() {
    response, err := pager.NextPage(context.TODO())
    if err != nil {
        panic(err)
    }
    for _, entityBytes := range response.Entities {
        var entity aztables.EDMEntity
        err := json.Unmarshal(entityBytes, &entity)
        if err != nil {
            panic(err)
        }
        
        writeOutput(fmt.Sprintf("Found entity:\t%s\t%s", entity.Properties["Name"], entity.RowKey))
    }
}

Uprzątnij zasoby

Jeśli nie potrzebujesz już przykładowej aplikacji lub zasobów, usuń odpowiednie wdrożenie i wszystkie zasoby.

azd down

Treści powiązane

  • Last updated on