MaxCompute：使用UNLOAD命令

樣本資料

表sale_detail的資料如下：

+------------+-------------+-------------+------------+------------+
| shop_name  | customer_id | total_price | sale_date  | region     |
+------------+-------------+-------------+------------+------------+
| s1         | c1          | 100.1       | 2013       | china      |
| s2         | c2          | 100.2       | 2013       | china      |
| s3         | c3          | 100.3       | 2013       | china      |
| null       | c5          | NULL        | 2014       | shanghai   |
| s6         | c6          | 100.4       | 2014       | shanghai   |
| s7         | c7          | 100.5       | 2014       | shanghai   |
+------------+-------------+-------------+------------+------------+

登入OSS管理主控台，建立OSS Bucket目錄oss-unload-test/data_location/，樣本地區為oss-cn-hangzhou。建立完成後如下圖所示：

OSS路徑如下：oss://oss-cn-hangzhou-internal.aliyuncs.com/oss-unload-test/data_location。

登入MaxCompute用戶端，執行UNLOAD命令，將sale_detail表的資料匯出至OSS。

1. 樣本1：將sale_detail表中的資料匯出為CSV格式並壓縮為GZIP。命令如下：

   -- 控制匯出檔案個數：設定單個Worker讀取MaxCompute表資料的大小，單位為MB。
   -- 由於MaxCompute表有壓縮，匯出到OSS的資料一般會膨脹4倍左右。
   SET odps.stage.mapper.split.size=256;
   
   -- 匯出資料
   UNLOAD FROM  
   (SELECT * FROM sale_detail)
   INTO
   LOCATION 'oss://oss-cn-hangzhou-internal.aliyuncs.com/oss-unload-test/data_location'
   STORED BY 'com.aliyun.odps.CsvStorageHandler'
   WITH SERDEPROPERTIES (
     'odps.properties.rolearn'='acs:ram::<uid>:role/AliyunODPSDefaultRole', 
     'odps.text.option.gzip.output.enabled'='true');                     

   其中，UNLOAD FROM (SELECT * FROM sale_detail)等效於UNLOAD FROM sale_detail。

2. 樣本2：將sale_detail表中分區為sale_date='2013'，region='china'的資料匯出為TSV格式並壓縮為GZIP。命令如下：

   -- 控制匯出檔案個數：設定單個Worker讀取MaxCompute表資料的大小，單位為MB。
   -- 由於MaxCompute表有壓縮，匯出到OSS的資料一般會膨脹4倍左右。
   SET odps.stage.mapper.split.size=256;
   
   -- 匯出資料。
   UNLOAD FROM sale_detail PARTITION (sale_date='2013',region='china')
   INTO
   LOCATION 'oss://oss-cn-hangzhou-internal.aliyuncs.com/oss-unload-test/data_location'
   STORED BY 'com.aliyun.odps.TsvStorageHandler'
   WITH SERDEPROPERTIES (
     'odps.properties.rolearn'='acs:ram::<uid>:role/AliyunODPSDefaultRole', 
     'odps.text.option.gzip.output.enabled'='true');

兩個樣本中出現的參數'odps.text.option.gzip.output.enabled'='true'用於指定匯出檔案為GZIP壓縮格式，當前僅支援GZIP壓縮格式。更多參數資訊，請參見OSS外部表格。

樣本資料

表data_test的資料如下：

+------------+----------+
| id         | name     |
+------------+----------+
| 3          | rgege    |
| 4          | Gegegegr |
+------------+----------+

在Hologres建立資料接收表mc_2_holo（所在資料庫名稱為test）。

可以在HoloWeb的SQL編輯器中執行建表語句，詳情請參見串連HoloWeb並執行查詢。建表語句如下：

CREATE TABLE mc_2_holo (id INT, name TEXT);

資料接收表的欄位類型需與MaxCompute表欄位類型對應，詳情請參見MaxCompute與Hologres的資料類型映射。

登入MaxCompute用戶端，執行UNLOAD命令，將data_test表的資料匯出至Hologres。命令樣本如下：

UNLOAD FROM  
(SELECT * FROM data_test) 
INTO 
LOCATION 'jdbc:postgresql://hgprecn-cn-5y**********-cn-hangzhou-internal.hologres.aliyuncs.com:80/test?ApplicationName=MaxCompute&currentSchema=public&useSSL=false&table=mc_2_holo/'  
STORED BY 'com.aliyun.odps.jdbc.JdbcStorageHandler'
WITH SERDEPROPERTIES ( 
  'odps.properties.rolearn'='acs:ram::13**************:role/aliyunodpsholorole',
  'mcfed.mapreduce.jdbc.driver.class'='org.postgresql.Driver', 
  'odps.federation.jdbc.target.db.type'='holo'
);

在Hologres中查詢匯出資料：

SELECT * FROM mc_2_holo;

返回結果樣本如下：

id	name
4	Gegegegr
3	rgege