A convenient S3 client based on Vert.x that is compatible with Amazon S3 REST API protocol
Warning
|
The module in active development, this means the API can change between versions. |
// Create auth options
var authOptions = new S3AuthOptions()
.setSignatureVersion(S3SignatureVersion.V4)
.setAccessKey("access-key")
.setSecretKey("secret-key");
// Create client options
var clientOptions = new S3ClientOptions()
.setAuthOptions(authOptions)
.setRegion("region")
.setWebClientOptions(new WebClientOptions()
.setHost("s3.example.com")
.setPort(443)
.setSsl(true));
// Create the client
var client = S3Client.create(vertx, clientOptions);
// Create new bucket
client.putBucket(new S3BucketOptions(), "/my-bucket").onComplete(r -> {
if (r.succeeded()) {
System.out.println("Put bucket succeeded");
} else {
System.out.println("Put bucket failed!");
}
});
// Create object request options with content type
var objectOptions = new S3ObjectOptions()
.contentType("text/plain");
// Read existing text file
var fileBuffer = vertx.fileSystem().readFileBlocking("readme.txt");
// Create new object
client.putObject(objectOptions, "/my-bucket/my-file.txt", fileBuffer).onComplete(r -> {
if (r.succeeded()) {
System.out.println("Put object succeeded");
} else {
System.out.println("Put object failed!");
}
});
// The S3 Client now supports streaming for large objects
var asyncFile = vertx.fileSystem().openBlocking("large-image.png", new OpenOptions().setRead(true));
// Object content type
var options = new S3ObjectOptions().contentType("image/png");
// Upload large object as ReadStream<Buffer>
client.putObjectAsStream(options, "/my-bucket/large-object.png", asyncFile).onComplete(res -> {
if(res.succeeded()) {
System.out.println("Put large object as stream succeeded");
} else {
System.out.println("Put large object as stream failed!");
}
});