org.jclouds.blobstore.BlobStore.putBlob()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(179)

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

BlobStore.putBlob介绍

[英]Adds a Blob representing the data at location container/blob.metadata.name
[中]在位置container/Blob处添加表示数据的Blob。元数据。名称

代码示例

代码示例来源：origin: apache/usergrid

  1. BlobBuilder blobBuilder = blobStore.blobBuilder( filename )
  2.   .payload( ephemeral )
  3.   .contentMD5(Files.hash( ephemeral, Hashing.md5() ))
  4.   .contentType("application/json");
  5. final String uploadedFile = blobStore.putBlob(
  6.   bucketName, blob, PutOptions.Builder.multipart() );

代码示例来源：origin: com.googlecode.the-fascinator.plugins/plugin-storage-blobstore

  1. private void writePayloadMetadata(Map<String, String> userMetadata) throws StorageException {
  2.   Properties metadata = new Properties();
  3.   for (String key : userMetadata.keySet()) {
  4.     metadata.setProperty(key, userMetadata.get(key));
  5.   }
  6.   BlobStore blobStore = BlobStoreClient.getClient();
  7.   ByteArrayOutputStream output = new ByteArrayOutputStream();
  8.   try {
  9.     metadata.store(output, null);
  10.   } catch (IOException e) {
  11.     throw new StorageException("Failed to write payload metadata", e);
  12.   }
  13.   InputStream input = new ByteArrayInputStream(output.toByteArray());
  14.   Blob metadataBlob = blobStore.blobBuilder(blob.getMetadata().getName() + METADATA_SUFFIX).build();
  15.   metadataBlob.setPayload(input);
  16.   blobStore.putBlob(BlobStoreClient.getContainerName(), metadataBlob);
  17. }

代码示例来源：origin: apache/usergrid

  1. BlobBuilder blobBuilder = blobStore.blobBuilder( filename )
  2.   .payload( uploadFile )
  3.   .contentMD5(Files.hash( uploadFile, Hashing.md5()))
  4.   .contentType( "application/json" );
  5. final String uploadedFile = blobStore.putBlob( bucketName, blob, PutOptions.Builder.multipart() );

代码示例来源：origin: rackerlabs/blueflood

  1. public void publish(String remoteName, byte[] payload) throws IOException {
  2.     Timer.Context ctx = uploadTimer.time();
  3.     try {
  4.       Blob blob = blobStore.blobBuilder(remoteName).payload(payload)
  5.           .contentType("application/json")
  6.           .contentEncoding(remoteName.endsWith(".gz") ? "gzip" : "identity")
  7.           .calculateMD5().build();
  9.       String containerName = CONTAINER_DATE_FORMAT.format(new Date());
  10.       if (!lastContainerCreated.matches(containerName)) {
  11.         createContainer();
  12.       }
  13.       blobStore.putBlob(containerName, blob);
  14.     } finally {
  15.       ctx.stop();
  16.     }
  17.   }
  18. }

代码示例来源：origin: gaul/s3proxy

  1. ByteSource payload = ByteSource.empty();
  2. BlobBuilder.PayloadBlobBuilder builder = blobStore
  3.     .blobBuilder(blobName)
  4.     .payload(payload);
  5. addContentMetdataFromHttpRequest(builder, request);
  6. builder.contentLength(payload.size());
  7.   blobStore.putBlob(containerName, builder.name(mpu.id()).build(),
  8.       options);

代码示例来源：origin: gaul/s3proxy

  1. .blobBuilder(blobName)
  2.     .payload(is)
  3.     .contentLength(contentLength);
  4. eTag = blobStore.putBlob(containerName, builder.build(),
  5.     options);

代码示例来源：origin: gaul/s3proxy

  1. .blobBuilder(blobName)
  2.     .payload(payload);
  3. if (contentType != null) {
  4.   builder.contentType(contentType);
  5. blobStore.putBlob(containerName, blob);

代码示例来源：origin: jclouds/legacy-jclouds

  1. public void execute(String containerName, String directory) {
  2.    blobStore.putBlob(
  3.       containerName,
  4.       blobStore.blobBuilder(directory + directorySuffix).type(StorageType.RELATIVE_PATH)
  5.          .payload(newByteArrayPayload(new byte[] {})).contentType("application/directory").build());
  6.   }
  7. }

代码示例来源：origin: io.cloudsoft.jclouds/jclouds-blobstore

  1. public void execute(String containerName, String directory) {
  2.    blobStore.putBlob(
  3.       containerName,
  4.       blobStore.blobBuilder(directory + directorySuffix).type(StorageType.RELATIVE_PATH)
  5.          .payload(newByteArrayPayload(new byte[] {})).contentType("application/directory").build());
  6.   }
  7. }

代码示例来源：origin: org.apache.jclouds/jclouds-blobstore

  1. public void execute(String containerName, String directory) {
  2.    blobStore.putBlob(
  3.       containerName,
  4.       blobStore.blobBuilder(directory + directorySuffix).type(StorageType.FOLDER)
  5.          .payload(newByteArrayPayload(new byte[] {})).contentType("application/directory").build());
  6.   }
  7. }

代码示例来源：origin: org.jclouds/jclouds-blobstore

  1. public void execute(String containerName, String directory) {
  2.    blobStore.putBlob(
  3.       containerName,
  4.       blobStore.blobBuilder(directory + directorySuffix).type(StorageType.RELATIVE_PATH)
  5.          .payload(newByteArrayPayload(new byte[] {})).contentType("application/directory").build());
  6.   }
  7. }

