diff options
| author | chrislu <chris.lu@gmail.com> | 2023-02-16 21:30:55 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-02-16 21:30:55 -0800 |
| commit | a9aa2d581fcb246d01bad603cd1164d992ad2cfc (patch) | |
| tree | dfe2076377ba8804347df39734967df1916af6f1 /other/java/s3copier/src | |
| parent | 79af6b41d450d10f3eaa6c6de40d838610e73e9d (diff) | |
| download | seaweedfs-a9aa2d581fcb246d01bad603cd1164d992ad2cfc.tar.xz seaweedfs-a9aa2d581fcb246d01bad603cd1164d992ad2cfc.zip | |
add some more example
Diffstat (limited to 'other/java/s3copier/src')
| -rw-r--r-- | other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java b/other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java index b86df95a0..06e623886 100644 --- a/other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java +++ b/other/java/s3copier/src/main/java/com/seaweedfs/s3/HighLevelMultipartUpload.java @@ -10,6 +10,8 @@ import com.amazonaws.client.builder.AwsClientBuilder; import com.amazonaws.regions.Regions; import com.amazonaws.services.s3.AmazonS3; import com.amazonaws.services.s3.AmazonS3ClientBuilder; +import com.amazonaws.services.s3.model.CreateBucketRequest; +import com.amazonaws.services.s3.model.GetBucketLocationRequest; import com.amazonaws.services.s3.transfer.TransferManager; import com.amazonaws.services.s3.transfer.TransferManagerBuilder; import com.amazonaws.services.s3.transfer.Upload; @@ -42,6 +44,19 @@ public class HighLevelMultipartUpload { .withS3Client(s3Client) .build(); + + if (!s3Client.doesBucketExistV2(bucketName)) { + // Because the CreateBucketRequest object doesn't specify a region, the + // bucket is created in the region specified in the client. + s3Client.createBucket(new CreateBucketRequest(bucketName)); + + // Verify that the bucket was created by retrieving it and checking its location. + String bucketLocation = s3Client.getBucketLocation(new GetBucketLocationRequest(bucketName)); + System.out.println("Bucket location: " + bucketLocation); + } else { + System.out.println("Bucket already exists"); + } + // TransferManager processes all transfers asynchronously, // so this call returns immediately. Upload upload = tm.upload(bucketName, keyName, file); |
