Kurz: Vytvoření poznámkového bloku Jupyter pro analýzu dat v účtu Azure Cosmos DB for NoSQL pomocí poznámkových bloků Jupyter editoru Visual Studio Code

Článek
10/18/2023

PLATÍ PRO: NoSQL

Tento kurz vás provede používáním poznámkových bloků Jupyter v editoru Visual Studio Code k interakci s účtem Azure Cosmos DB for NoSQL. Uvidíte, jak se připojit ke svému účtu, importovat data a spouštět dotazy.

Existující účet Azure Cosmos DB for NoSQL.
- Pokud máte existující předplatné Azure, vytvořte nový účet.
- Žádné předplatné Azure? Službu Azure Cosmos DB můžete vyzkoušet zdarma bez nutnosti platební karty.
Nainstalujte Visual Studio Code a nastavte prostředí tak, aby používalo poznámkové bloky.

Vytvoření nového poznámkového bloku

V této části vytvoříte databázi Azure Cosmos, kontejner a importujete maloobchodní data do kontejneru.

Python
C#

Otevřete Visual Studio Code.
Spusťte příkaz Create: New Jupyter Notebook z palety příkazů (Ctrl+Shift+P) nebo vytvořte nový soubor .ipynb v pracovním prostoru.

Tip

Teď, když byl nový poznámkový blok vytvořen, můžete ho uložit a pojmenovat ho jako AnalyzeRetailData.ipynb.

Vytvoření databáze a kontejneru pomocí sady SDK

Python
C#

Začněte ve výchozí buňce kódu.
Nainstalujte balíček Azure.cosmos. Před pokračováním spusťte tuto buňku.
```
%pip install azure.cosmos
```

Importujte všechny balíčky, které pro účely tohoto kurzu potřebujete.

import azure.cosmos
from azure.cosmos.partition_key import PartitionKey
from azure.cosmos import CosmosClient

Vytvořte novou instanci CosmosClient.

endpoint = "<FILL ME>"
key = "<FILL ME>"
cosmos_client = CosmosClient(url=endpoint, credential=key)

Vytvořte databázi s názvem RetailIngest pomocí integrované sady SDK.

database = cosmos_client.create_database_if_not_exists('RetailIngest')

Vytvořte kontejner s názvem WebsiteMetrics s klíčem oddílu /CartID.

container = database.create_container_if_not_exists(id='WebsiteMetrics', partition_key=PartitionKey(path='/CartID'))

Vyberte Spustit a vytvořte databázi a prostředek kontejneru.

Začněte ve výchozí buňce kódu.
Nainstalujte balíček NuGet Microsoft.Azure.Cosmos. Před pokračováním spusťte tuto buňku.
```
#r "nuget: Microsoft.Azure.Cosmos"
```
Vytvořte novou buňku kódu.
Importujte všechny balíčky, které pro účely tohoto kurzu potřebujete.
```
using Microsoft.Azure.Cosmos;
```
Vytvořte novou instanci typu klienta pomocí integrované sady SDK. Vyplňte koncový bod URI a klíč vašeho účtu služby Azure Cosmos DB. Tyto hodnoty najdete na stránce Klíče ve svém účtu služby Azure Cosmos DB.
```
var endpoint = "<FILL ME>";
var key = "<FILL ME>";

var cosmosClient = new CosmosClient(Cosmos.Endpoint, Cosmos.Key);
```

Vytvořte databázi s názvem RetailIngest.

Database database = await cosmosClient.CreateDatabaseIfNotExistsAsync("RetailIngest");

Vytvořte kontejner s názvem WebsiteMetrics s klíčem oddílu /CartID.

Container container = await database.CreateContainerIfNotExistsAsync("WebsiteMetrics", "/CartID");

Výběrem možnosti Provést buňku vytvořte databázi a prostředek kontejneru.

Import dat do kontejneru

Python
C#

Přidání nové buňky kódu

Do buňky kódu přidejte následující kód pro nahrání dat z této adresy URL: https://cosmosnotebooksdata.blob.core.windows.net/notebookdata/websiteData.json.

    import urllib.request
    import json

    with urllib.request.urlopen("https://cosmosnotebooksdata.blob.core.windows.net/notebookdata/websiteData.json") as url:
        docs = json.loads(url.read().decode())

    for doc in docs:
        container.upsert_item(doc)

Spusťte buňku. Spuštění bude trvat 45 sekund až 1 minutu.

Přidejte novou buňku kódu.

V buňce kódu vytvořte novou třídu jazyka C#, která bude představovat položku v kontejneru. Spusťte buňku.

