Självstudie: Skapa en Jupyter Notebook för att analysera data i ditt Azure Cosmos DB for NoSQL-konto med hjälp av Visual Studio Code Jupyter Notebooks

GÄLLER FÖR: NoSQL

Den här självstudien guidar dig i hur du använder Visual Studio Code Jupyter notebooks för att interagera med ditt Azure Cosmos DB för NoSQL-konto. Du kommer att se hur du ansluter till ditt konto, importerar data och kör frågor.

Förutsättningar

Python

• Ett befintligt Azure Cosmos DB för NoSQL-konto.
  • Om du har en befintlig Azure-prenumeration skapar du ett nytt konto.
  • Ingen Azure-prenumeration? Du kan prova Azure Cosmos DB kostnadsfritt utan kreditkort.
• Installera Visual Studio Code och konfigurera din miljö för att använda notebooks.

C#

• Ett befintligt Azure Cosmos DB för NoSQL-konto.
  • Om du har en befintlig Azure-prenumeration skapar du ett nytt konto.
  • Ingen Azure-prenumeration? Du kan prova Azure Cosmos DB kostnadsfritt utan kreditkort.
• Installera Visual Studio Code och ställ in din miljö för att använda anteckningsböcker.
• Installera tillägget Polyglot Notebooks för Visual Studio Code.

Skapa en ny notebook

I det här avsnittet skapar du Azure Cosmos-databasen, containern och importerar detaljhandelsdata till containern.

Python

1. Öppna Visual Studio Code.
2. Kör kommandot Skapa: Ny Jupyter Notebook från kommandopaletten (Ctrl+Skift+P) eller skapa en ny .ipynb-fil på arbetsytan.

C#

1. Öppna Visual Studio Code.

2. Kör Polyglot Notebook: Skapa ett nytt blank notebook-kommando från kommandopaletten (Ctrl+Skift+P).

   

3. Välj filnamnstillägget .ipynb.

4. Välj C# som standardspråk.

Tips

Nu när den nya notebook-filen har skapats kan du spara den och ge den namnet AnalyzeRetailData.ipynb.

Skapa en databas och container med hjälp av SDK

Python

1. Starta i standardkodcellen.

2. Installera Azure.cosmos-paketet. Kör den här cellen innan du fortsätter.

   %pip install azure.cosmos
   

3. Importera alla paket som du behöver för den här självstudien.

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

4. Skapa en ny instans av CosmosClient.

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

5. Skapa en databas med namnet RetailIngest med hjälp av det inbyggda SDK:et.

   database = cosmos_client.create_database_if_not_exists('RetailIngest')
   

6. Skapa en container med namnet WebsiteMetrics med partitionsnyckeln/CartID.

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

7. Välj Kör för att skapa databasen och containerresursen.

   

C#

1. Starta i standardkodcellen.

2. Installera NuGet-paketet Microsoft.Azure.Cosmos. Kör den här cellen innan du fortsätter.

   #r "nuget: Microsoft.Azure.Cosmos"
   

3. Skapa en ny kodcell.

4. Importera alla paket som du behöver för den här självstudien.

   using Microsoft.Azure.Cosmos;
   

5. Skapa en ny instans av klienttypen med hjälp av den inbyggda SDK:n. Fyll i URI-slutpunkten och nyckeln för ditt Azure Cosmos DB-konto. Du hittar dessa värden på sidan Nycklar i ditt Azure Cosmos DB-konto.

   var endpoint = "<FILL ME>";
   var key = "<FILL ME>";
   
   var cosmosClient = new CosmosClient(Cosmos.Endpoint, Cosmos.Key);
   

6. Skapa en databas med namnet RetailIngest.

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

7. Skapa en container med namnet WebsiteMetrics med partitionsnyckeln/CartID.

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

8. Välj Kör cell för att skapa databasen och containerresursen.

   

Importera data till containern

Python

1. Lägga till en ny kodcell

2. I kodcellen lägger du till följande kod för att ladda upp data från den här URL:en: <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)
   

3. Kör cellen. Det tar 45 sekunder till 1 minut att genomföra.

C#

1. Lägg till en ny kodcell.

2. I kodcellen skapar du en ny C#-klass som representerar ett objekt i containern. Kör cellen.

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

3. Lägg till en ny kodcell.

4. I kodcellen lägger du till följande kod för att ladda upp data från den här URL:en: <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
   }
   

5. Kör cellen. Det tar 45 sekunder till 1 minut att köra.

Analysera dina data

Python

1. Skapa en ny kodcell.

2. I kodcellen använder du en SQL-fråga för att fylla i en Pandas DataFrame. Kör den här cellen.

   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)
   

3. Skapa en ny kodcell.

4. I kodcellen matar du ut de 10 översta objekten från dataramen. Kör den här cellen.

   df_cosmos.head(10)
   

5. Observera utdata från körningen av kommandot.

   	Åtgärd	Artikelintäkt	Land	Artikel
   0	Inköpt	19.99	Nordmakedonien	Skjorta med knapp
   1	Visat	12,00	Papua Nya Guinea	Halsband
   2	Visad	25,00	Slovakien (Slovakien)	Kofta tröja
   3	Inköpt	14,00	Senegal	Flip Flop skor
   4	Visat	50.00	Panama	Jeansshorts
   5	Visat	14,00	Senegal	Flip Flop skor
   6	Tillagd	14,00	Senegal	Flip Flop skor
   7	Tillagd	50.00	Panama	Jeansshorts
   8	Inköpt	33,00	Det palestinska territoriet	Röd topp
   9	Visat	30,00	Malta	Grön tröja

6. Skapa en ny kodcell.

7. Importera Pandas-paketet i kodcellen för att anpassa dataramens utdata. Kör den här cellen.

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

8. Observera utdata från körningen av kommandot.

   	Artikel	Test
   0	Flip Flop skor	66
   1	Halsband	55
   2	Atletiska skor	111
   ...	...	...
   45	Vindbrytarjacka	56

C#

1. Skapa en ny kodcell.

2. I kodcellen lägger du till kod för att köra en SQL-fråga med hjälp av SDK :et som lagrar utdata för frågan i en variabel av typen List<T> namngivna resultat.

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

3. Skapa en ny kodcell.

4. I kodcellen skapar du en ordlista genom att lägga till unika permutationer av fältet Objekt som nyckel och summan av fältet Pris som värde. Detta ger den totala försäljningen för varje objekt. Kör den här cellen.

   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
   

5. Observera utdata med unika kombinationer av fälten Item och Price .

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

Nästa steg

• Kom igång med Azure Cosmos DB for NoSQL-klientbiblioteket för .NET
• Kom igång med Azure Cosmos DB for NoSQL-klientbiblioteket för Python