Oktatóanyag: Jupyter-jegyzetfüzet létrehozása az Azure Cosmos DB for NoSQL-fiók adatainak a Visual Studio Code Jupyter-jegyzetfüzetek használatával történő elemzéséhez

A KÖVETKEZŐRE VONATKOZIK: NoSQL

Ez az oktatóanyag bemutatja, hogyan használhatja a Visual Studio Code Jupyter-jegyzetfüzeteket az Azure Cosmos DB for NoSQL-fiók kezeléséhez. Megtudhatja, hogyan csatlakozhat a fiókjához, importálhat adatokat, és futtathat lekérdezéseket.

Előfeltételek

Python

• Egy meglévő Azure Cosmos DB for NoSQL-fiók.
  • Ha már rendelkezik Azure-előfizetéssel, hozzon létre egy új fiókot.
  • Nincs Azure-előfizetés? Ingyenesen kipróbálhatja az Azure Cosmos DB-t hitelkártya nélkül.
• Telepítse a Visual Studio Code-ot , és állítsa be a környezetet jegyzetfüzetek használatára.

C#

• Egy meglévő Azure Cosmos DB for NoSQL-fiók.
  • Ha már rendelkezik Azure-előfizetéssel, hozzon létre egy új fiókot.
  • Nincs Azure-előfizetés? Ingyenesen kipróbálhatja az Azure Cosmos DB-t hitelkártya nélkül.
• Telepítse a Visual Studio Code-ot , és állítsa be a környezetet jegyzetfüzetek használatára.
• Telepítse a Polyglot Notebooks bővítményt a Visual Studio Code-hoz.

Új jegyzetfüzet létrehozása

Ebben a szakaszban létrehozza az Azure Cosmos-adatbázist, a tárolót, és importálja a kiskereskedelmi adatokat a tárolóba.

Python

1. Nyissa meg a Visual Studio Code-ot.
2. Futtassa a Create: New Jupyter Notebook parancsot a parancskatalógusból (Ctrl+Shift+P), vagy hozzon létre egy új .ipynb fájlt a munkaterületen.

C#

1. Nyissa meg a Visual Studio Code-ot.

2. Futtassa a Többhelyes jegyzetfüzet: Új üres jegyzetfüzet létrehozása parancsot a parancskatalógusból (Ctrl+Shift+P).

   

3. Válassza ki az .ipynb fájlkiterjesztést.

4. Alapértelmezett nyelvként válassza a C#-t.

Tipp.

Most, hogy létrejött az új jegyzetfüzet, mentheti és elnevezheti az AnalyzeRetailData.ipynb fájlhoz hasonló nevet.

Adatbázis és tároló létrehozása az SDK használatával

Python

1. Kezdje az alapértelmezett kódcellával.

2. Telepítse az Azure.cosmos-csomagot. A folytatás előtt futtassa ezt a cellát.

   %pip install azure.cosmos
   

3. Importálja az oktatóanyaghoz szükséges csomagokat.

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

4. Hozzon létre egy új CosmosClient-példányt.

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

5. Hozzon létre egy RetailIngest nevű adatbázist a beépített SDK használatával.

   database = cosmos_client.create_database_if_not_exists('RetailIngest')
   

6. Hozzon létre egy WebsiteMetrics nevű tárolót a következő partíciókulccsal/CartID: .

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

7. Válassza a Futtatás lehetőséget az adatbázis és a tárolóerőforrás létrehozásához.

   

C#

1. Kezdje az alapértelmezett kódcellával.

2. Telepítse a Microsoft.Azure.Cosmos NuGet-csomagot. Futtassa a cellát a folytatás előtt.

   #r "nuget: Microsoft.Azure.Cosmos"
   

3. Hozzon létre egy új kódcellát.

4. Importálja az oktatóanyaghoz szükséges csomagokat.

   using Microsoft.Azure.Cosmos;
   

