com.aliyun.oss.OSSClient.getObject()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(7.2k)|赞(0)|评价(0)|浏览(1388)

本文整理了Java中com.aliyun.oss.OSSClient.getObject()方法的一些代码示例，展示了OSSClient.getObject()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。OSSClient.getObject()方法的具体详情如下：
包路径：com.aliyun.oss.OSSClient
类名称：OSSClient
方法名：getObject

OSSClient.getObject介绍

暂无

代码示例

代码示例来源：origin: Alluxio/alluxio

@Override
 protected InputStream createStream(long startPos, long endPos)
   throws IOException {
  GetObjectRequest req = new GetObjectRequest(mBucketName, mKey);
  // OSS returns entire object if we read past the end
  req.setRange(startPos, endPos < mContentLength ? endPos - 1 : mContentLength - 1);
  OSSObject ossObject = mOssClient.getObject(req);
  return new BufferedInputStream(ossObject.getObjectContent());
 }
}

代码示例来源：origin: aliyun/aliyun-emapreduce-sdk

private InputStream get(String key, long byteRangeStart) throws IOException {
 try {
  if (!doesObjectExist(key)) {
   return null;
  }
  ObjectMetadata objectMetadata = ossClient.getObjectMetadata(bucket, key);
  long fileSize = objectMetadata.getContentLength();
  GetObjectRequest getObjReq = new GetObjectRequest(bucket, key);
  getObjReq.setRange(byteRangeStart, fileSize - 1);
  OSSObject object = ossClient.getObject(getObjReq);
  return object.getObjectContent();
 } catch (ServiceException e) {
  if ("NoSuchKey".equals(e.getErrorCode())) {
   return null;
  }
  if (e.getCause() instanceof IOException) {
   throw (IOException) e.getCause();
  }
  throw new OssException(e);
 }
}

代码示例来源：origin: JpressProjects/jpress

toFile.createNewFile();
  ossClient.getObject(new GetObjectRequest(ossBucketName, path), toFile);
  return true;
} catch (Throwable e) {

代码示例来源：origin: aliyun/aliyun-oss-java-sdk

@Override
public OSSObject getObject(String bucketName, String key) throws OSSException, ClientException {
  return this.getObject(new GetObjectRequest(bucketName, key));
}

代码示例来源：origin: com.aliyun.oss/aliyun-sdk-oss

@Override
public OSSObject getObject(String bucketName, String key) throws OSSException, ClientException {
  return this.getObject(new GetObjectRequest(bucketName, key));
}

代码示例来源：origin: leecho/cola-cloud

@Override
public InputStream getInputStream(String key) {
  return ossClient.getObject(bucketName, key).getObjectContent();
}

代码示例来源：origin: alipay/rdf-file

/**
 * download one file
 * 
 * @param client
 * @param bucketName
 * @param filename
 * @param localFilename
 */
private void downloadFile(OSSClient client, String bucketName, String filename,
             String localFilename) {
  filename = this.toOSSPath(filename);
  GetObjectRequest getObjectRequest = new GetObjectRequest(bucketName, filename);
  File localFile = new File(localFilename);
  if (!localFile.getParentFile().exists()) {
    localFile.getParentFile().mkdirs();
  }
  client.getObject(getObjectRequest, localFile);
}

代码示例来源：origin: leecho/cola-cloud

@Override
public byte[] getBytes(String key) {
  OSSObject ossObject = ossClient.getObject(bucketName, key);
  BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent()));
  byte[] buf = new byte[1024];
  InputStream in = ossObject.getObjectContent();
  for (int n = 0; n != -1; ) {
    try {
      n = in.read(buf, 0, buf.length);
    } catch (IOException e) {
      throw new RuntimeException("download file error!");
    }
  }
  try {
    in.close();
    reader.close();
  } catch (IOException e) {
    throw new RuntimeException("download file error!");
  }
  return buf;
}

代码示例来源：origin: Snailclimb/springboot-integration-examples

/**
 * 通过文件名下载文件
 *
 * @param objectName    要下载的文件名
 * @param localFileName 本地要创建的文件名
 */
public static void downloadFile(String objectName, String localFileName) {
  // 创建OSSClient实例。
  OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
  // 下载OSS文件到本地文件。如果指定的本地文件存在会覆盖，不存在则新建。
  ossClient.getObject(new GetObjectRequest(bucketName, objectName), new File(localFileName));
  // 关闭OSSClient。
  ossClient.shutdown();
}

代码示例来源：origin: org.apache.hadoop/hadoop-aliyun

