Öğretici: Visual Studio Code Jupyter not defterlerini kullanarak NoSQL için Azure Cosmos DB hesabınızdaki verileri analiz etmek için Jupyter Not Defteri oluşturma

UYGULANANLAR: NoSQL

Bu öğreticide, NoSQL için Azure Cosmos DB hesabınızla etkileşime geçmek için Visual Studio Code Jupyter not defterlerinin nasıl kullanılacağı açıklanmaktadır. Hesabınıza bağlanmayı, verileri içeri aktarmayı ve sorgu çalıştırmayı göreceksiniz.

Ön koşullar

Python

• Mevcut bir NoSQL için Azure Cosmos DB hesabı.
  • Mevcut bir Azure aboneliğiniz varsa yeni bir hesap oluşturun.
  • Azure aboneliği yok mu? Kredi kartı gerektirmeden Azure Cosmos DB'i ücretsiz deneyebilirsiniz.
• Visual Studio Code'u yükleyin ve ortamınızı not defterlerini kullanacak şekilde ayarlayın.

C#

• Mevcut bir NoSQL için Azure Cosmos DB hesabı.
  • Mevcut bir Azure aboneliğiniz varsa yeni bir hesap oluşturun.
  • Azure aboneliği yok mu? Kredi kartı gerektirmeden Azure Cosmos DB'i ücretsiz deneyebilirsiniz.
• Visual Studio Code'u yükleyin ve ortamınızı not defterlerini kullanacak şekilde ayarlayın.
• Visual Studio Code için Polyglot not defterleri uzantısını yükleyin.

Yeni not defteri oluşturma

Bu bölümde Azure Cosmos veritabanını, kapsayıcısını oluşturacak ve perakende verilerini kapsayıcıya aktaracaksınız.

Python

1. Visual Studio Code'u açın.
2. Komut Paleti'nden Oluştur: Yeni Jupyter Not Defteri komutunu çalıştırın (Ctrl+Shift+P) veya çalışma alanınızda yeni bir .ipynb dosyası oluşturun.

C#

1. Visual Studio Code'u açın.

2. Komut Paleti'nden Polyglot Not Defteri: Yeni boş not defteri oluştur komutunu çalıştırın (Ctrl+Shift+P).

   

3. .ipynb dosya uzantısını seçin.

4. Varsayılan dil olarak C# seçeneğini belirleyin.

Bahşiş

Yeni not defteri oluşturulduğuna göre, not defterini kaydedebilir ve AnalyzeRetailData.ipynb gibi adlandırabilirsiniz.

SDK kullanarak veritabanı ve kapsayıcı oluşturma

Python

1. Varsayılan kod hücresinde başlayın.

2. Azure.cosmos paketini yükleyin. Devam etmeden önce bu hücreyi çalıştırın.

   %pip install azure.cosmos
   

3. Bu öğretici için ihtiyacınız olan tüm paketleri içeri aktarabilirsiniz.

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

4. CosmosClient'ın yeni bir örneğini oluşturun.

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

5. Yerleşik SDK'sını kullanarak RetailIngest adlı bir veritabanı oluşturun.

   database = cosmos_client.create_database_if_not_exists('RetailIngest')
   

6. bölüm anahtarıyla /CartIDWebsiteMetrics adlı bir kapsayıcı oluşturun.

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

7. Veritabanını ve kapsayıcı kaynağını oluşturmak için Çalıştır'ı seçin.

   

C#

1. Varsayılan kod hücresinde başlayın.

2. Microsoft.Azure.Cosmos NuGet paketini yükleyin. Devam etmeden önce bu hücreyi çalıştırın.

   #r "nuget: Microsoft.Azure.Cosmos"
   

3. Yeni bir kod hücresi oluşturun.

4. Bu öğretici için ihtiyacınız olan tüm paketleri içeri aktarabilirsiniz.

   using Microsoft.Azure.Cosmos;
   

5. Yerleşik SDK'sını kullanarak istemci türünün yeni bir örneğini oluşturun. Azure Cosmos DB hesabınızın URI uç noktasını ve anahtarını doldurun. Bu değerleri Azure Cosmos DB hesabınızdaki Anahtarlar sayfasında bulabilirsiniz.

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

