MaxCompute:Kullanım kılavuzu

• Upload: Yerel bir dosyadaki verileri bir MaxCompute tablosuna yükler. Her yükleme işlemi tek bir tabloya veya tek bir bölüme veri yazabilir. Bölümlenmiş tablolar için hedef bölümü belirtmeniz gerekir. Çok düzeyli bölümlenmiş tablolar için en alt düzey bölümü belirtmelisiniz. Daha fazla bilgi için bkz. Upload.

• Download: Bir MaxCompute tablosundaki veya belirli bir örneğin sonuçlarındaki verileri yerel bir dosyaya indirir. Her indirme işlemi, bir tabloyu veya bir bölümü tek bir dosyaya indirebilir. Bölümlenmiş tablolar için kaynak bölümü belirtmeniz gerekir. Çok düzeyli bölümlenmiş tablolar için en alt düzey bölümü belirtmelisiniz. Daha fazla bilgi için bkz. Download.

• Resume: Ağ sorunları veya Tunnel hizmeti hataları nedeniyle bir yükleme başarısız olursa, dosya yüklemeye devam etmek için Resume komutunu kullanabilirsiniz. Bu komut önceki yükleme işlemini sürdürür. Resume komutu şu anda indirme işlemlerini desteklemez. Daha fazla bilgi için bkz. Resume.

• Show: Geçmiş görevlere ilişkin bilgileri görüntüler. Daha fazla bilgi için bkz. Show.

• Purge: Oturum dizinini temizler. Bu komut varsayılan olarak son üç güne ait günlükleri kaldırır. Daha fazla bilgi için bkz. Purge.

• Help: Yardım bilgilerini görüntüler. Her komut ve seçenek için kısa komut biçimleri desteklenir.

• Upsert: Update ve Insert anlamlarını birleştirerek veri yazar. Bu komut yalnızca Transaction Table 2.0 tabloları için desteklenir.

  Hedef tabloda eşleşen veri bulunmazsa yeni veri eklenir. Veri zaten varsa güncellenir.

Başlamadan önce data.txt adlı bir veri dosyası hazırlayın ve d:\data.txt konumuna kaydedin. Dosya aşağıdaki verileri içerir.

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

Aşağıdaki adımlarda tablo verilerinin nasıl yükleneceği ve indirileceği açıklanmaktadır.

1. MaxCompute istemcisinde aşağıdaki ifadeleri çalıştırarak bölümlenmiş sale_detail tablosunu oluşturun ve buna bir bölüm ekleyin.

   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. data.txt veri dosyasını bölümlenmiş sale_detail tablosuna yüklemek için upload komutunu kullanın.

   • Örnek komut

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

   • Dönüş değeri

     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

     Not

     data.txt dosyası hatalı veri içerdiğinden veri aktarımı başarısız olur. Bir oturum kimliği ve bir hata mesajı döndürülür.

3. Verileri doğrulamak için aşağıdaki ifadeyi çalıştırın.

   • Örnek komut

     select * from sale_detail where sale_date='201312';

   • Dönüş değerleri

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

     Not

     Veri aktarımı hatalı veri nedeniyle başarısız olmuş ve tablo boş kalmıştır.

4. Başarısız yüklemenin oturum kimliğini sorgulamak için show komutunu kullanın.

   • Örnek komut

     tunnel show history;

   • Döndürülen sonuç

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

5. data.txt örnek veri dosyasını, sale_detail tablo şemasıyla eşleşen aşağıdaki verileri içerecek şekilde değiştirin.

   shopx,x_id,100
   shopy,y_id,200

6. Veri yüklemesini sürdürmek için resume komutunu çalıştırın. Bu komutta 20230505xxxxxxxxxxxb0b02dbb6bd başarısız yüklemenin oturum kimliğidir.

   • Örnek komut

     tunnel resume 20230505xxxxxxxxxxxb0b02dbb6bd --force;

   • Dönüş değeri

     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. Verileri doğrulamak için aşağıdaki ifadeyi çalıştırın. Yükleme başarılıdır.

   • Örnek komut

     select * from sale_detail where sale_date='201312';

   • Dönüş değeri

     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. sale_detail tablosundaki verileri result.txt adlı yerel bir dosyaya indirmek için download komutunu çalıştırın.

   Not

   Verilerin indirildiği yerel yol path için adlandırma kuralları aşağıdaki gibidir:

   • Dosyayı doğrudan MaxCompute istemcisinin bin dizinine kaydetmek için path değerini filename.extension olarak ayarlayın.

   • Dosyayı D sürücüsündeki test klasörü gibi başka bir yola kaydetmek için path değerini D:\test\filename.extension olarak ayarlayın.

   • Aynı ada sahip yerel bir dosya varsa üzerine yazılır.

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

9. result.txt dosyasının içeriğini doğrulayın. Dosya aşağıdaki içeriği içerir; bu da indirmenin başarılı olduğunu gösterir.

   Not

   İndirilen dosyada yalnızca bölüm dışı alanların değerleri görüntülenir.

   shopx,x_id,100.0
   shopy,y_id,200.0