Java Examples for Amazon S3 Batch Operations

This section provides examples of how to create and manage Amazon S3 batch operations jobs using the AWS SDK for Java. For instructions on creating and testing a working sample, see Testing the Amazon S3 Java Code Examples.

Topics

• Creating an Amazon S3 batch operations Job Using the AWS SDK for Java
• Canceling an Amazon S3 batch operations Job Using the AWS SDK for Java
• Updating the Status of a Amazon S3 batch operations Job Using the AWS SDK for Java
• Updating the Priority of a Amazon S3 batch operations Job Using the AWS SDK for Java

Creating an Amazon S3 batch operations Job Using the AWS SDK for Java

The following example shows how to create an Amazon S3 batch operations job. For information about creating a job, see Creating an Amazon S3 Batch Operations Job.

For information about setting up the permissions you need to create a job, see Granting Permissions for Amazon S3 Batch OperationsRequired Permissions for Creating an Amazon S3 Batch Operations Job.

Example

package aws.example.s3control;

import com.amazonaws.AmazonServiceException;

import com.amazonaws.SdkClientException;

import com.amazonaws.auth.profile.ProfileCredentialsProvider;

import com.amazonaws.services.s3control.AWSS3Control;

import com.amazonaws.services.s3control.AWSS3ControlClient;

import com.amazonaws.services.s3control.model.*;

import java.util.UUID;

import java.util.ArrayList;

import static com.amazonaws.regions.Regions.US_WEST_2;

public class CreateJob {

public static void main(String[] args) {

String accountId = "Account ID";

String iamRoleArn = "IAM Role ARN";

String reportBucketName = "arn:aws:s3:::bucket-where-completion-report-goes";

String uuid = UUID.randomUUID().toString();

ArrayList tagSet = new ArrayList<S3Tag>();

tagSet.add(new S3Tag().withKey("keyOne").withValue("ValueOne"));

try {

JobOperation jobOperation = new JobOperation()

.withS3PutObjectTagging(new S3SetObjectTaggingOperation()

.withTagSet(tagSet)

);

JobManifest manifest = new JobManifest()

.withSpec(new JobManifestSpec()

.withFormat("S3BatchOperations_CSV_20180820")

.withFields(new String[]{

"Bucket", "Key"

}))

.withLocation(new JobManifestLocation()

.withObjectArn("arn:aws:s3:::my_manifests/manifest.csv")

.withETag("60e460c9d1046e73f7dde5043ac3ae85"));

JobReport jobReport = new JobReport()

.withBucket(reportBucketName)

.withPrefix("reports")

.withFormat("Report_CSV_20180820")

.withEnabled(true)

.withReportScope("AllTasks");

AWSS3Control s3ControlClient = AWSS3ControlClient.builder()

.withCredentials(new ProfileCredentialsProvider())

.withRegion(US_WEST_2)

.build();

s3ControlClient.createJob(new CreateJobRequest()

.withAccountId(accountId)

.withOperation(jobOperation)

.withManifest(manifest)

.withReport(jobReport)

.withPriority(42)

.withRoleArn(iamRoleArn)

.withClientRequestToken(uuid)

.withDescription("job description")

.withConfirmationRequired(false)

);

} catch (AmazonServiceException e) {

// The call was transmitted successfully, but Amazon S3 couldn't process

// it and returned an error response.

e.printStackTrace();

} catch (SdkClientException e) {

// Amazon S3 couldn't be contacted for a response, or the client

// couldn't parse the response from Amazon S3.

e.printStackTrace();

}

}

}

Canceling an Amazon S3 batch operations Job Using the AWS SDK for Java

The following example shows how to cancel an Amazon S3 batch operations job.

Example

package aws.example.s3control;

import com.amazonaws.AmazonServiceException;

import com.amazonaws.SdkClientException;

import com.amazonaws.auth.profile.ProfileCredentialsProvider;

import com.amazonaws.services.s3control.AWSS3Control;

import com.amazonaws.services.s3control.AWSS3ControlClient;

import com.amazonaws.services.s3control.model.UpdateJobStatusRequest;

