Tutorial: Erstellen eines Jupyter Notebooks zum Analysieren von Daten in Ihrem Azure Cosmos DB for NoSQL-Konto mithilfe von Visual Studio Code Jupyter-Notebooks

Öffnen Sie Visual Studio Code.

Führen Sie den Befehl Polyglot-Notebook: Erstellen eines neuen leeren Notebooks über die Befehlspalette (Strg+Umschalt+P) aus.

Wählen Sie die IPYNB-Dateierweiterung aus.

Wählen Sie C# als Standardsprache aus.

Beginnen Sie in der Standardcodezelle.

Installieren Sie das Azure.cosmos-Paket. Führen Sie diese Zelle aus, bevor Sie fortfahren.

%pip install azure.cosmos

Importieren Sie alle Pakete, die Sie für dieses Tutorial benötigen.

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

Erstellen Sie eine neue Instanz von CosmosClient.

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

Erstellen Sie mit dem integrierten SDK eine Datenbank namens RetailIngest.

database = cosmos_client.create_database_if_not_exists('RetailIngest')

Erstellen Sie einen Container namens WebsiteMetrics mit einem Partitionsschlüssel von /CartID.

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

Wählen Sie Ausführen aus, um die Datenbank und die Containerressource zu erstellen.

Beginnen Sie in der Standardcodezelle.

Installieren Sie das NuGet-Paket „Microsoft.Azure.Cosmos“. Führen Sie diese Zelle aus, bevor Sie fortfahren.

#r "nuget: Microsoft.Azure.Cosmos"

Erstellen Sie eine neue Codezelle.

Importieren Sie alle Pakete, die Sie für dieses Tutorial benötigen.

using Microsoft.Azure.Cosmos;

Erstellen Sie mit dem integrierten SDK eine neue Instanz des Clienttyps. Füllen Sie den URI-Endpunkt und den Schlüssel Ihres Azure Cosmos DB-Kontos aus. Diese Werte finden Sie auf der Seite Schlüssel in Ihrem Azure Cosmos DB-Konto.

var endpoint = "<FILL ME>";
var key = "<FILL ME>";

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

Erstellen Sie eine Datenbank namens RetailIngest.

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

Erstellen Sie einen Container namens WebsiteMetrics mit einem Partitionsschlüssel von /CartID.

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

Wählen Sie Zelle ausführen aus, um die Datenbank- und Containerressource zu erstellen.

Fügen Sie eine neue Codezelle hinzu

Fügen Sie in der Codezelle den folgenden Code hinzu, um Daten aus dieser URL hochzuladen: <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)

Führen Sie die Zelle aus. Dies dauert 45 Sekunden bis 1 Minute.

Fügen Sie eine neue Codezelle hinzu.

Erstellen Sie in der Codezelle eine neue C#-Klasse, um ein Element im Container darzustellen. Führen Sie die Zelle aus.

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; }
}

Fügen Sie eine neue Codezelle hinzu.

Fügen Sie in der Codezelle den folgenden Code hinzu, um Daten aus dieser URL hochzuladen: <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
}

Führen Sie die Zelle aus. Dies dauert 45 Sekunden bis 1 Minute.

Erstellen Sie eine weitere neue Codezelle.

Verwenden Sie in der Codezelle eine SQL-Abfrage, um einen Pandas DataFrame zu erstellen. Führen Sie diese Zelle aus.

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)

Erstellen Sie eine weitere neue Codezelle.

Geben Sie in der Codezelle die oberen 10 Dataframe-Elemente aus. Führen Sie diese Zelle aus.

df_cosmos.head(10)

Beobachten Sie die Ausgabe der Befehlsausführung.

Erstellen Sie eine weitere neue Codezelle.

Importieren Sie in der Codezelle das pandas-Paket, um die Dataframe-Ausgabe anzupassen. Führen Sie diese Zelle aus.

import pandas as pd    
df_cosmos.groupby("Item").size().reset_index()

Beobachten Sie die Ausgabe der Befehlsausführung.

Erstellen Sie eine neue Codezelle.

Fügen Sie in der Codezelle Code hinzu, um eine SQL-Abfrage mit dem SDK auszuführen und die Ausgabe der Abfrage in einer Variablen des Typs List<T> namens results zu speichern.

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);
    }
}

Erstellen Sie eine weitere neue Codezelle.

Erstellen Sie in der Codezelle ein Wörterbuch, indem Sie eindeutige Permutationen des Item-Felds als Schlüssel und die Summe des Price-Felds als Wert hinzufügen. Dies gibt den Gesamtumsatz für jeden Artikel an. Führen Sie diese Zelle aus.

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

Beobachten Sie die Ausgabe mit eindeutigen Kombinationen der Felder Item und Price.

...
Black Tee: 603
Flannel Shirt: 1199.40
Socks: 210.00
Rainjacket: 2695
...