ApsaraDB for SelectDB：OSS Load

前提條件

• 已擷取AccessKey資訊。具體操作，請參見建立AccessKey。

• 已開通OSS服務，並建立與ApsaraDB for SelectDB執行個體位於相同地區的儲存空間（Bucket）。具體操作，請參見開通OSS服務和建立儲存空間。

• 請確保OSS儲存空間（Bucket）與ApsaraDB for SelectDB執行個體在同一地區，並使用阿里雲VPC網路訪問OSS。

匯入文法​

LOAD LABEL load_label
(
    data_desc1[, data_desc2, ...]
)
WITH S3
(
    "AWS_PROVIDER" = "OSS",
    "AWS_REGION" = "REGION",  
    "AWS_ENDPOINT" = "ENDPOINT",
    "AWS_ACCESS_KEY" = "AccessKey ID",
    "AWS_SECRET_KEY"="AccessKey Secret"
)
PROPERTIES 
(
  "key1"="value1", ...
);

參數說明

data_desc1用於描述一組需要匯入的檔案，其完整定義如下。

[MERGE|APPEND|DELETE]
DATA INFILE
(
"file_path1"[, file_path2, ...]
)
[NEGATIVE]
INTO TABLE `table_name`
[PARTITION (p1, p2, ...)]
[COLUMNS TERMINATED BY "column_separator"]
[FORMAT AS "file_type"]
[(column_list)]
[COLUMNS FROM PATH AS (c1, c2, ...)]
[PRECEDING FILTER predicate]
[SET (column_mapping)]
[WHERE predicate]
[DELETE ON expr]
[ORDER BY source_sequence]
[PROPERTIES ("key1"="value1", ...)]

雲端儲存體服務配置參數說明如下。

PROPERTIES的常用參數定義如下。

使用樣本

1. 建立待匯入的SelectDB資料表，樣本如下。

   CREATE TABLE test_table
   (
       id int,
       name varchar(50),
       age int,
       address varchar(50),
       url varchar(500)
   )
   DISTRIBUTED BY HASH(id) BUCKETS 4
   PROPERTIES("replication_num" = "1");

2. 建立待匯入的檔案test_file.txt，樣本如下。

   1,yang,32,shanghai,http://example.com
   2,wang,22,beijing,http://example.com
   3,xiao,23,shenzhen,http://example.com
   4,jess,45,hangzhou,http://example.com
   5,jack,14,shanghai,http://example.com
   6,tomy,25,hangzhou,http://example.com
   7,lucy,45,shanghai,http://example.com
   8,tengyin,26,shanghai,http://example.com
   9,wangli,27,shenzhen,http://example.com
   10,xiaohua,37,shanghai,http://example.com

3. 通過以下方式進行OSS Load，樣本如下。

   LOAD LABEL test_db.test_label_1
   (
       DATA INFILE("s3://your_bucket_name/test_file.txt")
       INTO TABLE test_table
       COLUMNS TERMINATED BY ","
   )
   WITH S3
   (
       "AWS_PROVIDER" = "OSS",
       "AWS_REGION" = "oss-cn-beijing",  
       "AWS_ENDPOINT" = "oss-cn-beijing-internal.aliyuncs.com",
       "AWS_ACCESS_KEY" = "<your_access_key>",
       "AWS_SECRET_KEY"="<your_secret_key>"
   )
   PROPERTIES
   (
       "timeout" = "3600"
   );
   

   說明

   Object Storage Service的路徑固定以“s3://”開頭。

取消匯入

當OSS Load作業狀態不為CANCELLED或FINISHED時，可以手動取消匯入。取消時需要指定待取消匯入任務的Label。匯入任務取消後，已寫入的資料也會復原，不會生效。

文法

CANCEL LOAD
[FROM db_name]
WHERE [LABEL = "load_label" | LABEL like "label_pattern"];

參數說明

使用樣本

• 撤銷資料庫example_db上，Label為example_db_test_load_label的匯入作業。

  CANCEL LOAD
  FROM example_db
  WHERE LABEL = "example_db_test_load_label";

• 撤銷資料庫example_db上，所有包含example_的匯入作業。

  CANCEL LOAD
  FROM example_db
  WHERE LABEL like "example_";

查看匯入

OSS Load是一個非同步匯入處理程序，語句執行成功僅代表匯入任務提交成功，並不代表資料匯入成功。匯入狀態需要通過SHOW LOAD命令查看。

文法

SHOW LOAD
[FROM db_name]
[
   WHERE
   [LABEL [ = "your_label" | LIKE "label_matcher"]]
   [STATE = ["PENDING"|"ETL"|"LOADING"|"FINISHED"|"CANCELLED"|]]
]
[ORDER BY ...]
[LIMIT limit][OFFSET offset];

參數說明