البرنامج التعليمي: إنشاء دفتر ملاحظات Jupyter لتحليل البيانات في حساب Azure Cosmos DB ل NoSQL باستخدام دفاتر ملاحظات Visual Studio Code Jupyter

مقالة
10/18/2023

ينطبق على: NoSQL

يتعرف هذا البرنامج التعليمي على كيفية استخدام دفاتر ملاحظات Jupyter لتعليمة Visual Studio البرمجية للتفاعل مع حساب Azure Cosmos DB ل NoSQL. سترى كيفية الاتصال بحسابك واستيراد البيانات وتشغيل الاستعلامات.

حساب Azure Cosmos DB ل NoSQL موجود.
- إذا كان لديك اشتراك Azure موجود، فبادر بإنشاء حساب جديد.
- لا يوجد اشتراك في Azure؟ يمكنك تجربة Azure Cosmos DB مجانا دون الحاجة إلى بطاقة ائتمان.
تثبيت Visual Studio Code وإعداد بيئتك لاستخدام دفاتر الملاحظات.

قم بإنشاء دفتر ملاحظات جديد

في هذا القسم، ستقوم بإنشاء قاعدة بيانات Azure Cosmos وحاوية واستيراد بيانات البيع بالتجزئة إلى الحاوية.

Python
C#‎

فتح Visual Studio Code.
قم بتشغيل الأمر Create: New Jupyter Notebook من لوحة الأوامر (Ctrl+Shift+P) أو قم بإنشاء ملف .ipynb جديد في مساحة العمل الخاصة بك.

تلميح

الآن بعد إنشاء دفتر الملاحظات الجديد، يمكنك حفظه وتسميه شيئا مثل AnalyzeRetailData.ipynb.

إنشاء قاعدة بيانات وحاوية باستخدام SDK

Python
C#‎

ابدأ في خلية التعليمات البرمجية الافتراضية.
تثبيت حزمة Azure.cosmos. قم بتشغيل هذه الخلية قبل المتابعة.
```
%pip install azure.cosmos
```

قم باستيراد أي حزم تحتاجها لهذا البرنامج التعليمي.

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

إنشاء مثيل جديد من CosmosClient.

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

إنشاء قاعدة بيانات باسم RetailIngest باستخدام SDK المضمنة.
```
database = cosmos_client.create_database_if_not_exists('RetailIngest')
```

قم بإنشاء حاوية باسم WebsiteMetrics باستخدام مفتاح قسم ل /CartID.

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

حدد Run لإنشاء قاعدة البيانات ومورد الحاوية.

ابدأ في خلية التعليمات البرمجية الافتراضية.
تثبيت حزمة Microsoft.Azure.Cosmos NuGet. قم بتشغيل هذه الخلية قبل المتابعة.
```
#r "nuget: Microsoft.Azure.Cosmos"
```
إنشاء خلية تعليمات برمجية جديدة.
قم باستيراد أي حزم تحتاجها لهذا البرنامج التعليمي.
```
using Microsoft.Azure.Cosmos;
```
إنشاء مثيل جديد من نوع العميل باستخدام SDK المضمنة. املأ نقطة نهاية URI ومفتاح حساب Azure Cosmos DB الخاص بك. يمكنك العثور على هذه القيم في صفحة Keys في حساب Azure Cosmos DB الخاص بك.
```
var endpoint = "<FILL ME>";
var key = "<FILL ME>";

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

إنشاء قاعدة بيانات باسم RetailIngest.

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

قم بإنشاء حاوية باسم WebsiteMetrics باستخدام مفتاح قسم ل /CartID.

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

حدد Execute Cell لإنشاء قاعدة البيانات ومورد الحاوية.

استيراد البيانات إلى الحاوية

Python
C#‎

إضافة خلية تعليمات برمجية جديدة

ضمن خلية التعليمات البرمجية، أضف التعليمات البرمجية التالية لتحميل البيانات من عنوان url هذا: 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)

قم بتشغيل الخلية. سيستغرق هذا 45 ثانية إلى دقيقة واحدة للتشغيل.

إضافة خلية تعليمات برمجية جديدة.

في خلية التعليمات البرمجية، قم بإنشاء فئة C# جديدة لتمثيل عنصر في الحاوية. قم بتشغيل الخلية.

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

إضافة خلية تعليمات برمجية جديدة.

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
}

قم بتشغيل الخلية. سيستغرق هذا 45 ثانية إلى دقيقة واحدة للتشغيل.

تحليل بياناتك

Python
C#‎

إنشاء خلية تعليمات برمجية جديدة أخرى.

في خلية التعليمات البرمجية، استخدم استعلام SQL لتعبئة Pandas DataFrame. قم بتشغيل هذه الخلية.

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)

إنشاء خلية تعليمات برمجية جديدة أخرى.
في خلية التعليمات البرمجية، قم إخراج أهم 10 عناصر من إطار البيانات. قم بتشغيل هذه الخلية.
```
df_cosmos.head(10)
```

لاحظ إخراج تشغيل الأمر.

	الإجراء	إعادة ترتيب العناصر	الدولة	العنصر
0	المشترى	19.99	مقدونيا الشمالية	قميص ذو زر لأعلى
1	معروض	12.00	بابوا غينيا الجديدة	قلادة
2	معروض	25.00	سلوفاكيا (جمهورية سلوفاكيا)	سترة كارديغان
3	المشترى	14.00	السنغال	Flip Flop Shoes
4	معروض	50.00	بنما	السراويل الدنيم
5	معروض	14.00	السنغال	Flip Flop Shoes
6	Added	14.00	السنغال	Flip Flop Shoes
7	Added	50.00	بنما	السراويل الدنيم
8	المشترى	33.00	الفلسطينيه	أعلى أحمر
9	معروض	30.00	مالطا	سترة خضراء

إنشاء خلية تعليمات برمجية جديدة أخرى.
في خلية التعليمات البرمجية، قم باستيراد حزمة pandas لتخصيص إخراج إطار البيانات. قم بتشغيل هذه الخلية.
```
import pandas as pd    
df_cosmos.groupby("Item").size().reset_index()
```
لاحظ إخراج تشغيل الأمر.

العنصر اختبار

0 Flip Flop Shoes 66

1 قلادة 55

2 أحذية رياضية 111

... ... ...

45 سترة مكسرة الرياح 56

	العنصر	اختبار
0	Flip Flop Shoes	66
1	قلادة	55
2	أحذية رياضية	111
...	...	...
45	سترة مكسرة الرياح	56

إنشاء خلية تعليمات برمجية جديدة.

في خلية التعليمات البرمجية، أضف التعليمات البرمجية لتنفيذ استعلام SQL باستخدام SDK الذي يخزن إخراج الاستعلام في متغير من النوع List<T> المسمى النتائج.

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

إنشاء خلية تعليمات برمجية جديدة أخرى.
في خلية التعليمات البرمجية، أنشئ قاموسا بإضافة تباديل فريدة لحقل العنصر كمفتاح ومجموع حقل السعر كقيمة. وهذا يعطي إجمالي المبيعات لكل عنصر. قم بتشغيل هذه الخلية.
```
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
```
لاحظ الإخراج باستخدام مجموعات فريدة من حقلي Item و Price .
```
...
Black Tee: 603
Flannel Shirt: 1199.40
Socks: 210.00
Rainjacket: 2695
...
```

مشاركة عبر