ApsaraDB for SelectDB:OSS Load を使用してデータをインポートする

前提条件

• AccessKey ペアを取得済みであること。詳細については、「AccessKey ペアを作成する」をご参照ください。

• OSS がアクティブ化されており、OSS バケットが作成されていること。OSS バケットは、データをインポートする ApsaraDB for SelectDB インスタンスと同じリージョンにあること。詳細については、「OSS コンソールを使用して開始する」をご参照ください。

• OSS バケットが ApsaraDB for SelectDB インスタンスと同じリージョンにあること。OSS は VPC 経由でアクセスできること。

データインポートの構文

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. ApsaraDB for 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"
   );
   

   説明

   OSS バケットのパスは s3:// で始まる必要があります。

OSS ロード ジョブのキャンセル

OSS Load ジョブが 場合ロード ジョブは CANCELLED または または FINISHED 状態ではない場合は、ジョブを手動でキャンセルできます。キャンセルするインポートジョブの 状態の場合、ジョブを手動でキャンセルできます。 label を指定する必要があります。インポートジョブがキャンセルされると、ジョブに書き込まれたデータはロールバックされ、有効になりません。 インポート ジョブのキャンセル対象です。インポート ジョブ

構文

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

パラメーター

例

• label が example_db_test_load_label であるインポートジョブを example_db

  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 は非同期データインポート方式です。データインポート文が正常に実行されると、OSS Load ジョブは正常にコミットされますが、データはインポートされない場合があります。Broker 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];

パラメーター