Masukkan data ke dalam gudang data Anda menggunakan pernyataan COPY

Berlaku untuk:✅ Gudang di Microsoft Fabric

Pernyataan COPY adalah cara utama untuk memasukkan data ke dalam tabel Data Warehousing. COPY melakukan penyerapan data throughput tinggi dari akun penyimpanan Azure eksternal. Anda dapat mengonfigurasi opsi format file sumber, menentukan lokasi untuk menyimpan baris yang ditolak, melewati baris header, dan mengatur opsi lainnya.

Tutorial ini menunjukkan contoh penyerapan data untuk tabel Gudang dengan menggunakan pernyataan T-SQL COPY .

Catatan

Gudang juga memungkinkan Anda menggunakan pernyataan BULK INSERT untuk penyerapan data. Pernyataan COPY INTO adalah yang direkomendasikan untuk kode penyerapan baru, sementara pernyataan BULK INSERT memungkinkan Anda menggunakan kembali kode yang Anda gunakan di SQL Server atau Azure SQL Database.

Untuk mempelajari selengkapnya tentang pernyataan T-SQL COPY termasuk contoh lainnya dan sintaks lengkapnya, lihat COPY (Transact-SQL).

Buat tabel

Sebelum Anda menggunakan pernyataan COPY, tabel tujuan perlu dibuat. Untuk membuat tabel tujuan untuk sampel ini, gunakan langkah-langkah berikut:

  1. Di ruang kerja Microsoft Fabric Anda, temukan dan buka gudang Anda.

  2. Beralih ke tab Beranda dan pilih Kueri SQL baru.

    Cuplikan layar bagian atas ruang kerja pengguna memperlihatkan tombol Kueri SQL Baru.

  3. Untuk membuat tabel yang digunakan sebagai tujuan dalam tutorial ini, jalankan kode berikut:

        CREATE TABLE dbo.TaxiTrips
        (
            doLocationId            varchar(MAX)      NULL,
            endLat                  float             NULL,
            endLon                  float             NULL,
            extra                   float             NULL,
            fareAmount              float             NULL,
            improvementSurcharge    varchar(MAX)      NULL,
            mtaTax                  float             NULL,
            passengerCount          int               NULL,
            paymentType             varchar(MAX)      NULL,
            puLocationId            varchar(MAX)      NULL,
            puMonth                 int               NULL,
            puYear                  int               NULL,
            rateCodeId              int               NULL,
            startLat                float             NULL,
            startLon                float             NULL,
            storeAndFwdFlag         varchar(1)        NULL,
            tipAmount               float             NULL,
            tollsAmount             float             NULL,
            totalAmount             float             NULL,
            tpepDropoffDateTime     datetime2(6)      NULL,
            tpepPickupDateTime      datetime2(6)      NULL,
            tripDistance            float             NULL,
            vendorId_str            varchar(MAX)      NULL,
            vendorId_lpep           int               NULL
        );
    

Memuat data Parquet menggunakan pernyataan COPY

Dalam contoh ini, kami memuat data menggunakan sumber Parquet. Karena data ini tersedia untuk umum dan tidak memerlukan autentikasi, Anda dapat dengan mudah menyalin data ini dengan menentukan sumber dan tujuan. Tidak diperlukan detail autentikasi. Anda hanya perlu menentukan FILE_TYPE argumen.

Gunakan kode berikut untuk menjalankan pernyataan COPY dengan sumber Parquet:

COPY INTO dbo.TaxiTrips
FROM 'https://azureopendatastorage.blob.core.windows.net/nyctlc/yellow'
WITH (
    FILE_TYPE = 'PARQUET'
)

Periksa hasilnya

Pernyataan COPY selesai dengan menyerap 1.571.671.152 baris ke dalam tabel baru Anda. Anda dapat mengonfirmasi operasi berhasil dijalankan dengan menjalankan kueri yang mengembalikan jumlah total baris dalam tabel Anda:

SELECT COUNT_BIG(*) FROM dbo.TaxiTrips;

Opsi penyerapan data

Cara lain untuk menyerap data ke gudang Anda meliputi: