文档 AWS SDK 示例 GitHub 存储库中还有更多 S AWS DK 示例。
本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
SubmitJob与 AWS SDK 或 CLI 配合使用
以下代码示例演示如何使用 SubmitJob。
操作示例是大型程序的代码摘录，必须在上下文中运行。您可以在以下代码示例中查看此操作的上下文：
- CLI
-
- AWS CLI
-
提交作业
此示例向作业队列提交了一个名为 example 的简单容器 HighPriority 作业。
命令:
aws batch submit-job --job-name example --job-queue HighPriority --job-definition sleep60
输出：
{
"jobName": "example",
"jobId": "876da822-4198-45f2-a252-6cea32512ea8"
}
- Java
-
- 适用于 Java 的 SDK 2.x
-
/**
* Submits a job asynchronously to the AWS Batch service.
*
* @param jobDefinitionName the name of the job definition to use
* @param jobQueueName the name of the job queue to submit the job to
* @param jobARN the Amazon Resource Name (ARN) of the job definition
* @return a CompletableFuture that, when completed, contains the job ID of the submitted job
*/
public CompletableFuture<String> submitJobAsync(String jobDefinitionName, String jobQueueName, String jobARN) {
SubmitJobRequest jobRequest = SubmitJobRequest.builder()
.jobDefinition(jobARN)
.jobName(jobDefinitionName)
.jobQueue(jobQueueName)
.build();
CompletableFuture<SubmitJobResponse> responseFuture = getAsyncClient().submitJob(jobRequest);
responseFuture.whenComplete((response, ex) -> {
if (ex != null) {
throw new RuntimeException("Unexpected error occurred: " + ex.getMessage(), ex);
}
});
return responseFuture.thenApply(SubmitJobResponse::jobId);
}
