Zelfstudie: Een Jupyter Notebook maken in Azure Cosmos DB for NoSQL om gegevens te analyseren en visualiseren (preview)

VAN TOEPASSING OP: NoSQL

Waarschuwing

De Jupyter Notebooks-functie van Azure Cosmos DB wordt op 30 maart 2024 buiten gebruik gesteld; U kunt geen ingebouwde Jupyter-notebooks gebruiken vanuit het Azure Cosmos DB-account. We raden u aan de ondersteuning van Visual Studio Code te gebruiken voor Jupyter-notebooks of de client van uw favoriete notebooks.

In deze zelfstudie wordt uitgelegd hoe u de Jupyter Notebooks-functie van Azure Cosmos DB gebruikt om voorbeelddetailgegevens te importeren in een Azure Cosmos DB for NoSQL-account. U ziet hoe u de magic-opdrachten van Azure Cosmos DB kunt gebruiken om query's uit te voeren, de gegevens te analyseren en de resultaten te visualiseren.

Vereisten

• Een bestaand Azure Cosmos DB for NoSQL-account.
  • Als u een bestaand Azure-abonnement hebt, maakt u een nieuw account.
  • Geen Azure-abonnement? U kunt Azure Cosmos DB gratis proberen zonder dat er een creditcard is vereist.

Een nieuwe notebook maken

In deze sectie maakt u de Azure Cosmos-database, -container en importeert u de retailgegevens in de container.

1. Navigeer naar uw Azure Cosmos DB-account en open Data Explorer.

2. Selecteer Nieuw notitieblok.

   

3. Selecteer Maken in het bevestigingsdialoogvenster dat wordt weergegeven.

   Notitie

   Er wordt een tijdelijke werkruimte gemaakt waarmee u met Jupyter Notebooks kunt werken. Wanneer de sessie verloopt, worden notitieblokken in de werkruimte verwijderd.

4. Selecteer de kernel die u wilt gebruiken voor het notebook.

Python

C#

Tip

Nu het nieuwe notitieblok is gemaakt, kunt u de naam ervan wijzigen in bijvoorbeeld VisualizeRetailData.ipynb.

Een database en container maken met behulp van de SDK

Python

1. Begin in de standaardcodecel.

2. Importeer alle pakketten die u nodig hebt voor deze zelfstudie.

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

3. Maak een database met de naam RetailIngest met behulp van de ingebouwde SDK.

   database = cosmos_client.create_database_if_not_exists('RetailIngest')
   

4. Maak een container met de naam WebsiteMetrics met een partitiesleutel van /CartID.

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

5. Selecteer Uitvoeren om de database en containerresource te maken.

   

C#

1. Begin in de standaardcodecel.

2. Importeer alle pakketten die u nodig hebt voor deze zelfstudie.

   using Microsoft.Azure.Cosmos;
   

3. Maak een nieuw exemplaar van het clienttype met behulp van de ingebouwde SDK.

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

4. Maak een database met de naam RetailIngest.

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

5. Maak een container met de naam WebsiteMetrics met een partitiesleutel van /CartID.

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

6. Selecteer Uitvoeren om de database en containerresource te maken.

   

Gegevens importeren met magic-opdrachten

1. Voeg een nieuwe codecel toe.

2. Voeg in de codecel de volgende magic-opdracht toe om te uploaden naar uw bestaande container, de JSON-gegevens uit deze URL: https://cosmosnotebooksdata.blob.core.windows.net/notebookdata/websiteData.json

   %%upload --databaseName RetailIngest --containerName WebsiteMetrics --url https://cosmosnotebooksdata.blob.core.windows.net/notebookdata/websiteData.json
   

3. Selecteer Actieve cel uitvoeren om alleen de opdracht in deze specifieke cel uit te voeren.

   

   Notitie

   Het kan 5-10 seconden duren voordat de importopdracht is voltooid.

4. Bekijk de uitvoer van de opdracht Uitvoeren. Zorg ervoor dat 2654 documenten zijn geïmporteerd.

   Documents successfully uploaded to WebsiteMetrics
   Total number of documents imported:
     Success: 2654
     Failure: 0
   Total time taken : 00:00:04 hours
   Total RUs consumed : 27309.660000001593
   

Uw gegevens visualiseren

Python

1. Maak nog een nieuwe codecel.

