创建OSS Schema和表

在DLA中创建OSS Schema和表即可读取OSS中的文件数据。

创建Schema

1. 登录DLA控制台。

2. 单击左侧导航栏的访问点管理，然后登录DMS，在DLA中创建OSS Schema的语法如下所示：

    CREATE SCHEMA oss_data_schema with DBPROPERTIES(
      catalog='oss',
     location = 'oss://oss_bucket_name/table/'
     );

   • catalog='oss'：创建的是OSS Schema。

   • location：数据文件所在的OSS Bucket的目录，需以/结尾表示目录。

     后续建表的location所指向的数据文件，必须在该OSS目录下。

创建OSS表

本示例中dla_table_1、dla_table_2分别与AnalyticDB for MySQL中的shipping、order_table表信息一致。且OSS Bucket中table Object下已经上传了dla_table_1、dla_table_2文件。

CREATE EXTERNAL TABLE IF NOT EXISTS dla_table_1 (
  id bigint NOT NULL COMMENT '',
  origin_state varchar NOT NULL COMMENT '',
  origin_zip varchar NOT NULL COMMENT '',
  destination_state varchar NOT NULL COMMENT '',
  destination_zip varchar NOT NULL COMMENT '',
  package_weight int NOT NULL COMMENT ''
) 
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|' 
STORED AS TEXTFILE 
LOCATION 'oss://oss_bucket_name/table/';

CREATE EXTERNAL TABLE IF NOT EXISTS dla_table_2 (
   customer_id bigint NOT NULL COMMENT '',
   order_id varchar NOT NULL COMMENT '',
   order_time date NOT NULL COMMENT '',
   order_amount double NOT NULL COMMENT '',
   order_type varchar NOT NULL COMMENT '',
   address varchar NOT NULL COMMENT '',
   city varchar NOT NULL COMMENT '',
   order_season bigint COMMENT '',
   PRIMARY KEY (customer_id)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|' 
STORED AS TEXTFILE 
LOCATION 'oss://oss_bucket_name/table/';

下一步

创建AnalyticDB Schema