CREATE LOCATION

描述

该语句用于创建一个 Location 对象。Location 对象用于存储外表、临时外表所访问的路径和鉴权信息，供数据库读取或写入外部数据。

权限要求

• 执行权限：

  执行 CREATE LOCATION 语句，需要当前用户拥有 CREATE LOCATION 权限。有关 OceanBase 数据库权限的详细介绍，参见 MySQL 模式下的权限分类。

• 认证凭据权限：

  提供的 ACCESSID 和 ACCESSKEY 需具备目标存储服务的合法访问权限。

语法

CREATE [OR REPLACE] LOCATION location_name
    URL = 'file_path'
    [CREDENTIAL = (
        ACCESSID = 'string' 
        ACCESSKEY = 'string' 
        HOST = 'string'
        [S3_REGION = 'string',]
        [PRINCIPAL = 'string',]
        [KEYTAB = 'string',]
        [KRB5CONF = 'string',]
        [CONFIGS = 'string',]
        [USERNAME = 'string']
        )
    ];

参数说明

file_path

外表文件存放的路径有以下格式：

• 本地路径格式为：URL = 'file://local_file_path'，其中 local_file_path 可以为相对路径，也可以为绝对路径。

• HDFS 路径格式为：URL = 'hdfs://localhost:port/PATH'，其中 localhost 指的是 HDFS 的地址，port 指的是 HDFS 的端口号，PATH 指 HDFS 中的目录路径。

• 对象存储（OSS/S3）路径格式为：URL = '{oss | s3}://bucket/remote_file_path'。

configs_option

示例

• 创建存储位置在本地的 Location 对象。

  obclient> CREATE LOCATION test_location_local
      URL = 'file://home/admin/test_csv';
  

• 创建存储位置在 OSS 的 Location 对象。

  obclient> CREATE LOCATION test_location_oss
      URL = 'oss://dir'
      CREDENTIAL = (
          ACCESSID = '******',
          ACCESSKEY = '******',
          HOST = '****'
      );
  

• 创建用户认证模式的 Location 对象。

  无需 Kerberos，但需以特定 HDFS 用户身份访问。

  说明

  适用于未开启 Kerberos 权限认证的集群，但相关 HDFS 路径需要特定用户才能访问的场景。

  CREATE LOCATION hdfs_user
      URL = 'hdfs://namenode:8020/'
      CREDENTIAL (
          USER = 'hdfs_user_name'
      );
  

• 创建启用 Kerberos，HDFS 为单 NameNode（非 HA 模式）的 Location 对象。

  说明

  CONFIGS 中的 dfs.data.transfer.protection 必须与 HDFS 集群配置一致。

  CREATE LOCATION hdfs_kerberos_single
      URL = 'hdfs://namenode.example.com:8020/'
      CREDENTIAL (
          PRINCIPAL = "hdfs/xxx@xxx.COM",
          KEYTAB = "/data/hdfs.keytab",
          KRB5CONF = "/data/krb5.conf",
          CONFIGS = 'dfs.data.transfer.protection=integrity'
      );
  

• 创建启用 Kerberos，HDFS 为高可用（HA）模式的 Location 对象。

  CREATE LOCATION hdfs_kerberos_ha
      URL = 'hdfs://${nameservice id}'
      CREDENTIAL (
          PRINCIPAL = "hdfs/xxx@xxx.COM",
          KEYTAB = "/etc/ob/hdfs.keytab",
          KRB5CONF = "/etc/krb5.conf",
          CONFIGS = 'dfs.data.transfer.protection=${string}#dfs.nameservices=${nameservice id}#dfs.ha.namenodes.${nameservice id}=${namenode1}, ${namenode2}#dfs.namenode.rpc-address.${nameservice id}.${namenode1}=${namenode 1 address}#dfs.namenode.rpc-address.${nameservice id}.${namenode2}=${namenode 2 address}#dfs.ha.automatic-failover.enabled.${nameservice id}=true#dfs.client.failover.proxy.provider.${nameservice id}=org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider'
          );
  

• 未启用 Kerberos，但 HDFS 为高可用（HA）模式。

  说明

  未启用 Kerberos，但 HDFS 为高可用（HA）模式，无需设置 PRINCIPAL、KEYTAB 和 KRB5CONF 参数。

  CREATE LOCATION hdfs_location_ha
      URL = 'hdfs://${nameservice id}'
      CREDENTIAL (
          CONFIGS = 'dfs.nameservices=${nameservice id}#dfs.ha.namenodes.${nameservice id}=${namenode1}, ${namenode2}#dfs.namenode.rpc-address.${nameservice id}.${namenode1}=${namenode 1 address}#dfs.namenode.rpc-address.${nameservice id}.${namenode2}=${namenode 2 address}#dfs.ha.automatic-failover.enabled.${nameservice id}=true#dfs.client.failover.proxy.provider.${nameservice id}=org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider'
          );
  

相关文档

• 关于查看 Location 对象下文件的介绍信息，参见 SHOW。
• 关于修改 Location 对象的介绍信息，参见 ALTER LOCATION。
• 关于删除 Location 对象下文件的介绍信息，参见 REMOVE。
• 关于删除 Location 对象的介绍信息，参见 DROP LOCATION。