public class Record
{
  public string id { get; set; }
  public int CartID { get; set; }
  public string Action { get; set; }
  public decimal Price { get; set; }
  public string Country { get; set; }
  public string Item { get; set; }
}

Přidejte novou buňku kódu.

Do buňky kódu přidejte následující kód pro nahrání dat z této adresy URL: https://cosmosnotebooksdata.blob.core.windows.net/notebookdata/websiteData.json.

using System.Net.Http;
using System.Text.Json;
using System.IO;

var dataURL = "https://cosmosnotebooksdata.blob.core.windows.net/notebookdata/websiteData.json";
var jsonData = new HttpClient().GetStringAsync(dataURL).Result;

Record[] result = JsonSerializer.Deserialize<Record[]>(jsonData);

foreach (Record record in result) {
    await container.UpsertItemAsync<Record>(record, new PartitionKey(record.CartID)); //43 seconds
}

Spusťte buňku. Spuštění bude trvat 45 sekund až 1 minutu.

Analýza dat

Python
C#

Vytvořte další novou buňku kódu.

V buňce kódu použijte dotaz SQL k naplnění datového rámce Pandas. Spusťte tuto buňku.

import pandas as pd
from pandas import DataFrame

QUERY = "SELECT c.Action, c.Price as ItemRevenue, c.Country, c.Item FROM c"
results = container.query_items(
    query=QUERY, enable_cross_partition_query=True
)

df_cosmos = pd.DataFrame(results)

Vytvořte další novou buňku kódu.
V buňce kódu zadejte výstup prvních 10 položek z datového rámce. Spusťte tuto buňku.
```
df_cosmos.head(10)
```

Sledujte výstup spuštění příkazu.

	Akce	ItemRevenue	Země/oblast	Item
0	Koupeno	19.99	Makedonie	Tričko s tlačítkem
1	Zobrazeno	12,00	Papua-Nová Guinea	Náhrdelník
2	Zobrazeno	25.00	Slovensko (Slovenská republika)	Svetr s karganem
3	Koupeno	14,00	Senegal	Flip Flop Boty
4	Zobrazeno	50.00	Panama	Denim Shorts
5	Zobrazeno	14,00	Senegal	Flip Flop Boty
6	Přidáno	14,00	Senegal	Flip Flop Boty
7	Přidáno	50.00	Panama	Denim Shorts
8	Koupeno	33,00	Palestinská území	Červená nahoře
9	Zobrazeno	30.00	Malta	Zelený svetr

Vytvořte další novou buňku kódu.
V buňce kódu importujte balíček pandas a přizpůsobte výstup datového rámce. Spusťte tuto buňku.
```
import pandas as pd    
df_cosmos.groupby("Item").size().reset_index()
```
Sledujte výstup spuštění příkazu.

Item Test

0 Flip Flop Boty 66

1 Náhrdelník 55

2 Sportovní boty 111

... ... ...

45 Bunda windbreaker 56

	Item	Test
0	Flip Flop Boty	66
1	Náhrdelník	55
2	Sportovní boty	111
...	...	...
45	Bunda windbreaker	56

Vytvořte novou buňku kódu.

V buňce kódu přidejte kód pro spuštění dotazu SQL pomocí sady SDK, který ukládá výstup dotazu do proměnné s pojmenovanými výsledky typuList<T>.

using System.Collections.Generic;

var query = new QueryDefinition(
    query: "SELECT c.Action, c.Price, c.Country, c.Item FROM c"
);

FeedIterator<Record> feed = container.GetItemQueryIterator<Record>(
    queryDefinition: query
);

var results = new List<Record>();
while (feed.HasMoreResults)
{
    FeedResponse<Record> response = await feed.ReadNextAsync();
    foreach (Record result in response)
    {
        results.Add(result);
    }
}

Vytvořte další novou buňku kódu.

V buňce kódu vytvořte slovník přidáním jedinečných permutací pole Item jako klíče a součtem pole Cena jako hodnoty. Tím se zobrazí celkový prodej pro každou položku. Spusťte tuto buňku.

var dictionary = new Dictionary<string, decimal>();

foreach(var result in results)
{
    if (dictionary.ContainsKey(result.Item)) {
        dictionary[result.Item] += result.Price;
    }
    else {
        dictionary.TryAdd (result.Item, result.Price); 

    }
}

dictionary

Prohlédněte si výstup s jedinečnými kombinacemi polí Item (Položka ) a Price (Cena ).
```
...
Black Tee: 603
Flannel Shirt: 1199.40
Socks: 210.00
Rainjacket: 2695
...
```