/**
 * Retrieve a part of an object.
 *
 * @param key the object name that is being retrieved from the Aliyun OSS.
 * @param byteStart start position.
 * @param byteEnd end position.
 * @return This method returns null if the key is not found.
 */
public InputStream retrieve(String key, long byteStart, long byteEnd) {
 try {
  GetObjectRequest request = new GetObjectRequest(bucketName, key);
  request.setRange(byteStart, byteEnd);
  return ossClient.getObject(request).getObjectContent();
 } catch (OSSException | ClientException e) {
  LOG.error("Exception thrown when store retrieves key: "
      + key + ", exception: " + e);
  return null;
 }
}

代码示例来源：origin: lcw2004/one

/**
 * 不要调用这个接口，因为ossclient关闭了，会导致is也关闭
 *
 * @param relativePath 相对路径
 * @return
 */
@Override
public InputStream loadFile(String relativePath) {
  OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
  OSSObject ossObject = ossClient.getObject(bucketName, relativePath);
  InputStream is = ossObject.getObjectContent();
  ossClient.shutdown();
  return is;
}

代码示例来源：origin: lcw2004/one

@Override
public void loadFile(String relativePath, OutputStream os) {
  OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
  OSSObject ossObject = ossClient.getObject(bucketName, relativePath);
  try {
    IOUtils.copy(ossObject.getObjectContent(), os, FileUtil.BUFF_SIZE);
  } catch (IOException e) {
    throw new OneBaseException("读取文件[" + relativePath + "]失败");
  }
  ossClient.shutdown();
}

代码示例来源：origin: ECNU-1X/DataX-Masking

@Override
public void startRead(RecordSender recordSender) {
  LOG.debug("read start");
  String object = readerSliceConfig.getString(Key.OBJECT);
  OSSClient client = OssUtil.initOssClient(readerSliceConfig);
  OSSObject ossObject = client.getObject(
      readerSliceConfig.getString(Key.BUCKET), object);
  InputStream objectStream = ossObject.getObjectContent();
  UnstructuredStorageReaderUtil.readFromStream(objectStream, object,
      this.readerSliceConfig, recordSender,
      this.getTaskPluginCollector());
  recordSender.flush();
}

代码示例来源：origin: alipay/rdf-file

/** 
 * @see com.alipay.rdf.file.storage.FileInnterStorage#getInputStream(java.lang.String)
 */
@Override
public InputStream getInputStream(String filePath) {
  filePath = toOSSPath(filePath);
  if (isExist(filePath)) {
    OSSObject object = client.getObject(ossConfig.getBucketName(), filePath);
    return new OssInputStream(object);
  } else {
    throw new RdfFileException(
      "rdf-file#FileOssStorage.getInputStream(filePath=" + filePath + "), 文件不存在",
      RdfErrorEnum.NOT_EXSIT);
  }
}

代码示例来源：origin: aliyun/aliyun-emapreduce-sdk

private InputStream get(String key, boolean checkMetadata)
  throws IOException {
 try {
  if (!doesObjectExist(key)) {
   return null;
  }
  OSSObject object = ossClient.getObject(bucket, key);
  if (checkMetadata) {
   checkMetadata(object);
  }
  return object.getObjectContent();
 } catch (ServiceException e) {
  if ("NoSuchKey".equals(e.getErrorCode())) {
   return null;
  }
  if (e.getCause() instanceof IOException) {
   throw (IOException) e.getCause();
  }
  throw new OssException(e);
 }
}

代码示例来源：origin: alipay/rdf-file

/** 
 * @see com.alipay.rdf.file.storage.FileInnterStorage#getInputStream(java.lang.String, long, long)
 */
@Override
public InputStream getInputStream(String filePath, long start, long length) {
  if (length <= 0) {
    throw new RdfFileException("rdf-file#FileOssStorage.getInputStream(filePath=" + filePath
                  + ", start=" + start + ", length=" + length + "获取数据长度必须大于零",
      RdfErrorEnum.ILLEGAL_ARGUMENT);
  }
  filePath = toOSSPath(filePath);
  if (isExist(filePath)) {
    GetObjectRequest getObjectRequest = new GetObjectRequest(ossConfig.getBucketName(),
      filePath);
    getObjectRequest.setRange(start, start + length - 1);
    OSSObject object = client.getObject(getObjectRequest);
    return new OssInputStream(object);
  } else {
    throw new RdfFileException("rdf-file#FileOssStorage.getInputStream(filePath=" + filePath
                  + ", start=" + start + ", length=" + length + ")",
      RdfErrorEnum.NOT_EXSIT);
  }
}

内容来源于网络，如有侵权，请联系作者删除！

OSSClient

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com