全部产品

创建OSS Schema和表

更新时间:2020-06-17 13:09:33

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

创建Schema

  1. 登录DLA控制台

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

    1. CREATE SCHEMA oss_data_schema with DBPROPERTIES(
    2. catalog='oss',
    3. location = 'oss://oss_bucket_name/table/'
    4. );
    • 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文件。

  1. CREATE EXTERNAL TABLE IF NOT EXISTS dla_table_1 (
  2. id bigint NOT NULL COMMENT '',
  3. origin_state varchar NOT NULL COMMENT '',
  4. origin_zip varchar NOT NULL COMMENT '',
  5. destination_state varchar NOT NULL COMMENT '',
  6. destination_zip varchar NOT NULL COMMENT '',
  7. package_weight int NOT NULL COMMENT ''
  8. )
  9. ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
  10. STORED AS TEXTFILE
  11. LOCATION 'oss://oss_bucket_name/table/';
  1. CREATE EXTERNAL TABLE IF NOT EXISTS dla_table_2 (
  2. customer_id bigint NOT NULL COMMENT '',
  3. order_id varchar NOT NULL COMMENT '',
  4. order_time date NOT NULL COMMENT '',
  5. order_amount double NOT NULL COMMENT '',
  6. order_type varchar NOT NULL COMMENT '',
  7. address varchar NOT NULL COMMENT '',
  8. city varchar NOT NULL COMMENT '',
  9. order_season bigint COMMENT '',
  10. PRIMARY KEY (customer_id)
  11. )
  12. ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
  13. STORED AS TEXTFILE
  14. LOCATION 'oss://oss_bucket_name/table/';

下一步

创建AnalyticDB Schema