Tutorial: Membuat Jupyter Notebook untuk menganalisis data di akun Azure Cosmos DB for NoSQL Anda menggunakan notebook Jupyter Visual Studio Code

Tutorial ini menjelaskan cara menggunakan notebook Visual Studio Code Jupyter untuk berinteraksi dengan akun Azure Cosmos DB for NoSQL Anda. Anda akan melihat cara menyambungkan ke akun, mengimpor data, dan menjalankan kueri.

Prasyarat

Python

• Akun Azure Cosmos DB for NoSQL yang sudah ada.
  • Jika Anda memiliki langganan Azure yang sudah ada, buat akun baru.
• Instal Visual Studio Code dan siapkan lingkungan Anda untuk menggunakan notebook.

C#

• Akun Azure Cosmos DB for NoSQL yang sudah ada.
  • Jika Anda memiliki langganan Azure yang sudah ada, buat akun baru.
• Instal Visual Studio Code dan siapkan lingkungan Anda untuk menggunakan notebook.
• Pasang ekstensi Polyglot notebooks untuk Visual Studio Code.

Buat notebook baru

Di bagian ini, Anda akan membuat database Azure Cosmos, kontainer, dan mengimpor data ritel ke kontainer.

Python

1. Buka Visual Studio Code.
2. Jalankan perintah Buat: Notebook Jupyter Baru dari Palet Perintah (Ctrl+Shift+P) atau buat file .ipynb baru di ruang kerja Anda.

C#

1. Buka Visual Studio Code.

2. Jalankan Buku Catatan Poliglot: Buat buku catatan kosong baru dari Palet Perintah (Ctrl+Shift+P).

   

3. Pilih ekstensi file .ipynb.

4. Pilih C# sebagai bahasa default.

Petunjuk / Saran

Sekarang setelah buku catatan baru dibuat, Anda dapat menyimpannya dan menamainya seperti AnalyzeRetailData.ipynb.

Membuat database dan kontainer menggunakan SDK

Python

1. Mulai di sel kode default.

2. Instal paket Azure.cosmos. Jalankan sel ini sebelum melanjutkan.

   %pip install azure.cosmos
   

3. Impor paket apa pun yang Anda butuhkan untuk tutorial ini.

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

4. Buat instans baru CosmosClient.

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

5. Buat database bernama RetailIngest menggunakan SDK bawaan.

   database = cosmos_client.create_database_if_not_exists('RetailIngest')
   

6. Buat kontainer bernama WebsiteMetrics dengan kunci partisi ./CartID

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

7. Pilih Jalankan untuk membuat database dan sumber daya kontainer.

   

C#

1. Mulai di sel kode default.

2. Instal paket Microsoft.Azure.Cosmos NuGet. Jalankan sel ini sebelum melanjutkan.

   #r "nuget: Microsoft.Azure.Cosmos"
   

3. Buat sel kode baru.

4. Impor paket apa pun yang Anda butuhkan untuk tutorial ini.

   using Microsoft.Azure.Cosmos;
   

5. Buat instans baru jenis klien menggunakan SDK bawaan. Isi titik akhir URI dan kunci akun Azure Cosmos DB Anda. Anda dapat menemukan nilai-nilai ini di halaman Kunci di akun Azure Cosmos DB Anda.

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

6. Buat database bernama RetailIngest.

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

7. Buat kontainer bernama WebsiteMetrics dengan kunci partisi ./CartID

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

8. Pilih Jalankan Sel untuk membuat database dan sumber daya kontainer.

   

Mengimpor data ke dalam kontainer

Python

1. Menambahkan sel kode baru

2. Dalam sel kode, tambahkan kode berikut untuk mengunggah data dari url ini: <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. Jalankan sel ini. Ini akan memakan waktu 45 detik hingga 1 menit untuk dijalankan.

C#

1. Tambahkan sel kode baru.

2. Di sel kode, buat kelas C# baru untuk mewakili item dalam kontainer. Jalankan sel ini.

   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. Tambahkan sel kode baru.

4. Dalam sel kode, tambahkan kode berikut untuk mengunggah data dari url ini: <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. Jalankan sel ini. Ini akan memakan waktu 45 detik hingga 1 menit untuk dijalankan.

Analisis data Anda

Python

1. Buat sel kode baru lainnya.

2. Di sel kode, gunakan kueri SQL untuk mengisi DataFrame Pandas. Jalankan sel ini.

   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. Buat sel kode baru lainnya.

4. Di sel kode, keluarkan 10 item teratas dari dataframe. Jalankan sel ini.

   df_cosmos.head(10)
   

5. Amati hasil dari menjalankan perintah.

   	Tindakan	Pendapatan Barang	Negara	Item
   0	Dibeli	19.99	Makedonia	Kemeja Berkancing
   1	Telah Dilihat	12.00	Papua Nugini	Kalung
   2	Telah Dilihat	25.00	Slowakia (Republik Slowakia)	Kardigan
   3	Dibeli	14.00	Senegal	Sepatu Sandal
   4	Telah Dilihat	50.00	Panama	Celana Pendek Denim
   5	Telah Dilihat	14.00	Senegal	Sepatu Sandal
   6	Ditambahkan	14.00	Senegal	Sepatu Sandal
   7	Ditambahkan	50.00	Panama	Celana Pendek Denim
   8	Dibeli	33,00	Wilayah Palestina	Atasan merah
   9	Telah Dilihat	30.00	Malta	Sweater Hijau

6. Buat sel kode baru lainnya.

7. Di dalam sel kode, impor paket pandas untuk menyesuaikan output dari dataframe. Jalankan sel ini.

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

8. Amati hasil dari menjalankan perintah.

   	Item	Test
   0	Sepatu Sandal	66
   1	Kalung	55
   2	Sepatu Atletik	111
   ...	...	...
   45	Jaket Pemecah Angin	56

C#

1. Buat sel kode baru.

2. Di sel kode, tambahkan kode untuk menjalankan kueri SQL menggunakan SDK yang menyimpan output kueri dalam variabel jenis List<T> hasil bernama.

   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. Buat sel kode baru lainnya.

4. Di sel kode, buat kamus dengan menambahkan permutasi unik bidang Item sebagai kunci dan jumlah bidang Harga sebagai nilai. Ini memberikan total penjualan untuk setiap item. Jalankan sel ini.

   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. Amati output dengan kombinasi unik bidang Item dan Harga .

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

Langkah selanjutnya

• Mulai menggunakan pustaka klien Azure Cosmos DB for NoSQL untuk .NET
• Mulai menggunakan pustaka klien Azure Cosmos DB for NoSQL untuk Python