一、从OBS上读数据并导入DWS

1. 进入OBS控制台，新建桶dws-test20210316及对象testobs1。
   
   
   
2. 上传txt数据文件到obs上。
   
   
3. 连接DWS集群建立内表table1，以及obs外表table1_inobs_ft。
   

   CREATE FOREIGN TABLE table1_inobs_ft(like  table1)
   SERVER gsmpp_server
   OPTIONS(
   LOCATION 'obs://dws-test20210316/testobs1/text1.txt',
   FORMAT 'text' ,
   DELIMITER ',',
   ENCODING 'utf8',
   HEADER 'false',
   ACCESS_KEY 'U76V66',
   SECRET_ACCESS_KEY 'qCJyo9B',
   FILL_MISSING_FIELDS 'true',
   IGNORE_EXTRA_DATA 'true'
   )
   READ ONLY
   LOG INTO product_info_err
   PER NODE REJECT LIMIT 'unlimited';

   注意：ACCESS_KEY，SECRET_ACCESS_KEY 是在“我的凭证”—“访问密钥”中下载。首次申请密钥后会提示下载。
   

   
   

4. 读取obs数据
   Select * from table1_inobs_ft;
   
   
5. 导入OBS数据到DWS
   insert into table1 select * from table1_inobs_ft;
   

二、DWS导出数据到OBS

1. 在桶dws-test20210316中新建对象output1，设置可读写。
   
   
   
2. 创建table1的obs导出外表
   

   CREATE FOREIGN TABLE table1_outobs_ft (like  table1)
   SERVER gsmpp_server
   OPTIONS(LOCATION 'obs://dws-test20210316/output1/',
   FORMAT 'text',
   ENCODING 'utf8', 
   DELIMITER ',', 
   ENCRYPT 'off',
   ACCESS_KEY 'U7DGJ6V66',
   SECRET_ACCESS_KEY 'qC9B'
   ) WRITE ONLY;

3. 导出数据到obs
   insert into table1_outobs_ft select * from table1;
   
   
   
4. 建立外表读取上步骤导出的数据（LOCATION 中table1_outobs_ft表示所有以table1_outobs_ft开头的文件）
   

   CREATE FOREIGN TABLE table1_selobs_ft (like  table1) 
   SERVER gsmpp_server 
   OPTIONS(
   LOCATION 'obs://dws-test20210316/output1/table1_outobs_ft',
   FORMAT 'text' ,
   DELIMITER ',',
   ENCODING 'utf8',
   HEADER 'false',
   ACCESS_KEY 'U7D66',
   SECRET_ACCESS_KEY 'qCJycqn0wo9B',
   FILL_MISSING_FIELDS 'true',
   IGNORE_EXTRA_DATA 'true'
   )
   READ ONLY ;

   select * from table1_selobs_ft;