代码示例来源：origin: Nextdoor/bender

  1. public void execute(String containerName, String directory) {
  2.    blobStore.putBlob(
  3.       containerName,
  4.       blobStore.blobBuilder(directory + directorySuffix).type(StorageType.FOLDER)
  5.          .payload(newByteArrayPayload(new byte[] {})).contentType("application/directory").build());
  6.   }
  7. }

代码示例来源：origin: com.amysta.jclouds/jclouds-blobstore

  1. public void execute(String containerName, String directory) {
  2.    blobStore.putBlob(
  3.       containerName,
  4.       blobStore.blobBuilder(directory + directorySuffix).type(StorageType.FOLDER)
  5.          .payload(newByteArrayPayload(new byte[] {})).contentType("application/directory").build());
  6.   }
  7. }

代码示例来源：origin: apache/jclouds

  1. public void execute(String containerName, String directory) {
  2.    blobStore.putBlob(
  3.       containerName,
  4.       blobStore.blobBuilder(directory + directorySuffix).type(StorageType.FOLDER)
  5.          .payload(newByteArrayPayload(new byte[] {})).contentType("application/directory").build());
  6.   }
  7. }

代码示例来源：origin: org.apache.whirr/whirr-core

  1. @Override
  2. public void save(Cluster cluster) throws IOException {
  3.  BlobStore store = context.getBlobStore();
  4.  Blob blob = store.blobBuilder(blobName).payload(serialize(cluster)).build();
  5.  store.putBlob(container, blob);
  6.  LOG.info("Saved cluster state to '{}' ", context.getSigner()
  7.   .signGetBlob(container, blobName).getEndpoint().toString());
  8. }

代码示例来源：origin: apache/attic-whirr

  1. @Override
  2. public void save(Cluster cluster) throws IOException {
  3.  BlobStore store = context.getBlobStore();
  4.  Blob blob = store.blobBuilder(blobName).payload(serialize(cluster)).build();
  5.  store.putBlob(container, blob);
  6.  LOG.info("Saved cluster state to '{}' ", context.getSigner()
  7.   .signGetBlob(container, blobName).getEndpoint().toString());
  8. }

代码示例来源：origin: org.apache.whirr/whirr-core

  1. public synchronized void putIfAbsent(File file) throws FileNotFoundException {
  2.   allocateContainer();
  3.   BlobStore store = context.getBlobStore();
  4.   if (!store.blobExists(container, file.getName())) {
  5.    LOG.info("Uploading '{}' to '{}' blob cache.", file.getName(), container);
  6.    Blob blob = context.getBlobStore().blobBuilder(container)
  7.        .name(file.getName())
  8.        .payload(file)
  9.        .contentLength(file.length())
  10.        .build();
  11.    store.putBlob(container, blob, multipart());
  12.   }
  13. }

代码示例来源：origin: apache/attic-whirr

  1. public synchronized void putIfAbsent(File file) throws FileNotFoundException {
  2.   allocateContainer();
  3.   BlobStore store = context.getBlobStore();
  4.   if (!store.blobExists(container, file.getName())) {
  5.    LOG.info("Uploading '{}' to '{}' blob cache.", file.getName(), container);
  6.    Blob blob = context.getBlobStore().blobBuilder(container)
  7.        .name(file.getName())
  8.        .payload(file)
  9.        .contentLength(file.length())
  10.        .build();
  11.    store.putBlob(container, blob, multipart());
  12.   }
  13. }

代码示例来源：origin: org.apache.camel/camel-jclouds

  1. /**
  2.  * Writes {@link Payload} to the {@link BlobStore}.
  3.  */
  4. public static void writeBlob(BlobStore blobStore, String container, String blobName, Payload payload) {
  5.   if (blobName != null && payload != null) {
  6.     mkDirs(blobStore, container, blobName);
  7.     Blob blob = blobStore.blobBuilder(blobName).payload(payload).contentType(MediaType.APPLICATION_OCTET_STREAM).contentDisposition(blobName).build();
  8.     blobStore.putBlob(container, blob, multipart());
  9.   }
  10. }

代码示例来源：origin: apache/jackrabbit-oak

  1. /**
  2.  * Uploads the block to the cloud service.
  3.  */
  4. @Override
  5. protected void storeBlock(byte[] digest, int level, byte[] data) throws IOException {
  6.   Preconditions.checkNotNull(context);
  7.   String id = StringUtils.convertBytesToHex(digest);
  8.   cache.put(id, data);
  9.   
  10.   org.jclouds.blobstore.BlobStore blobStore = context.getBlobStore();
  11.   if (!blobStore.blobExists(cloudContainer, id)) {
  12.     Map<String, String> metadata = Maps.newHashMap();
  13.     metadata.put("level", String.valueOf(level));
  14.     Blob blob = blobStore.blobBuilder(id)
  15.         .payload(data)
  16.         .userMetadata(metadata)
  17.         .build();
  18.     String etag = blobStore.putBlob(cloudContainer, blob, multipart());
  19.     LOG.debug("Blob " + id + " created with cloud tag : " + etag);
  20.   } else {
  21.     LOG.debug("Blob " + id + " already exists");
  22.   }
  23. }

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

BlobStore

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    BlobStore类方法

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