يتيح هذا معالجة الملفات من Azure Blob Storage بالتوازي باستخدام العديد من العقد في عنقود محدد. على العقدة البادئة، يُنشئ اتصالًا بجميع العقد في العنقود، ويفك علامات النجمة في مسار ملف S3، ويوزّع كل ملف ديناميكيًا. وعلى العقدة العاملة، يطلب من العقدة البادئة المهمة التالية لمعالجتها ثم يعالجها. ويتكرر ذلك حتى تكتمل جميع المهام.
تشبه دالة الجدول هذه الدالة s3Cluster.
azureBlobStorageCluster(cluster_name, connection_string|storage_account_url, container_name, blobpath, [account_name, account_key, format, compression, structure])
| Argument | الوصف |
|---|
cluster_name | اسم العنقود المستخدم لبناء مجموعة من العناوين ومعلمات الاتصال بالخوادم البعيدة والمحلية. |
connection_string | storage_account_url — تتضمن connection_string اسم الحساب والمفتاح (إنشاء connection string)، أو يمكنك أيضًا توفير URL لحساب التخزين هنا، وتمرير اسم الحساب ومفتاحه كمعلمات منفصلة (راجع المعلمتين account_name وaccount_key) |
container_name | اسم الحاوية |
blobpath | مسار الملف. يدعم أحرف البدل التالية في وضع readonly: *, **, ?, {abc,def} و {N..M}، حيث إن N وM — أرقام، و'abc' و'def' — سلاسل نصية. |
account_name | إذا استُخدم storage_account_url، فيمكن تحديد اسم الحساب هنا |
account_key | إذا استُخدم storage_account_url، فيمكن تحديد مفتاح الحساب هنا |
format | تنسيق الملف: تنسيق |
compression | القيم المدعومة: none, gzip/gz, brotli/br, xz/LZMA, zstd/zst. افتراضيًا، سيُكتشف الضغط تلقائيًا من امتداد الملف. (وهو ما يعادل ضبطه على auto). |
structure | بنية الجدول. التنسيق 'column1_name column1_type, column2_name column2_type, ...'. |
azurite1.
استعلِم عن العدد للملف test_cluster_*.csv باستخدام جميع العقد في عنقود cluster_simple:
SELECT count(*) FROM azureBlobStorageCluster(
'cluster_simple', 'http://azurite1:10000/devstoreaccount1', 'testcontainer', 'test_cluster_count.csv', 'devstoreaccount1',
'Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==', 'CSV',
'auto', 'key UInt64')
استخدام توقيعات الوصول المشتركة (SAS)
آخر تعديل في ٢٩ يونيو ٢٠٢٦