6. RetailIngest adlı bir veritabanı oluşturun.

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

7. bölüm anahtarıyla /CartIDWebsiteMetrics adlı bir kapsayıcı oluşturun.

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

8. Veritabanını ve kapsayıcı kaynağını oluşturmak için Hücreyi Yürüt'e tıklayın.

   

Kapsayıcıya veri aktarma

Python

1. Yeni kod hücresi ekleme

2. Kod hücresinin içine şu url'den veri yüklemek için aşağıdaki kodu ekleyin: 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. Hücreyi çalıştırın. Bunun çalıştırılması 45 saniye ile 1 dakika sürer.

C#

1. Yeni bir kod hücresi ekleyin.

2. Kod hücresinde kapsayıcıdaki bir öğeyi temsil eden yeni bir C# sınıfı oluşturun. Hücreyi çalıştırın.

   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. Yeni bir kod hücresi ekleyin.

4. Kod hücresinin içine şu url'den veri yüklemek için aşağıdaki kodu ekleyin: 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. Hücreyi çalıştırın. Bunun çalıştırılması 45 saniye ile 1 dakika sürer.

Verilerinizi analiz etme

Python

1. Başka bir yeni kod hücresi oluşturun.

2. Kod hücresinde, Pandas DataFrame'i doldurmak için SQL sorgusu kullanın. Bu hücreyi çalıştırın.

   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. Başka bir yeni kod hücresi oluşturun.

4. Kod hücresinde, veri çerçevesinden ilk 10 öğenin çıkışını alın. Bu hücreyi çalıştırın.

   df_cosmos.head(10)
   

5. komutunu çalıştırmanın çıkışını gözlemleyin.

   	Eylem	ItemRevenue	Ülke	Kalem
   0	Satın alınan	19.99	Makedonya	Düğmeli Gömlek
   1	Görüntülendi	12,00	Papua Yeni Gine	Kolye
   2	Görüntülendi	25.00	Slovakya (Slovakça Cumhuriyeti)	Hırka Kazak
   3	Satın alınan	14,00	Senegal	Flip Flop Shoes
   4	Görüntülendi	50.00	Panama	Denim Şort
   5	Görüntülendi	14,00	Senegal	Flip Flop Shoes
   6	Eklendi	14,00	Senegal	Flip Flop Shoes
   7	Eklendi	50.00	Panama	Denim Şort
   8	Satın alınan	33.00	Filistin Yönetimi	Kırmızı Üst
   9	Görüntülendi	30.00	Malta	Yeşil Kazak

6. Başka bir yeni kod hücresi oluşturun.

7. Veri çerçevesinin çıkışını özelleştirmek için kod hücresinde pandas paketini içeri aktarın. Bu hücreyi çalıştırın.

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

8. komutunu çalıştırmanın çıkışını gözlemleyin.

   	Kalem	Test etme
   0	Flip Flop Shoes	66
   1	Kolye	55
   2	Atletik Ayakkabı	111
   ...	...	...
   45	Rüzgarlık Ceket	56

C#

1. Yeni bir kod hücresi oluşturun.

2. Kod hücresinde, sorgunun çıktısını results adlı bir değişkende List<T> depolayarak BIR SQL sorgusu yürütmek için kod ekleyin.

   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. Başka bir yeni kod hücresi oluşturun.

4. Kod hücresinde, Anahtar olarak Öğe alanının benzersiz permütasyonlarını ve değer olarak Price alanının toplamını ekleyerek bir sözlük oluşturun. Bu, her öğenin toplam satışını verir. Bu hücreyi çalıştırın.

   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. Madde ve Fiyat alanlarının benzersiz birleşimleriyle çıkışı gözlemleyin.

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

Sonraki adımlar

• .NET için NoSQL için Azure Cosmos DB istemci kitaplığını kullanmaya başlama
• Python için NoSQL için Azure Cosmos DB istemci kitaplığını kullanmaya başlama