5. Hozzon létre egy új ügyféltípus-példányt a beépített SDK használatával. Töltse ki az Azure Cosmos DB-fiók URI-végpontját és kulcsát. Ezeket az értékeket az Azure Cosmos DB-fiók Kulcsok lapján találja.

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

6. Hozzon létre egy RetailIngest nevű adatbázist.

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

7. Hozzon létre egy WebsiteMetrics nevű tárolót a következő partíciókulccsal/CartID: .

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

8. Válassza a Cella végrehajtása lehetőséget az adatbázis és a tárolóerőforrás létrehozásához.

   

Adatok importálása tárolóba

Python

1. Új kódcella hozzáadása

2. A kódcellán belül adja hozzá a következő kódot, hogy adatokat töltsön fel ebből az URL-címből: 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. Futtassa a cellát. Ez 45 másodperc és 1 perc között fut.

C#

1. Adjon hozzá egy új kódcellát.

2. A kódcellában hozzon létre egy új C#-osztályt a tároló egy elemének megjelenítéséhez. Futtassa a cellát.

   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. Adjon hozzá egy új kódcellát.

4. A kódcellán belül adja hozzá a következő kódot, hogy adatokat töltsön fel ebből az URL-címből: 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. Futtassa a cellát. Ez 45 másodperc és 1 perc között fut.

Az adatok elemzése

Python

1. Hozzon létre egy másik új kódcellát.

2. A kódcellában sql-lekérdezés használatával töltse fel a Pandas DataFrame-et. Futtassa ezt a cellát.

   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. Hozzon létre egy másik új kódcellát.

4. A kódcellában adja ki a 10 legfontosabb elemet az adatkeretből. Futtassa ezt a cellát.

   df_cosmos.head(10)
   

5. Figyelje meg a parancs futtatásának kimenetét.

   	Action	ItemRevenue	Ország	Cikk
   0	Vásárolt	19.99	Macedónia	Gombos póló
   1	Megjelenítve	12.00	Pápua Új-Guinea	Nyaklánc
   2	Megjelenítve	25.00	Szlovákia (Szlovák Köztársaság)	Kardigán pulóver
   3	Vásárolt	14.00	Szenegál	Papucs cipő
   4	Megjelenítve	50.00	Panama	Denim Shorts
   5	Megjelenítve	14.00	Szenegál	Papucs cipő
   6	Hozzáadva	14.00	Szenegál	Papucs cipő
   7	Hozzáadva	50.00	Panama	Denim Shorts
   8	Vásárolt	33,00	Palesztin területek	Piros felül
   9	Megjelenítve	30.00	Málta	Zöld pulóver

6. Hozzon létre egy másik új kódcellát.

7. A kódcellában importálja a pandas-csomagot az adatkeret kimenetének testreszabásához. Futtassa ezt a cellát.

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

8. Figyelje meg a parancs futtatásának kimenetét.

   	Cikk	Test
   0	Papucs cipő	66
   1	Nyaklánc	55
   2	Sportcipők	111
   ...	...	...
   45	Windbreaker Jacket	56

C#

1. Hozzon létre egy új kódcellát.

2. A kódcellában adjon hozzá kódot egy SQL-lekérdezés végrehajtásához az SDK használatával, amely a lekérdezés kimenetét egy elnevezett típusú változóban List<T> tárolja.

   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. Hozzon létre egy másik új kódcellát.

4. A kódcellában hozzon létre egy szótárt úgy, hogy kulcsként hozzáadja az Elem mező egyedi permutációit, és értékként az Ár mező összegét. Ez az egyes cikkek teljes értékesítését adja meg. Futtassa ezt a cellát.

   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. Figyelje meg a kimenetet az Elem és az Ár mező egyedi kombinációival.

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

Következő lépések

• Bevezetés a .NET-hez készült Azure Cosmos DB for NoSQL ügyfélkódtár használatbavételéhez
• Ismerkedés a Pythonhoz készült Azure Cosmos DB for NoSQL ügyfélkódtárral