Tutoriel : Créer un Jupyter Notebook pour analyser des données dans votre compte Azure Cosmos DB for NoSQL à l’aide de notebooks Jupyter Visual Studio Code

Ouvrez Visual Studio Code.

Exécutez la commande Notebook Polyglot : créer un notebook vide à partir de la palette de commandes (Ctrl+Maj+P).

Sélectionnez l’extension de fichier .ipynb.

Sélectionnez C# comme langage par défaut.

Démarrez dans la cellule de code par défaut.

Installez le package Azure.cosmos. Exécutez cette cellule avant de continuer.

%pip install azure.cosmos

Importez les packages dont vous avez besoin pour ce tutoriel.

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

Créez une instance de CosmosClient.

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

Créez une base de données nommée RetailIngest à l’aide du Kit de développement logiciel (SDK) intégré.

database = cosmos_client.create_database_if_not_exists('RetailIngest')

Créez un conteneur nommé WebsiteMetrics avec une clé de partition de /CartID.

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

Sélectionnez Exécuter pour créer la base de données et la ressource de conteneur.

Démarrez dans la cellule de code par défaut.

Installez le package NuGet Microsoft.Azure.Cosmos. Exécutez cette cellule avant de continuer.

#r "nuget: Microsoft.Azure.Cosmos"

Créez une nouvelle cellule de code.

Importez les packages dont vous avez besoin pour ce tutoriel.

using Microsoft.Azure.Cosmos;

Créez une instance du type client à l’aide du Kit de développement logiciel (SDK) intégré. Renseignez le point de terminaison d’URI et la clé de votre compte Azure Cosmos DB. Vous trouverez ces valeurs dans la page Clés de votre compte Azure Cosmos DB.

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

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

Créez une base de données nommée RetailIngest.

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

Créez un conteneur nommé WebsiteMetrics avec une clé de partition de /CartID.

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

Sélectionnez Exécuter la cellule pour créer la base de données et la ressource de conteneur.

Ajouter une cellule de code

Dans la cellule de code, ajoutez le code suivant pour charger des données à partir de cette 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)

Exécutez la cellule. L’exécution prend 45 secondes à 1 minute.

Ajoutez une cellule de code.

Dans la cellule de code, créez une classe C# pour représenter un élément dans le conteneur. Exécutez la cellule.

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

Ajoutez une cellule de code.

Dans la cellule de code, ajoutez le code suivant pour charger des données à partir de cette 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
}

Exécutez la cellule. L’exécution prend 45 secondes à 1 minute.

Créez une autre cellule de code.

Dans la cellule de code, utilisez une requête SQL pour remplir un DataFrame Pandas. Exécutez cette cellule.

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)

Créez une autre cellule de code.

Dans la cellule de code, sortiez les 10 premiers éléments du dataframe. Exécutez cette cellule.

df_cosmos.head(10)

Observez la sortie de l’exécution de la commande.

Créez une autre cellule de code.

Dans la cellule de code, importez le package pandas pour personnaliser la sortie du dataframe. Exécutez cette cellule.

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

Observez la sortie de l’exécution de la commande.

Créez une nouvelle cellule de code.

Dans la cellule de code, ajoutez du code pour exécuter une requête SQL à l’aide du Kit de développement logiciel (SDK) stockant la sortie de la requête dans une variable de type List<T> nommé results.

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

Créez une autre cellule de code.

Dans la cellule de code, créez un dictionnaire en ajoutant des permutations uniques du champ Item en tant que clé et la somme du champ Price comme valeur. Cela donne le total des ventes pour chaque article. Exécutez cette cellule.

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

Observez la sortie avec des combinaisons uniques des champs Item et Price.

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