محرك جدول DeltaLake

يوفّر هذا المحرك تكاملًا مع جداول Delta Lake الموجودة في Amazon S3 وGCS وAzure Blob Storage، ويدعم عمليتَي القراءة والكتابة كلتيهما.

يوفّر هذا المحرك تكاملًا مع جداول Delta Lake الموجودة في S3 وGCP وAzure Storage، ويدعم عمليتَي القراءة والكتابة كلتيهما (الكتابة في S3 وGCS بدءًا من v25.10، وفي Azure بدءًا من v26.9).

​

إنشاء جدول DeltaLake

افتراضيًا، يجب أن يكون جدول Delta Lake موجودًا مسبقًا في S3 أو GCP أو Azure Storage، وتُرفق به الأوامر أدناه دون تعريفات أعمدة DDL. عند ضبط allow_delta_lake_create_table = 1، يؤدي استخدام CREATE TABLE بأعمدة صريحة مع موقع لا يحتوي على _delta_log إلى إنشاء جدول Delta Lake جديد بدلًا من ذلك، عبر كتابة الالتزام الأولي باستخدام delta-kernel-rs (لا يُدعم إنشاء الجداول المقسّمة إلى أقسام بعد). كما يُسجَّل الجدول في الكتالوج عند وجوده داخل قاعدة بيانات Unity DataLakeCatalog.

S3

البنية

CREATE TABLE table_name
ENGINE = DeltaLake(url, [aws_access_key_id, aws_secret_access_key,] [extra_credentials])

معلمات المحرك

• url — عنوان URL للـ bucket مع المسار إلى جدول Delta Lake الحالي.
• aws_access_key_id, aws_secret_access_key - بيانات اعتماد طويلة الأجل لمستخدم حساب AWS. يمكنك استخدامها لمصادقة طلباتك. هذه المعلمة اختيارية. وإذا لم يتم تحديد بيانات الاعتماد، فسيتم استخدامها من ملف الإعدادات.
• extra_credentials - اختياري. يُستخدم لتمرير role_arn للوصول المستند إلى الأدوار في ClickHouse Cloud. راجع تأمين S3 لمعرفة خطوات الإعداد.

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

مثال

CREATE TABLE deltalake
ENGINE = DeltaLake('http://mars-doc-test.s3.amazonaws.com/clickhouse-bucket-3/test_table/', 'ABC123', 'Abc+123')

باستخدام المجموعات المسماة:

<clickhouse>
    <named_collections>
        <deltalake_conf>
            <url>http://mars-doc-test.s3.amazonaws.com/clickhouse-bucket-3/</url>
            <access_key_id>ABC123</access_key_id>
            <secret_access_key>Abc+123</secret_access_key>
        </deltalake_conf>
    </named_collections>
</clickhouse>

CREATE TABLE deltalake
ENGINE = DeltaLake(deltalake_conf, filename = 'test_table')

GCP

البنية

-- استخدام عنوان URL عبر HTTPS (موصى به)
CREATE TABLE table_name
ENGINE = DeltaLake('https://storage.googleapis.com/<bucket>/<path>/', '<access_key_id>', '<secret_access_key>')

مُعرّف URI الخاص بـ gsutil مثل gs://clickhouse-docs-example-bucket غير مدعوم. يُرجى استخدام عنوان URL يبدأ بـ https://storage.googleapis.com

الوسائط

• url — عنوان URL لـ GCS bucket المؤدي إلى جدول Delta Lake. يجب استخدام التنسيق https://storage.googleapis.com/<bucket>/<path>/ (وهو API endpoint الخاص بـ GCS XML)، أو gs://<bucket>/<path>/ الذي يُحوَّل تلقائيًا.
• access_key_id — مفتاح الوصول إلى GCS. أنشِئه عبر Google Cloud Console → Cloud Storage → Settings → Interoperability.
• secret_access_key — المفتاح السري لـ GCS.

المجموعات المسماة

يمكنك أيضًا استخدام المجموعات المسماة. على سبيل المثال:

CREATE NAMED COLLECTION gcs_creds AS
access_key_id = '<access_key>',
secret_access_key = '<secret>';

CREATE TABLE gcpDeltaLake
ENGINE = DeltaLake(gcs_creds, url = 'https://storage.googleapis.com/<bucket>/<path>')

Azure

البنية

CREATE TABLE table_name
ENGINE = DeltaLake(connection_string|storage_account_url, container_name, blobpath, [account_name, account_key, format, compression])

الوسائط

• connection_string — سلسلة اتصال Azure
• storage_account_url — عنوان URL لحساب Azure Storage (على سبيل المثال، https://account.blob.core.windows.net)
• container_name — اسم Azure container
• blobpath — المسار إلى جدول Delta Lake داخل الـ container
• account_name — اسم حساب Azure Storage
• account_key — مفتاح حساب Azure Storage

​

كتابة البيانات باستخدام جدول DeltaLake

بعد إنشاء جدول باستخدام محرك جدول DeltaLake، يمكنك إدراج البيانات فيه باستخدام:

SET allow_delta_lake_writes = 1;

INSERT INTO deltalake(id, firstname, lastname, gender, age)
VALUES (1, 'John', 'Smith', 'M', 32);

تُعد عمليات الكتابة إلى Delta Lake ميزة Beta وتكون معطلة افتراضيًا ويجب تمكينها باستخدام SET allow_delta_lake_writes = 1; (متاح بدءًا من الإصدار 26.7؛ وفي الإصدارات الأقدم استخدم SET allow_experimental_delta_lake_writes = 1;).

لا تُدعَم الكتابة باستخدام محرك الجدول إلا عبر نواة Delta. تعمل عمليات الكتابة مع S3 وGCS، ومع Azure بدءًا من الإصدار 26.9. لا تدعم نواة Delta مصادقة Workload Identity في Azure (extra_credentials(client_id = ..., tenant_id = ...)).

​

ذاكرة التخزين المؤقت للبيانات

يدعم محرك جدول DeltaLake ودالة الجدول التخزين المؤقت للبيانات، تمامًا كما هو الحال مع أنظمة التخزين S3 وAzureBlobStorage وHDFS. راجع “محرك جدول S3” لمزيد من التفاصيل.

​

راجع أيضًا

• دالة الجدول deltaLake