MaxCompute:Panduan penggunaan

• Upload: Mengunggah data dari file lokal ke tabel MaxCompute. Setiap operasi unggah hanya dapat menulis data ke satu tabel atau satu partition. Untuk tabel partisi, Anda harus menentukan partisi tujuan. Untuk tabel partisi multi-level, Anda harus menentukan partisi level terendah. Untuk informasi selengkapnya, lihat Upload.

• Download: Mengunduh data dari tabel MaxCompute atau hasil instans tertentu ke file lokal. Setiap operasi unduh hanya dapat mengunduh satu tabel atau satu partisi ke satu file. Untuk tabel partisi, Anda harus menentukan partisi sumber. Untuk tabel partisi multi-level, Anda harus menentukan partisi level terendah. Untuk informasi selengkapnya, lihat Download.

• Resume: Jika unggahan gagal karena masalah jaringan atau error layanan Tunnel, Anda dapat menggunakan perintah Resume untuk melanjutkan unggahan file tersebut. Perintah ini melanjutkan operasi unggah sebelumnya. Saat ini, perintah Resume tidak mendukung operasi unduh. Untuk informasi selengkapnya, lihat Resume.

• Show: Menampilkan informasi tentang tugas historis. Untuk informasi selengkapnya, lihat Show.

• Purge: Membersihkan direktori sesi. Secara default, perintah ini menghapus log dari tiga hari terakhir. Untuk informasi selengkapnya, lihat Purge.

• Help: Menampilkan informasi bantuan. Format perintah singkat didukung untuk setiap perintah dan opsi.

• Upsert: Menulis data menggunakan kombinasi semantik Update dan Insert. Perintah ini hanya didukung untuk tabel Transaction Table 2.0.

  Jika data yang sesuai tidak ditemukan di tabel tujuan, data baru akan dimasukkan. Jika data sudah ada, data tersebut akan diperbarui.

Sebelum memulai, siapkan file data bernama data.txt dan simpan di d:\data.txt. File tersebut berisi data berikut.

shopx,x_id,100
shopy,y_id,200
shopz,z_id

Langkah-langkah berikut menjelaskan cara mengunggah dan mengunduh data tabel.

1. Di client MaxCompute, jalankan pernyataan berikut untuk membuat tabel partisi sale_detail dan menambahkan partisi ke dalamnya.

   CREATE TABLE IF NOT EXISTS sale_detail(
         shop_name     STRING,
         customer_id   STRING,
         total_price   DOUBLE)
   PARTITIONED BY (sale_date STRING,region STRING);
   
   alter table sale_detail add partition (sale_date='201312', region='hangzhou');

2. Gunakan perintah upload untuk mengunggah file data data.txt ke tabel partisi sale_detail.

   • Contoh perintah

     tunnel upload d:\data.txt sale_detail/sale_date=201312,region=hangzhou -s false;

   • Nilai kembalian

     Upload session: 20230505xxxxxxxxxxxb0b02dbb6bd
     Start upload:d:\data.txt
     Using \r\n to split records
     Upload in strict schema mode: true
     Total bytes:42   Split input to 1 blocks
     2023-05-05 10:11:35     upload block: '1'
     ERROR: column mismatch -,expected 3 columns, 2 columns found, please check data or delimiter

     Catatan

     Karena data.txt berisi data kotor, impor data gagal. ID sesi dan pesan error dikembalikan.

3. Jalankan pernyataan berikut untuk memverifikasi data.

   • Contoh perintah

     select * from sale_detail where sale_date='201312';

   • Nilai kembalian

     ID = 20230505xxxxxxxxxxxvc61z5
     +-----------+-------------+-------------+-----------+--------+
     | shop_name | customer_id | total_price | sale_date | region |
     +-----------+-------------+-------------+-----------+--------+
     +-----------+-------------+-------------+-----------+--------+

     Catatan

     Impor data gagal karena data kotor, sehingga tabel tetap kosong.

4. Gunakan perintah show untuk menanyakan ID sesi dari unggahan yang gagal.

   • Contoh perintah

     tunnel show history;

   • Hasil yang dikembalikan

     20230505xxxxxxxxxxxb0b02dbb6bd  failed  'upload d:\data.txt sale_detail/sale_date=201312,region=Hangzhou -s false'

5. Ubah file data sampel data.txt agar berisi data berikut, yang sesuai dengan skema tabel sale_detail.

   shopx,x_id,100
   shopy,y_id,200

6. Jalankan perintah resume untuk melanjutkan unggahan data. Dalam perintah ini, 20230505xxxxxxxxxxxb0b02dbb6bd adalah ID sesi dari unggahan yang gagal.

   • Contoh perintah

     tunnel resume 20230505xxxxxxxxxxxb0b02dbb6bd --force;

   • Nilai kembalian

     start resume
     20230505xxxxxxxxxxxb0b02dbb6bd
     Upload session: 20230505xxxxxxxxxxxb0b02dbb6bd
     Start upload:d:\data.txt
     Using \r\n to split records
     Upload in strict schema mode: true
     Resume 1 blocks 
     2023-05-05 10:32:39     upload block: '1'
     2023-05-05 10:32:40     upload block complete, block id: 1
     upload complete, average speed is 0 bytes/s
     OK

7. Jalankan pernyataan berikut untuk memverifikasi data. Unggahan berhasil.

   • Contoh perintah

     select * from sale_detail where sale_date='201312';

   • Nilai kembalian

     ID = 20230505xxxxxxxxxxxx7afc9qcg
      +-----------+-------------+-------------+-----------+--------+
      | shop_name | customer_id | total_price | sale_date | region |
      +-----------+-------------+-------------+-----------+--------+
      | shopx     | x_id        | 100.0       | 201312    | hangzhou|
      | shopy     | y_id        | 200.0       | 201312    | hangzhou|
      +-----------+-------------+-------------+-----------+--------+

8. Jalankan perintah download untuk mengunduh data dari tabel sale_detail ke file lokal bernama result.txt.

   Catatan

   Konvensi penamaan untuk path lokal path tempat data diunduh adalah sebagai berikut:

   • Untuk menyimpan file langsung ke direktori bin client MaxCompute, atur path menjadi filename.extension.

   • Untuk menyimpan file ke path lain, seperti folder test di drive D, atur path menjadi D:\test\filename.extension.

   • Jika file lokal dengan nama yang sama sudah ada, file tersebut akan ditimpa.

   tunnel download sale_detail/sale_date=201312,region=hangzhou result.txt;

9. Verifikasi isi file result.txt. File tersebut berisi konten berikut, yang menunjukkan bahwa unduhan berhasil.

   Catatan

   File yang diunduh hanya menampilkan nilai bidang non-partisi.

   shopx,x_id,100.0
   shopy,y_id,200.0