使用 Java API 在 Google 云存储中批量插入?
Batch inserts in Google Cloud Storage using the Java API?
根据 documentation 可以使用 HTTP 批量插入 Google 云存储服务。但是如何使用 Java API 来做到这一点呢?我似乎找不到任何文档或示例。
根据本库的 documentation, Google has provided a Google Cloud Client Library. The java doc,提供了以下示例代码以使用单个 RPC
请求进行批量请求:
StorageBatch batch = storage.batch();
BlobId firstBlob = BlobId.of("bucket", "blob1"));
BlobId secondBlob = BlobId.of("bucket", "blob2"));
batch.delete(firstBlob).notify(new BatchResult.Callback<Boolean, StorageException>() {
public void success(Boolean result) {
// deleted successfully
}
public void error(StorageException exception) {
// delete failed
}
});
batch.update(BlobInfo.builder(secondBlob).contentType("text/plain").build());
StorageBatchResult<Blob> result = batch.get(secondBlob);
batch.submit();
Blob blob = result.get(); // returns get result or throws StorageException
根据 documentation 可以使用 HTTP 批量插入 Google 云存储服务。但是如何使用 Java API 来做到这一点呢?我似乎找不到任何文档或示例。
根据本库的 documentation, Google has provided a Google Cloud Client Library. The java doc,提供了以下示例代码以使用单个 RPC
请求进行批量请求:
StorageBatch batch = storage.batch();
BlobId firstBlob = BlobId.of("bucket", "blob1"));
BlobId secondBlob = BlobId.of("bucket", "blob2"));
batch.delete(firstBlob).notify(new BatchResult.Callback<Boolean, StorageException>() {
public void success(Boolean result) {
// deleted successfully
}
public void error(StorageException exception) {
// delete failed
}
});
batch.update(BlobInfo.builder(secondBlob).contentType("text/plain").build());
StorageBatchResult<Blob> result = batch.get(secondBlob);
batch.submit();
Blob blob = result.get(); // returns get result or throws StorageException