Rychlý start: Použití služby Azure Cosmos DB pro MongoDB s Pythonem

  • Platí pro: ✅ MongoDB

Important

Chcete migrovat existující aplikaci MongoDB nebo používat funkce jazyka MQL (MongoDB Query Language)? Zvažte Azure DocumentDB.

Hledáte databázové řešení pro scénáře ve velkém měřítku s 99,999% smlouvou o úrovni služeb (SLA), okamžitým automatickým škálováním a automatickým převzetím služeb při selhání napříč několika oblastmi? Zvažte Azure Cosmos DB pro NoSQL.

V tomto rychlém startu nasadíte základní aplikaci Azure Cosmos DB pro MongoDB pomocí Pythonu. Azure Cosmos DB pro MongoDB je úložiště dat bez schématu, které umožňuje aplikacím ukládat nestrukturované dokumenty v cloudu s knihovnami MongoDB. Naučíte se vytvářet dokumenty a provádět základní úlohy v rámci prostředku služby Azure Cosmos DB pomocí Pythonu.

Zdrojový kód knihovny | Balíček (PyPI) | Azure Developer CLI

Prerequisites

  • Azure Developer CLI
  • Docker Desktop
  • Python 3.12

Pokud nemáte účet Azure, vytvořte si bezplatný účet před tím, než začnete.

Inicializace projektu

Pomocí Azure Developer CLI (azd) vytvořte účet Azure Cosmos DB for Table a nasaďte kontejnerizovanou ukázkovou aplikaci. Ukázková aplikace používá klientskou knihovnu ke správě, vytváření, čtení a dotazování ukázkových dat.

  1. Otevřete terminál v prázdném adresáři.

  2. Pokud ještě nejste ověřeni, ověřte se v Azure Developer CLI pomocí azd auth login. Postupujte podle kroků určených nástrojem k ověření v rozhraní příkazového řádku pomocí vašich upřednostňovaných přihlašovacích údajů Azure.

    azd auth login

  3. K inicializaci projektu použijte azd init.

    azd init --template cosmos-db-mongodb-python-quickstart

  4. Během inicializace nakonfigurujte jedinečný název prostředí.

  5. Nasaďte účet služby Azure Cosmos DB pomocí azd up. Šablony Bicep také nasazují ukázkovou webovou aplikaci.

    azd up

  6. Během procesu zřizování vyberte své předplatné, požadovanou lokalitu a cílovou skupinu zdrojů. Počkejte na dokončení procesu nastavení. Proces může trvat přibližně pět minut.

  7. Po dokončení zřizování prostředků Azure se do výstupu zahrne adresa URL spuštěné webové aplikace.

    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. Pomocí adresy URL v konzole přejděte do webové aplikace v prohlížeči. Sledujte výstup spuštěné aplikace.

Snímek obrazovky se spuštěnou webovou aplikací

Instalace klientské knihovny

Klientská knihovna je k dispozici prostřednictvím PyPi jako pymongo balíček.

  1. Otevřete terminál a přejděte do /src složky.

    cd ./src

  2. Pokud ještě není nainstalovaný, nainstalujte pymongo balíček pomocí pip install.

    pip install pymongo

  3. Otevřete a zkontrolujte soubor src/requirements.txt a ověřte, že pymongo položka existuje.

Import knihoven

Naimportujte MongoClient typ do kódu aplikace.

from pymongo import MongoClient

Objektový model

Name Description
MongoClient Typ použitý pro připojení k MongoDB.
Database Představuje databázi v účtu.
Collection Představuje kolekci v databázi v účtu.

Příklady kódu

Vzorový kód v šabloně používá databázi s názvem cosmicworks a kolekcí s názvem products. Kolekce products obsahuje podrobnosti, jako je název, kategorie, množství a jedinečný identifikátor každého produktu. Kolekce používá vlastnost /category jako klíč pro sharding.

Ověření klienta

Tato ukázka vytvoří novou instanci MongoClient typu.

connection_string = "<azure-cosmos-db-for-mongodb-connection-string>"

client = MongoClient(connection_string)

Získání databáze

Tento příklad vytvoří instanci typu Database použitím funkce get_database z typu MongoClient.

database = client.get_database("<database-name>")

Získání kolekce

Tento příklad vytvoří instanci typu Collection použitím funkce get_collection z typu Database.

collection = database.get_collection("<collection-name>")

Vytvoření dokumentu

Vytvořte dokument v kolekci pomocí collection.update_one. Tato metoda vkládá nebo aktualizuje položku tím, že položku účinně nahradí, pokud již existuje.

new_document = {
    "_id": "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
    "category": "gear-surf-surfboards",
    "name": "Yamba Surfboard",
    "quantity": 12,
    "sale": False,
}

filter = {
    "_id": "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
    "category": "gear-surf-surfboards"
}
payload = {
    "$set": new_document
}
result = collection.update_one(filter, payload, upsert=True);

Čtení dokumentu

Proveďte operaci bodového čtení pomocí pole jedinečného identifikátoru (id) i shard klíče. Použijte collection.find_one k efektivnímu načtení konkrétní položky.

filter = {
    "_id": "bbbbbbbb-1111-2222-3333-cccccccccccc",
    "category": "gear-surf-surfboards"
}
existing_document = collection.find_one(filter)

Dotazování na dokumenty

Proveďte dotaz na více položek v kontejneru pomocí collection.find. Tento dotaz najde všechny položky v zadané kategorii (shard key).

filter = {
    "category": "gear-surf-surfboards"
}

matched_documents = collection.find(filter)

for document in matched_documents:
    # Do something with each item

Prozkoumání dat

Prozkoumejte data MongoDB pomocí rozšíření Visual Studio Code pro službu Azure Cosmos DB. Můžete provádět základní databázové operace, mezi které patří mimo jiné:

  • Provádění dotazů pomocí poznámkového bloku nebo editoru dotazů
  • Úpravy, aktualizace, vytváření a odstraňování dokumentů
  • Import hromadných dat z jiných zdrojů
  • Správa databází a kolekcí

Další informace najdete v tématu Použití rozšíření Visual Studio Code k prozkoumání dat Azure Cosmos DB pro MongoDB.

Vyčistěte zdroje

Pokud už ukázkovou aplikaci nebo prostředky nepotřebujete, odeberte odpovídající nasazení a všechny prostředky.

azd down --force --purge

Související obsah

  • Last updated on