مشاركة عبر

التشغيل السريع: استخدام Azure Cosmos DB للجدول مع Azure SDK ل Java

  • ينطبق على: ✅ Table

في هذا التشغيل السريع، يمكنك نشر Azure Cosmos DB الأساسي لتطبيق Table باستخدام Azure SDK ل Java. Azure Cosmos DB للجدول هو مخزن بيانات بلا مخطط يسمح للتطبيقات بتخزين بيانات الجدول المنظمة في السحابة. ستتعلم كيفية إنشاء جداول وصفوف وتنفيذ المهام الأساسية داخل مورد Azure Cosmos DB باستخدام Azure SDK ل Java.

الوثائق | المرجعية لواجهة برمجة التطبيقات حزمة التعليمات البرمجية | المصدر لمكتبة (Maven) | Azure Developer CLI

المتطلبات الأساسية

  • Azure Developer CLI
  • سطح مكتب Docker
  • جافا 21

إذا لم يكن لديك حساب Azure، فأنشئ حساباً مجانياً قبل أن تبدأ.

تهيئة المشروع

استخدم Azure Developer CLI (azd) لإنشاء حساب Azure Cosmos DB للجدول ونشر نموذج تطبيق حاوية. يستخدم نموذج التطبيق مكتبة العميل لإدارة البيانات النموذجية وإنشاءها وقراءتها والاستعلام عن البيانات.

  1. افتح محطة طرفية في دليل فارغ.

  2. إذا لم تكن قد تمت مصادقتك بالفعل، فقم بالمصادقة على Azure Developer CLI باستخدام azd auth login. اتبع الخطوات المحددة بواسطة الأداة للمصادقة على CLI باستخدام بيانات اعتماد Azure المفضلة لديك.

    azd auth login

  3. استخدم azd init لتهيئة المشروع.

    azd init --template cosmos-db-table-java-quickstart

  4. أثناء التهيئة، قم بتكوين اسم بيئة فريد.

  5. انشر حساب Azure Cosmos DB باستخدام azd up. تنشر قوالب Bicep أيضا نموذج تطبيق ويب.

    azd up

  6. أثناء عملية التوفير، حدد اشتراكك والموقع المطلوب ومجموعة الموارد المستهدفة. انتظر حتى اكتمال عملية التوفير. قد تستغرق العملية حوالي خمس دقائق.

  7. بمجرد توفير موارد Azure الخاصة بك، يتم تضمين عنوان URL لتطبيق الويب قيد التشغيل في الإخراج.

    Deploying services (azd deploy)

  (✓) Done: Deploying service web
- Endpoint: <https://[container-app-sub-domain].azurecontainerapps.io>

SUCCESS: Your application was provisioned and deployed to Azure in 5 minutes 0 seconds.

  8. استخدم عنوان URL في وحدة التحكم للانتقال إلى تطبيق الويب الخاص بك في المستعرض. لاحظ إخراج التطبيق قيد التشغيل.

لقطة شاشة لتطبيق الويب قيد التشغيل.

تثبيت مكتبة العميل

تتوفر مكتبة العميل من خلال Maven، كحزمة azure-data-tables .

  1. انتقل إلى /src/web المجلد وافتح ملف pom.xml .

    cd ./src

  2. إذا لم يكن موجودا بالفعل، أضف إدخالا للحزمة azure-data-tables .

    <dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-data-tables</artifactId>
</dependency>

استيراد مكتبات

استيراد كافة مساحات الأسماء المطلوبة إلى التعليمات البرمجية للتطبيق الخاص بك.

import com.azure.core.http.rest.PagedFlux;
import com.azure.data.tables.TableAsyncClient;
import com.azure.data.tables.TableClientBuilder;
import com.azure.data.tables.models.ListEntitiesOptions;
import com.azure.data.tables.models.TableEntity;
import com.azure.identity.DefaultAzureCredential;
import com.azure.identity.DefaultAzureCredentialBuilder;

نموذج الكائن

Name ‏‏الوصف
TableServiceAsyncClient هذا النوع هو نوع العميل الأساسي ويستخدم لإدارة بيانات التعريف أو قواعد البيانات على مستوى الحساب.
TableAsyncClient يمثل هذا النوع العميل لجدول داخل الحساب.

أمثلة على التعليمات البرمجية

يستخدم نموذج التعليمات البرمجية في القالب جدولا يسمى cosmicworks-products. cosmicworks-products يحتوي الجدول على تفاصيل مثل الاسم والفئة والكمية والسعر والمعرف الفريد وعلامة البيع لكل منتج. تستخدم الحاوية معرفا فريدا* كمفتاح الصف والفئة كمفتاح قسم.

مصادقة العميل

ينشئ هذا النموذج مثيلا جديدا للفئة TableServiceAsyncClient .

DefaultAzureCredential azureTokenCredential = new DefaultAzureCredentialBuilder()
    .build();

TableServiceAsyncClient client = new TableServiceClientBuilder()
    .endpoint("<azure-cosmos-db-table-account-endpoint>")
    .credential(credential)
    .buildAsyncClient();

الحصول على جدول

ينشئ هذا النموذج مثيلا للفئة TableAsyncClient باستخدام GetTableClient أسلوب TableServiceClient الفئة .

TableAsyncClient table = client
    .getTableClient("<azure-cosmos-db-table-name>");

إنشاء كيان

أسهل طريقة لإنشاء كيان جديد في جدول هي استخدام createEntity.

String rowKey = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb";
String partitionKey = "gear-surf-surfboards";

TableEntity entity = new TableEntity(partitionKey, rowKey)
        .addProperty("Name", "Yamba Surfboard")
        .addProperty("Quantity", 12)
        .addProperty("Price", 850.00)
        .addProperty("Sale", false);

إنشاء كيان في المجموعة باستخدام upsertEntity.

Mono<Void> response = table.upsertEntity(entity);

الحصول على كيان

يمكنك استرداد كيان معين من جدول باستخدام getEntity.

String rowKey = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb";
String partitionKey = "gear-surf-surfboards";

TableEntity entity = table.getEntity(partitionKey, rowKey);

الاستعلام عن الكيانات

بعد إدراج كيان، يمكنك أيضا تشغيل استعلام للحصول على كافة الكيانات التي تطابق عامل تصفية معين باستخدام listEntities والفئة ListEntitiesOptions . setFilter استخدم الأسلوب لتحديد عامل تصفية OData سلسلة.

ListEntitiesOptions options = new ListEntitiesOptions()
    .setFilter("PartitionKey eq 'gear-surf-surfboards'");

PagedFlux<TableEntity> tableEntities = table.listEntities(options, null, null);

تحليل نتائج الاستعلام المرقمة باستخدام اشتراك.

tableEntities
    .DoOnNext(entity -> {
        // Do something
    });

تنظيف الموارد

عندما لم تعد بحاجة إلى نموذج التطبيق أو الموارد، قم بإزالة التوزيع المقابل وجميع الموارد.

azd down

المحتوى ذو الصلة

  • Last updated on