详情页标题前

阿里云对象存储OSS非EMR集群接入OSS-HDFS服务快速入门-云淘科技

详情页1

OSS-HDFS服务(JindoFS服务)完全兼容HDFS接口,同时支持目录层级的操作。JindoSDK为Apache Hadoop的计算分析应用(例如MapReduce、Hive、Spark、Flink等)提供了访问HDFS服务的能力。本文介绍如何通过在ECS实例中部署JindoSDK,然后完成OSS-HDFS服务快速入门相关操作。

前提条件

  • 已创建ECS实例。具体步骤,请参见选购ECS实例。
  • 已创建Hadoop环境。具体步骤,请参见创建Hadoop运行环境。
  • 已开通并授权访问OSS-HDFS服务。具体操作,请参见开通并授权访问OSS-HDFS服务。

操作视频

观看以下视频了解如何通过非EMR集群快速接入OSS-HDFS服务并完成常见操作。


操作步骤

  1. 连接ECS实例。具体操作,请参见连接ECS实例。
  2. 下载并解压JindoSDK JAR包。
    1. 执行以下命令,下载最新版本的JindoSDK JAR包。下载地址,请参见GitHub。
      wget https://jindodata-binary.oss-cn-shanghai.aliyuncs.com/release/x.x.x/jindosdk-x.x.x.tar.gz


      说明 x.x.x表示JindoSDK JAR包版本号。

    2. 执行以下命令,解压JindoSDK JAR包。
      tar zxvf jindosdk-x.x.x.tar.gz
  3. 配置环境变量。
    1. 配置JINDOSDK_HOME。以安装包内容解压在/usr/lib/jindosdk-x.x.x目录为例:
      export JINDOSDK_HOME=/usr/lib/jindosdk-x.x.x
    2. 配置HADOOP_CLASSPATH
      export HADOOP_CLASSPATH=$HADOOP_CLASSPATH:${JINDOSDK_HOME}/lib/*


      重要 请将安装目录和环境变量部署到所有所需节点上。

  4. 配置JindoFS服务实现类及AccessKey。
    1. 执行以下命令,进入Hadoop的core-site.xml配置文件
      vim /usr/local/hadoop/etc/hadoop/core-site.xml
    2. 将JindoSDK DLS实现类配置到Hadoop的core-site.xml中。
      
          
              fs.AbstractFileSystem.oss.impl
              com.aliyun.jindodata.oss.JindoOSS
          
      
          
              fs.oss.impl
              com.aliyun.jindodata.oss.JindoOssFileSystem
          
      
    3. 将已开启HDFS服务的Bucket对应的accessKeyId、accessKeySecret预先配置在Hadoop的core-site.xml中。
      
          
              fs.oss.accessKeyId
              xxx
          
      
          
              fs.oss.accessKeySecret
              xxx
          
      
  5. 配置JindoFS服务Endpoint。使用JindoFS服务访问OSS Bucket时需要配置Endpoint。推荐访问路径格式为oss://./,例如oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/exampleobject.txt。配置完成后,JindoSDK会根据访问路径中的Endpoint访问对应的JindoFS服务接口。

    您还可以通过其他方式配置JindoFS服务Endpoint,且不同方式配置的Endpoint存在生效优先级。更多信息,请参见附录一:配置Endpoint的其他方式。

  6. 通过HDFS Shell命令执行OSS-HDFS服务快速入门常见操作。
    • 上传文件

      将本地根目录下的examplefile.txt文件上传至examplebucket,示例如下:

      hdfs dfs -put examplefile.txt oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/
    • 新建目录

      在examplebucket下创建名为dir/的目录,示例如下:

      hdfs dfs -mkdir oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/dir/
    • 查看文件或目录信息

      查看examplebucket下的文件或目录信息,示例如下:

      hdfs dfs -ls oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/
    • 获取文件或目录大小

      获取examplebucket下所有文件或目录的大小,示例如下:

      hdfs dfs -du oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/
    • 查看文件内容

      查看examplebucket下名为localfile.txt的文件内容,示例如下:

      hdfs dfs -cat oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/localfile.txt


      重要 查看文件内容时,文件内容将以纯文本形式打印到屏幕上。如果文件内容进行了特定格式的编码,请使用HDFS的Java API读取并解码文件内容。

    • 拷贝目录或文件

      例如,将examplebucket下根目录subdir1拷贝到目录subdir2下,且根目录subdir1所在的位置、根目录下的文件和子目录结构和内容保持不变,示例如下:

      hdfs dfs -cp oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/subdir1  oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/subdir2/subdir1
    • 移动目录或文件

      例如,将examplebucket根目录srcdir及其包含的文件或者子目录移动至另一个根目录destdir下,示例如下:

      hdfs dfs -mv oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/srcdir  oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/destdir
    • 下载文件

      将examplebucket下的exampleobject.txt下载到本地根目录文件夹/tmp,示例如下:

      hdfs dfs -get oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/exampleobject.txt  /tmp/
    • 删除目录或文件

      删除examplebucket下destfolder/目录及其目录下的所有文件,示例如下:

      hdfs dfs -rm oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/destfolder/
  7. 附录一:配置Endpoint的其他方式

    除上述提到的在访问路径中指定Endpoint的方式以外,您还可以通过以下两种方式配置JindoFS服务的Endpoint:

    • Bucket级别的Endpoint

      如果使用oss:///格式的访问路径,即访问路径中未设置Endpoint。此时,您可以在Hadoop的配置文件core-site.xml中设置Bucket级别的Endpoint,从而指向JindoFS服务的Endpoint。

      
          
              
              fs.oss.bucket.examplebucket.endpoint
              
              cn-hangzhou.oss-dls.aliyuncs.com
          
      
    • 全局默认Endpoint

      如果使用oss:///格式的访问路径,且访问路径中未设置Bucket级别的Endpoint,则默认使用全局Endpoint的方式访问JindoFS服务。在Hadoop的配置文件core-site.xml中设置全局默认Endpoint的方式如下:

      
          
              fs.oss.endpoint
              
              cn-hangzhou.oss-dls.aliyuncs.com
          
      


      说明 通过不同方式配置Endpoint后,Endpoint生效优先级为访问路径中的Endpoint>Bucket级别的Endpoint>全局默认Endpoint

      附录二:性能调优

      您可以结合实际业务需求,将以下配置项添加到Hadoop的core-site.xml中。仅JindoSDK 4.0及以上版本支持以下配置项。

      
      
          
                
              fs.oss.tmp.data.dirs
              /tmp/
          
      
          
                
              fs.oss.retry.count
              5
          
      
          
                
              fs.oss.timeout.millisecond
              30000
          
      
          
                
              fs.oss.connection.timeout.millisecond
              3000
          
      
          
                
              fs.oss.upload.thread.concurrency
              5
          
      
          
                
              fs.oss.upload.queue.size
              5
          
      
          
                
              fs.oss.upload.max.pending.tasks.per.stream
              16
          
      
          
                
              fs.oss.download.queue.size
              5
          
      
          
                
              fs.oss.download.thread.concurrency
              16
          
      
          
                
              fs.oss.read.readahead.buffer.size
              1048576
          
      
          
                
              fs.oss.read.readahead.buffer.count
              4
          
      
      

      内容没看懂? 不太想学习?想快速解决? 有偿解决: 联系专家

      阿里云企业补贴进行中: 马上申请

      腾讯云限时活动1折起,即将结束: 马上收藏

      同尘科技为腾讯云授权服务中心。

      购买腾讯云产品享受折上折,更有现金返利:同意关联,立享优惠

      转转请注明出处:https://www.yunxiaoer.com/156979.html

      (0)
      上一篇 2023年12月10日
      下一篇 2023年12月10日
      详情页2

      相关推荐

      • 阿里云对象存储OSSGo配置访问凭证-云淘科技

        使用Go SDK发起OSS请求,您需要配置访问凭证。阿里云服务会通过访问凭证验证您的身份信息和访问权限。您可以根据使用场景对认证和授权的要求,选择不同类型的访问凭证。本文介绍如何配置临时访问凭证和长期访问凭证。 前提条件 在配置访问凭证前,您需要安装Go SDK。详情请参见Go安装。 访问凭证 您可以选择以下类型的访问凭证。 临时访问凭证:对于需要高安全性的…

        阿里云对象存储 2023年12月10日
      • 阿里云RDS数据库DescribeSQLLogFiles – 查询SQL洞察(SQL审计)导出文件列表-云淘科技

        该接口用于查询SQL洞察(SQL审计)导出文件列表。不支持查询通过控制台手动导出的SQL洞察日志文件,只支持查询通过DescribeSQLLogRecords接口生成(请求参数Form取值为File)的SQL洞察文件列表。 接口说明 适用引擎 RDS MySQL RDS PostgreSQL RDS SQL Server 说明 仅支持SQL Server 2…

        阿里云数据库 2023年12月9日
      • 阿里云对象存储OSSGo追加上传-云淘科技

        追加上传是指通过AppendObject方法在已上传的追加类型文件(Appendable Object)末尾直接追加内容。 注意事项 本文以华东1(杭州)外网Endpoint为例。如果您希望通过与OSS同地域的其他阿里云产品访问OSS,请使用内网Endpoint。关于OSS支持的Region与Endpoint的对应关系,请参见访问域名和数据中心。 本文以从环…

        阿里云对象存储 2023年12月10日
      • 信息流广告,信息流部分建议宽度830px,只针对默认列表样式,顺序随机
      • 阿里云对象存储OSS使用ossimport迁移数据-云淘科技

        ossimport支持将任意地域的本地存储数据、第三方存储数据、对象存储OSS数据迁移至任意地域的OSS中。本文介绍如何使用ossimport将数据从第三方存储迁移到OSS。 背景信息 某用户的数据存储于腾讯云COS广州(华南)区域,数据大小约500TB。现希望将这些数据,通过ossimport工具,于一周内迁移至OSS华东1(杭州)区域。在迁移的同时,需保…

        阿里云对象存储 2023年12月10日
      • 阿里云对象存储OSS如何提升OSS访问速度?-云淘科技

        本文介绍提升OSS访问速度的多种方式。 选择合适的地域 一般来说,距离您更近的地域访问速度更快。您可以根据费用、请求来源等选择合适的地域创建Bucket。更多信息,请参见如何选择OSS地域。 开启传输加速 OSS支持传输加速功能。开启传输加速后,您可以使用OSS的传输加速域名提升访问速度。更多信息,请参见传输加速。 使用CDN加速 如果您已开通阿里云CDN服…

        阿里云对象存储 2023年12月10日

      联系我们

      400-800-8888

      在线咨询: QQ交谈

      邮件:admin@example.com

      工作时间:周一至周五,9:30-18:30,节假日休息

      关注微信
      本站为广大会员提供阿里云、腾讯云、华为云、百度云等一线大厂的购买,续费优惠,保证底价,买贵退差。