2. Gebruik in de codecel een SQL-query om een Pandas DataFrame te vullen.

   %%sql --database RetailIngest --container WebsiteMetrics --output df_cosmos
   SELECT c.Action, c.Price as ItemRevenue, c.Country, c.Item FROM c
   

3. Selecteer Actieve cel uitvoeren om alleen de opdracht in deze specifieke cel uit te voeren.

4. Maak nog een nieuwe codecel.

5. Voer in de codecel de tien belangrijkste items uit het dataframe uit.

   df_cosmos.head(10)
   

6. Selecteer Actieve cel uitvoeren om alleen de opdracht in deze specifieke cel uit te voeren.

7. Bekijk de uitvoer van het uitvoeren van de opdracht.

   	Actie	ItemRevenue	Land/regio	Artikel
   0	Ingekocht	19.99	Macedonië (FYROM)	Button-Up Shirt
   1	Weergegeven	12,00	Papoea-Nieuw-Guinea	Halssnoer
   2	Weergegeven	25.00	Slowakije (Slowaakse Republiek)	Vest trui
   3	Ingekocht	14,00	Senegal	Flop schoenen spiegelen
   4	Weergegeven	50.00	Panama	Denim Shorts
   5	Weergegeven	14,00	Senegal	Flop schoenen spiegelen
   6	Toegevoegd	14,00	Senegal	Flop schoenen spiegelen
   7	Toegevoegd	50.00	Panama	Denim Shorts
   8	Ingekocht	33,00	Palestijnse gebieden	Rode bovenkant
   9	Weergegeven	30,00	Malta	Groene trui

8. Maak nog een nieuwe codecel.

9. Importeer in de codecel het pandas-pakket om de uitvoer van het dataframe aan te passen.

   import pandas as pd
   pd.options.display.html.table_schema = True
   pd.options.display.max_rows = None
   
   df_cosmos.groupby("Item").size()
   

10. Selecteer Actieve cel uitvoeren om alleen de opdracht in deze specifieke cel uit te voeren.

11. Selecteer in de uitvoer de optie Lijndiagram om een andere visualisatie van de gegevens weer te geven.

    

C#

1. Maak een nieuwe codecel.

2. Maak in de codecel een nieuwe C#-klasse om een item in de container weer te geven.

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

3. Maak nog een nieuwe codecel.

4. Voeg in de codecel code toe om een SQL-query uit te voeren met behulp van de SDK die de uitvoer van de query opslaat in een variabele van het type List<T> benoemde resultaten.

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

5. Maak nog een nieuwe codecel.

6. Maak in de codecel een woordenlijst door unieke permutaties van het veld Item toe te voegen als de sleutel en de gegevens in het veld Prijs als de waarde.

   var dictionary = new Dictionary<string, decimal>();
   
   foreach(var result in results)
   {
       dictionary.TryAdd (result.Item, result.Price); 
   }
   
   dictionary
   

7. Selecteer Actieve cel uitvoeren om alleen de opdracht in deze specifieke cel uit te voeren.

8. Bekijk de uitvoer met unieke combinaties van de velden Item en Prijs .

   ...
   Denim Jacket:31.99
   Fleece Jacket:65
   Sandals:12
   Socks:3.75
   Sandal:35.5
   Light Jeans:80
   ...
   

9. Maak nog een nieuwe codecel.

10. Voer in de codecel de resultatenvariabele uit .

    results
    

11. Selecteer Actieve cel uitvoeren om alleen de opdracht in deze specifieke cel uit te voeren.

12. Selecteer in de uitvoer de optie BoxPlot om een andere visualisatie van de gegevens weer te geven.

    

Uw notitieblok behouden

1. Open in de sectie Notitieblokken het contextmenu voor het notitieblok dat u voor deze zelfstudie hebt gemaakt en selecteer Downloaden.

   

   Tip

   Als u uw werk permanent wilt opslaan, slaat u uw notitieblokken op in een GitHub-opslagplaats of downloadt u de notebooks naar uw lokale computer voordat de sessie wordt beëindigd.

Volgende stappen

• Meer informatie over de Jupyter Notebooks-functie in Azure Cosmos DB
• Notebooks uit GitHub importeren in een Azure Cosmos DB for NoSQL-account
• Bekijk de veelgestelde vragen over ondersteuning voor Jupyter Notebook