Udostępnij za pomocą


Szybki start: używanie usługi Azure DocumentDB ze sterownikiem MongoDB dla języka Go

W tym przewodniku szybkiego startu utworzysz podstawową aplikację usługi Azure DocumentDB przy użyciu języka Go. Azure DocumentDB to magazyn danych NoSQL, który umożliwia aplikacjom przechowywanie dokumentów w chmurze i uzyskiwanie do nich dostępu przy użyciu oficjalnych sterowników bazy danych MongoDB. W tym przewodniku przedstawiono sposób tworzenia dokumentów i wykonywania podstawowych zadań w klastrze usługi Azure DocumentDB przy użyciu języka Go.

Dokumentacja interfejsu | APIKod źródłowy | Pakiet (Go)

Wymagania wstępne

  • Subskrypcja platformy Azure

  • Golang 1.18 lub nowszy

Tworzenie klastra usługi Azure DocumentDB

Aby rozpocząć, musisz najpierw utworzyć klaster usługi Azure DocumentDB, który służy jako podstawa do przechowywania danych NoSQL i zarządzania nimi.

  1. Zaloguj się do witryny Azure Portal (https://portal.azure.com).

  2. W menu witryny Azure Portal lub na stronie głównej wybierz pozycję Utwórz zasób.

  3. Na stronie Nowy wyszukaj i wybierz pozycję Azure DocumentDB.

    Zrzut ekranu przedstawiający wyszukiwanie usługi Azure DocumentDB.

  4. Na stronie Tworzenie klastra usługi Azure DocumentDB i w sekcji Podstawy wybierz opcję Konfiguruj w sekcji Warstwa klastra .

    Zrzut ekranu przedstawiający opcję Konfiguruj klaster.

  5. Na stronie Skalowanie skonfiguruj te opcje, a następnie wybierz Zapisz aby zapisać zmiany w warstwie klastra.

    Wartość
    Warstwa klastra M30 tier, 2 vCore, 8-GiB RAM
    Przechowywanie na odłam 128 GiB

    Zrzut ekranu przedstawiający opcje konfiguracji zasobów obliczeniowych i magazynu dla nowego klastra usługi Azure DocumentDB.

  6. W sekcji Podstawowe skonfiguruj następujące opcje:

    Wartość
    Subscription Wybierz subskrypcję platformy Azure
    Grupa zasobów Utwórz nową grupę zasobów lub wybierz istniejącą grupę zasobów
    Nazwa klastra Podaj globalnie unikatową nazwę
    Lokalizacja Wybieranie obsługiwanego regionu platformy Azure dla subskrypcji
    Wersja bazy danych MongoDB Wybierz pozycję 8.0
    Nazwa użytkownika administratora Tworzenie nazwy użytkownika w celu uzyskania dostępu do klastra jako administrator użytkownika
    Hasło Używanie unikatowego hasła skojarzonego z nazwą użytkownika

    Zrzut ekranu przedstawiający parametry klastra.

    Wskazówka

    Zapisz wartości używane dla nazwy użytkownika i hasła. Te wartości są używane w dalszej części tego przewodnika. Aby uzyskać więcej informacji na temat prawidłowych wartości, zobacz ograniczenia klastra.

  7. Wybierz Dalej: Sieć.

  8. W sekcji Reguły zapory na karcie Sieć skonfiguruj następujące opcje:

    Wartość
    Metoda łączności Public access
    Zezwól na publiczny dostęp do tego klastra z usług i zasobów w ramach platformy Azure Enabled
  9. Dodaj regułę zapory dla bieżącego urządzenia klienckiego, aby udzielić dostępu do klastra, wybierając pozycję + Dodaj bieżący adres IP klienta.

    Zrzut ekranu przedstawiający konfiguracje sieci.

    Wskazówka

    W wielu środowiskach firmowych adresy IP maszyny deweloperów są ukryte z powodu sieci VPN lub innych ustawień sieci firmowych. W takich przypadkach można tymczasowo zezwolić na dostęp do wszystkich adresów IP, dodając 0.0.0.0 - 255.255.255.255 zakres adresów IP jako regułę zapory. Użyj tej reguły zapory tylko tymczasowo w ramach testowania i programowania połączeń.

  10. Wybierz opcję Recenzja i utwórz.

  11. Przejrzyj ustawienia, które podałeś, a następnie wybierz Utwórz. Utworzenie klastra trwa kilka minut. Poczekaj na zakończenie wdrażania zasobów.

  12. Na koniec wybierz pozycję Przejdź do zasobu , aby przejść do klastra usługi Azure DocumentDB w portalu.

Zrzut ekranu przedstawiający opcje zasobów goto.

Pobieranie poświadczeń klastra

Pobierz poświadczenia używane do nawiązania połączenia z klastrem.

  1. Na stronie klastra wybierz opcję Parametry połączenia w menu zasobów.

  2. W sekcji Parametry połączenia skopiuj lub zarejestruj wartość z pola Parametry połączenia .

Zrzut ekranu przedstawiający opcję parametrów połączenia.

Ważne

Parametry połączenia w portalu nie zawierają wartości hasła. Musisz zastąpić element zastępczy <password> poświadczeniami, które wprowadziłeś podczas tworzenia klastra, lub wprowadzić hasło interaktywnie.

Inicjowanie projektu

Utwórz nowy moduł języka Go w bieżącym katalogu.

  1. Rozpocznij w pustym katalogu.

  2. Otwórz terminal w bieżącym katalogu.

  3. Zainicjuj nowy moduł Go.

    go mod init azure-documentdb-go-quickstart
    

Instalowanie biblioteki klienta

Biblioteka klienta jest dostępna za pośrednictwem języka Go jako modułu go.mongodb.org/mongo-driver/v2/mongo .

  1. Zainstaluj sterownik MongoDB Go przy użyciu polecenia go get.

    go get go.mongodb.org/mongo-driver/v2/mongo
    
  2. Utwórz nowy plik języka Go o nazwie main.go dla kodu aplikacji.

  3. Zaimportuj wymagane pakiety do kodu aplikacji:

    import (
        "context"
        "fmt"
        "log"
        "time"
    
        "go.mongodb.org/mongo-driver/v2/bson"
        "go.mongodb.org/mongo-driver/v2/mongo"
        "go.mongodb.org/mongo-driver/v2/mongo/options"
    )
    

Model obiektów

Name Description
mongo.Client Typ używany do nawiązywania połączenia z bazą danych MongoDB.
mongo.Database Reprezentuje bazę danych w klastrze.
mongo.Collection Reprezentuje kolekcję w bazie danych w klastrze.

Przykłady kodu

Kod w tej aplikacji łączy się z bazą danych o nazwie adventureworks i kolekcją o nazwie products. Kolekcja products zawiera szczegóły, takie jak nazwa, kategoria, ilość, unikatowy identyfikator i flaga sprzedaży dla każdego produktu. Przykłady kodu w tym miejscu wykonują najbardziej typowe operacje podczas pracy z kolekcją.

Uwierzytelnianie klienta

Najpierw połącz się z klientem przy użyciu podstawowych parametrów połączenia.

  1. Utwórz funkcję main i skonfiguruj parametry połączenia. Zastąp <your-cluster-name>, <your-username> i <your-password> rzeczywistymi informacjami o klastrze.

    func main() {
        // Connection string for Azure DocumentDB cluster
        connectionString := "mongodb+srv://<your-username>:<your-password>@<your-cluster-name>.global.mongocluster.cosmos.azure.com/?tls=true&authMechanism=SCRAM-SHA-256&retrywrites=false&maxIdleTimeMS=120000"
    
        // Create client options
        clientOptions := options.Client().ApplyURI(connectionString)
    
  2. Połącz się z klientem bazy danych MongoDB i sprawdź połączenie.

        // Create a new client and connect to the server
        ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
        defer cancel()
    
        client, err := mongo.Connect(ctx, clientOptions)
        if err != nil {
            log.Fatal(err)
        }
        defer client.Disconnect(ctx)
    
        // Ping the primary
        err = client.Ping(ctx, nil)
        if err != nil {
            log.Fatal(err)
        }
    
        fmt.Println("Successfully connected and pinged Azure DocumentDB")
    

Zdobądź kolekcję

Teraz pobierz bazę danych i kolekcję. Jeśli baza danych i kolekcja jeszcze nie istnieją, użyj sterownika, aby utworzyć ją automatycznie.

  1. Uzyskaj referencję do bazy danych.

        // Get database reference
        database := client.Database("adventureworks")
        fmt.Println("Connected to database:", database.Name())
    
  2. Pobierz odwołanie do kolekcji w bazie danych.

        // Get collection reference
        collection := database.Collection("products")
        fmt.Println("Connected to collection:", collection.Name())
    

Tworzenie dokumentu

Następnie utwórz kilka nowych dokumentów w kolekcji. Aktualizuj lub wstaw dokumenty, aby upewnić się, że zastępują one te istniejące dokumenty, które mają ten sam unikatowy identyfikator.

  1. Zdefiniuj typ produktu i utwórz przykładowe dokumenty produktu.

        type Product struct {
            ID       string  `bson:"_id,omitempty"`
            Name     string  `bson:"name"`
            Category string  `bson:"category"`
            Quantity int     `bson:"quantity"`
            Price    float64 `bson:"price"`
            Sale     bool    `bson:"sale"`
        }
    
        // Create sample products
        products := []Product{
            {
                ID:       "00000000-0000-0000-0000-000000004018",
                Name:     "Windry Mittens",
                Category: "apparel-accessories-gloves-and-mittens",
                Quantity: 121,
                Price:    35.00,
                Sale:     false,
            },
            {
                ID:       "00000000-0000-0000-0000-000000004318",
                Name:     "Niborio Tent",
                Category: "gear-camp-tents",
                Quantity: 140,
                Price:    420.00,
                Sale:     true,
            },
        }
    
  2. Wstaw dokumenty przy użyciu operacji upsert.

        // Insert documents with upsert
        for _, product := range products {
            filter := bson.M{"_id": product.ID}
            update := bson.M{"$set": product}
            opts := options.Update().SetUpsert(true)
    
            result, err := collection.UpdateOne(ctx, filter, update, opts)
            if err != nil {
                log.Fatal(err)
            }
    
            if result.UpsertedID != nil {
                fmt.Printf("Inserted document with ID: %v\n", result.UpsertedID)
            } else {
                fmt.Printf("Updated document with ID: %s\n", product.ID)
            }
        }
    

Pobieranie dokumentu

Następnie wykonaj operację odczytu punktowego, aby zlokalizować i pobrać określony dokument z kolekcji.

  1. Zdefiniuj filtr, aby znaleźć określony dokument według identyfikatora.

        // Retrieve a specific document by ID
        filter := bson.M{"_id": "00000000-0000-0000-0000-000000004018"}
        var retrievedProduct Product
    
  2. Wykonaj zapytanie i zdekoduj wynik.

        err = collection.FindOne(ctx, filter).Decode(&retrievedProduct)
        if err != nil {
            log.Fatal(err)
        }
    
        fmt.Printf("Retrieved product: %+v\n", retrievedProduct)
    

Zapytanie o dokumenty

Na koniec wykonaj zapytanie o wiele dokumentów przy użyciu języka zapytań MongoDB (MQL).

  1. Zdefiniuj zapytanie, aby znaleźć dokumenty spełniające określone kryteria.

        // Query for products on sale
        queryFilter := bson.M{"sale": true}
        cursor, err := collection.Find(ctx, queryFilter)
        if err != nil {
            log.Fatal(err)
        }
        defer cursor.Close(ctx)
    
  2. Iteruj kursor, aby pobrać wszystkie pasujące dokumenty.

        fmt.Println("Products on sale:")
        for cursor.Next(ctx) {
            var product Product
            if err := cursor.Decode(&product); err != nil {
                log.Fatal(err)
            }
            fmt.Printf("- %s: $%.2f (Category: %s)\n", product.Name, product.Price, product.Category)
        }
    
        if err := cursor.Err(); err != nil {
            log.Fatal(err)
        }
    }
    

Eksplorowanie danych przy użyciu programu Visual Studio Code

Użyj rozszerzenia DocumentDB w programie Visual Studio Code, aby wykonywać podstawowe operacje bazy danych, w tym wykonywanie zapytań, wstawianie, aktualizowanie i usuwanie danych.

  1. Otwórz program Visual Studio Code.

  2. Przejdź do widoku Rozszerzenia i wyszukaj termin DocumentDB. Znajdź rozszerzenie DocumentDB dla programu VS Code .

  3. Wybierz przycisk Zainstaluj dla rozszerzenia. Poczekaj na zakończenie instalacji. Załaduj ponownie program Visual Studio Code, jeśli zostanie wyświetlony monit.

  4. Przejdź do rozszerzenia usługi DocumentDB , wybierając odpowiednią ikonę na pasku działań.

  5. W okienku Połączenia usługi DocumentDB wybierz pozycję + Nowe połączenie....

  6. W oknie dialogowym wybierz pozycję Odnajdywanie usług , a następnie Pozycję Azure DocumentDB — Azure Service Discovery.

  7. Wybierz subskrypcję platformy Azure i nowo utworzony klaster usługi Azure DocumentDB.

    Wskazówka

    W wielu środowiskach firmowych adresy IP maszyny deweloperów są ukryte z powodu sieci VPN lub innych ustawień sieci firmowych. W takich przypadkach można tymczasowo zezwolić na dostęp do wszystkich adresów IP, dodając 0.0.0.0 - 255.255.255.255 zakres adresów IP jako regułę zapory. Użyj tej reguły zapory tylko tymczasowo w ramach testowania i programowania połączeń. Aby uzyskać więcej informacji, zobacz konfigurowanie zapory.

  8. Wróć do panelu Połączenia DocumentDB, rozwiń węzeł klastra i przejdź do istniejących dokumentów i kolekcji.

  9. Otwórz menu kontekstowe kolekcji, a następnie wybierz pozycję >.

  10. Wprowadź następujące polecenia języka zapytań bazy danych MongoDB (MQL), a następnie wybierz pozycję Uruchom wszystko. Zwróć uwagę na dane wyjściowe poleceń.

    db.products.find({
      price: { $gt: 200 },
      sale: true
    })
    .sort({ price: -1 })
    .limit(3)
    

Uprzątnij zasoby

Po zakończeniu pracy z klastrem usługi Azure DocumentDB możesz usunąć utworzone zasoby platformy Azure, aby nie ponosić dodatkowych opłat.

  1. Na pasku wyszukiwania witryny Azure Portal wyszukaj i wybierz pozycję Grupy zasobów.

    Zrzut ekranu przedstawiający opcję wyszukiwania grup zasobów.

  2. Na liście wybierz grupę zasobów używana dla tego szybkiego startu.

    Zrzut ekranu przedstawiający grupę zasobów.

  3. Na stronie grupa zasobów wybierz pozycję Usuń grupę zasobów.

  4. W oknie dialogowym potwierdzenia usunięcia wprowadź nazwę grupy zasobów, aby potwierdzić, że zamierzasz ją usunąć. Na koniec wybierz pozycję Usuń , aby trwale usunąć grupę zasobów.

    Zrzut ekranu przedstawiający przycisk potwierdzenia usuwania grupy zasobów.