Szybki start: używanie usługi Azure Cosmos DB dla tabel z zestawem Azure SDK dla języka Python
W tym przewodniku Szybki start wdrożysz podstawową aplikację usługi Azure Cosmos DB dla tabel przy użyciu zestawu Azure SDK dla języka Python. Usługa Azure Cosmos DB dla tabel to bez schematu magazyn danych, który umożliwia aplikacjom przechowywanie danych ze strukturą 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 Python.
Dokumentacja interfejsu API — pakiet | kodu | źródłowego biblioteki (PyPI) | Interfejs wiersza polecenia dla deweloperów platformy Azure
Wymagania wstępne
- Azure Developer CLI
- Docker Desktop
- Python 3.12
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.
Otwórz terminal w pustym katalogu.
Jeśli jeszcze nie uwierzytelniono, uwierzytelnij się w interfejsie wiersza polecenia dewelopera platformy Azure 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
Użyj
azd init
polecenia , aby zainicjować projekt.azd init --template cosmos-db-table-python-quickstart
Podczas inicjowania skonfiguruj unikatową nazwę środowiska.
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
Podczas procesu aprowizacji wybierz subskrypcję, żądaną lokalizację i docelową grupę zasobów. Poczekaj na zakończenie procesu aprowizacji. Proces może potrwać około pięciu minut.
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.
Użyj adresu URL w konsoli, aby przejść do aplikacji internetowej w przeglądarce. Obserwuj dane wyjściowe uruchomionej aplikacji.
Instalowanie biblioteki klienta
Biblioteka klienta jest dostępna za pośrednictwem interfejsu azure-data-tables
PyPi jako pakietu.
Otwórz terminal i przejdź do
/src
folderu.cd ./src
Jeśli pakiet nie został jeszcze zainstalowany, zainstaluj go
azure-data-tables
przy użyciu poleceniapip install
.pip install azure-data-tables
Otwórz i przejrzyj plik src/requirements.txt , aby sprawdzić, czy
azure-data-tables
wpis istnieje.
Model obiektów
Nazwa/nazwisko | opis |
---|---|
TableServiceClient |
Ten typ jest podstawowym typem klienta i służy do zarządzania metadanymi lub bazami danych dla całego konta. |
TableClient |
Ten typ reprezentuje klienta dla tabeli w ramach konta. |
Przykłady kodu
- Uwierzytelnianie użytkownika
- Pobieranie tabeli
- Tworzenie jednostki
- Pobieranie jednostki
- Wykonywanie zapytań o jednostki
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 użytkownika
Ten przykład tworzy nowe wystąpienie TableServiceClient
typu.
credential = DefaultAzureCredential()
client = TableServiceClient(endpoint="<azure-cosmos-db-table-account-endpoint>", credential=credential)
Pobieranie tabeli
Ten przykład tworzy wystąpienie TableClient
typu przy użyciu GetTableClient
funkcji TableServiceClient
typu.
table = client.get_table_client("<azure-cosmos-db-table-name>")
Tworzenie encji
Najprostszym sposobem utworzenia nowej jednostki w tabeli jest utworzenie nowego obiektu zapewniającego określenie obowiązkowych RowKey
i PartitionKey
właściwości.
new_entity = {
"RowKey": "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
"PartitionKey": "gear-surf-surfboards",
"Name": "Yamba Surfboard",
"Quantity": 12,
"Sale": False,
}
Utwórz jednostkę w tabeli przy użyciu polecenia upsert_entity
.
created_entity = table.upsert_entity(new_entity)
Pobieranie jednostki
Określoną jednostkę można pobrać z tabeli przy użyciu polecenia get_entity
.
existing_entity = table.get_entity(
row_key="aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
partition_key="gear-surf-surfboards",
)
Wykonywanie zapytań o jednostki
Po wstawieniu jednostki można również uruchomić zapytanie, aby pobrać wszystkie jednostki pasujące do określonego filtru przy użyciu query_entities
filtru OData ciągu.
category = "gear-surf-surfboards"
filter = f"PartitionKey eq '{category}'"
entities = table.query_entities(query_filter=filter)
Przeanalizuj wyniki zapytania podzielone na strony przy użyciu for
pętli.
for entity in entities:
# Do something
Czyszczenie zasobów
Jeśli nie potrzebujesz już przykładowej aplikacji lub zasobów, usuń odpowiednie wdrożenie i wszystkie zasoby.
azd down