import static com.amazonaws.regions.Regions.US_WEST_2;

public class CancelJob {

public static void main(String[] args) {

String accountId = "Account ID";

String jobId = "00e123a4-c0d8-41f4-a0eb-b46f9ba5b07c";

try {

AWSS3Control s3ControlClient = AWSS3ControlClient.builder()

.withCredentials(new ProfileCredentialsProvider())

.withRegion(US_WEST_2)

.build();

s3ControlClient.updateJobStatus(new UpdateJobStatusRequest()

.withAccountId(accountId)

.withJobId(jobId)

.withStatusUpdateReason("No longer needed")

.withRequestedJobStatus("Cancelled"));

} catch (AmazonServiceException e) {

// The call was transmitted successfully, but Amazon S3 couldn't process

// it and returned an error response.

e.printStackTrace();

} catch (SdkClientException e) {

// Amazon S3 couldn't be contacted for a response, or the client

// couldn't parse the response from Amazon S3.

e.printStackTrace();

}

}

}

Updating the Status of a Amazon S3 batch operations Job Using the AWS SDK for Java

The following example shows how to update the status of an Amazon S3 batch operations job. For more information about job status. see Job Status.

Example

package aws.example.s3control;

import com.amazonaws.AmazonServiceException;

import com.amazonaws.SdkClientException;

import com.amazonaws.auth.profile.ProfileCredentialsProvider;

import com.amazonaws.services.s3control.AWSS3Control;

import com.amazonaws.services.s3control.AWSS3ControlClient;

import com.amazonaws.services.s3control.model.UpdateJobStatusRequest;

import static com.amazonaws.regions.Regions.US_WEST_2;

public class UpdateJobStatus {

public static void main(String[] args) {

String accountId = "Account ID";

String jobId = "00e123a4-c0d8-41f4-a0eb-b46f9ba5b07c";

try {

AWSS3Control s3ControlClient = AWSS3ControlClient.builder()

.withCredentials(new ProfileCredentialsProvider())

.withRegion(US_WEST_2)

.build();

s3ControlClient.updateJobStatus(new UpdateJobStatusRequest()

.withAccountId(accountId)

.withJobId(jobId)

.withRequestedJobStatus("Ready"));

} catch (AmazonServiceException e) {

// The call was transmitted successfully, but Amazon S3 couldn't process

// it and returned an error response.

e.printStackTrace();

} catch (SdkClientException e) {

// Amazon S3 couldn't be contacted for a response, or the client

// couldn't parse the response from Amazon S3.

e.printStackTrace();

}

}

}

Updating the Priority of a Amazon S3 batch operations Job Using the AWS SDK for Java

The following example shows how to update the priority of an Amazon S3 batch operations job. For more information about job priority, see Assigning Job Priority.

Example

package aws.example.s3control;

import com.amazonaws.AmazonServiceException;

import com.amazonaws.SdkClientException;

import com.amazonaws.auth.profile.ProfileCredentialsProvider;

import com.amazonaws.services.s3control.AWSS3Control;

import com.amazonaws.services.s3control.AWSS3ControlClient;

import com.amazonaws.services.s3control.model.UpdateJobPriorityRequest;

import static com.amazonaws.regions.Regions.US_WEST_2;

public class UpdateJobPriority {

public static void main(String[] args) {

String accountId = "Account ID";

String jobId = "00e123a4-c0d8-41f4-a0eb-b46f9ba5b07c";

try {

AWSS3Control s3ControlClient = AWSS3ControlClient.builder()

.withCredentials(new ProfileCredentialsProvider())

.withRegion(US_WEST_2)

.build();

s3ControlClient.updateJobPriority(new UpdateJobPriorityRequest()

.withAccountId(accountId)

.withJobId(jobId)

.withPriority(98));

} catch (AmazonServiceException e) {

// The call was transmitted successfully, but Amazon S3 couldn't process

// it and returned an error response.

e.printStackTrace();

} catch (SdkClientException e) {

// Amazon S3 couldn't be contacted for a response, or the client

// couldn't parse the response from Amazon S3.

e.printStackTrace();

}

}

}