Perintah .ingest-from-storage-queued

Beralih layanan menggunakan daftar drop-down Versi . Pelajari selengkapnya tentang navigasi.
Berlaku untuk: ✅ Microsoft Fabric ✅ Azure Data Explorer

Perintah .ingest-from-storage-queued digunakan untuk mengantre blob untuk penyerapan ke dalam tabel. Ini mendukung penyerapan blob individual berdasarkan URL, beberapa blob dari file sumber, folder tertentu, atau seluruh kontainer penyimpanan. Perintah ini berguna untuk menguji dan mengelola skenario penyerapan, membantu memastikan bahwa skema, partisi, dan konfigurasi lainnya diterapkan dengan benar.

Nota

Metode penyerapan ini ditujukan untuk eksplorasi dan prototipe. Jangan gunakan dalam skenario produksi atau volume tinggi.

Nota

Perintah penyerapan antrean dijalankan pada titik akhir URI penyerapan data https://ingest-<YourClusterName><Region>.kusto.windows.net.

Hak akses

Anda harus memiliki setidaknya izin Table Ingestor untuk menjalankan perintah ini.

Sintaksis

.ingest-from-storage-queued into table [database(DatabaseName).]TableName[EnableTracking=EnableTracking] [SkipBatching=SkipBatching] [CompressionFactor=CompressionFactor] [with (IngestionPropertyName = IngestionPropertyValue [, ...])] <|Sumber Penyerapan

Pelajari selengkapnya tentang konvensi sintaksis.

Parameter-parameternya

Nama	Tipe	Diperlukan	Deskripsi
Nama Database	string	✔️	Nama database untuk menyerap data. Jika tidak ada nama database yang disediakan, database konteks permintaan akan digunakan.
Nama Tabel	string	✔️	Nama tabel untuk menyerap data.
Mengaktifkan Pelacakan	boolean		Menentukan apakah akan melacak penyerapan blob. Untuk informasi selengkapnya, lihat perintah .show queued ingestion operations. Defaultnya adalah false.
Lewati Batching	boolean		Jika diatur ke true, blob diserap secara individual daripada di-batch bersama dengan blob lain. Nilai defaultnya adalah false.
Faktor Kompresi	real		Faktor kompresi (rasio) antara ukuran asli dan ukuran blob yang dikompresi. Faktor kompresi digunakan untuk memperkirakan ukuran asli data untuk tujuan batching, ketika blob disediakan dalam format terkompresi.
IngestionPropertyName, IngestionPropertyValue	string		Properti penyerapan opsional. Untuk informasi selengkapnya tentang properti penyerapan, lihat Properti penyerapan data.
Sumber Penyerapan	string	✔️	Sumber penyerapan. Sumbernya bisa berupa URL blob (pratinjau) atau daftar blob yang dikembalikan menggunakan perintah .list blobs .

Nota

Perintah .list blobs dapat digunakan dengan .ingest-from-storage-queued perintah untuk mengembalikan blob yang ingin Anda serap. Untuk informasi terperinci tentang perintah dan daftar lengkap parameternya, lihat perintah .list blobs.

Pengembalian Barang

Hasil perintah adalah tabel dengan satu baris dan satu kolom.

Nama	Tipe	Deskripsi
IDOperasiPemasukan	string	ID unik yang digunakan untuk melacak kumpulan blob, apakah pelacakan diaktifkan atau tidak.
ClientRequestId	string	ID permintaan klien dari perintah .
OperationInfo	string	Menampilkan perintah yang akan dijalankan untuk mengambil status operasi saat ini.

Nota

Perintah ini tidak mengubah skema tabel target. Jika perlu, data dikonversi agar sesuai dengan skema tabel selama penyerapan. Kolom tambahan diabaikan dan kolom yang hilang diperlakukan sebagai nilai null.

Examples

Contoh di bagian ini memperlihatkan cara menggunakan sintaks untuk membantu Anda memulai.

Menyerap blob dari file (Pratinjau)

Contoh berikut mengantrekan blob dari file sumber.

.ingest-from-storage-queued into table database ('MyDatabase').mytable
EnableTracking=true
with (
  format='csv',
  ingestionMappingReference='MyMapping'
)
<| 'https://https://sample.blob.core.windows.net/sample/test_1.csv?...'
   'https://https://sample.blob.core.windows.net/sample/test_2.csv?...'
   'https://https://sample.blob.core.windows.net/sample/test_3.csv?...'

Nota

Pastikan untuk menyertakan token SAS atau menggunakan identitas terkelola untuk memberikan izin layanan untuk mengakses dan mengunduh blob. Lihat string koneksi penyimpanan untuk detailnya.

Menyerap semua blob dalam folder

Contoh berikut mengantrekan semua blob dalam folder untuk penyerapan menggunakan identitas terkelola sistem kluster.

.ingest-from-storage-queued into table database('LogDb').RawLogs
EnableTracking=true
with (
  format='csv',
  ingestionMappingReference='LogMapping',
  ignoreFirstRecord=false  
)
<|
  .list blobs (
      "https://mystorageaccount.blob.core.windows.net/datasets/myfolder;managed_identity=system"
  )

Konten terkait

• Ringkasan penyerapan antrean
• format data didukung untuk penyerapan
• Perintah .list blobs
• .ingest ke dalam
• .cancel perintah operasi penyerapan antrean