:createJob

メソッドの説明

ジョブを作成して送信します。

パラメータの説明

JobDescriptionの属性

getterメソッドとsetterメソッドはすべての属性で使用できます。

DAGの属性

getterメソッドとsetterメソッドはすべての属性で使用できます。

TaskDescriptionの属性

getterメソッドとsetterメソッドはすべての属性で使用できます。

AutoClusterの属性

getterメソッドとsetterメソッドはすべての属性で使用できます。

Parametersの属性

getterメソッドとsetterメソッドはすべての属性で使用できます。

Commandの属性 (getterメソッドとsetterメソッドはすべての属性で使用できます)

InputMappingConfigの属性

getterメソッドとsetterメソッドはすべての属性で使用できます。

Notificationの属性

getterメソッドとsetterメソッドはすべての属性で使用できます。

Topicの属性

getterメソッドとsetterメソッドはすべての属性で使用できます。

AppJobDescriptionの属性

AppJobDescription.Logginの属性

レスポンスの説明

作成に成功すると、CreateJobResponseインスタンスが返されます。response.getJobId()を使用して、作成されたジョブの名前を取得できます。

• 作成に失敗した場合、ClientExceptionがスローされます。

DAGジョブを送信するためのサンプルコード

package com.aliyuncs.batchcompute.sample.v20151111;

import com.aliyuncs.batchcompute.main.v20151111.*;
import com.aliyuncs.batchcompute.model.v20151111.*;
import com.aliyuncs.batchcompute.pojo.v20151111.*;
import com.aliyuncs.exceptions.ClientException;


public class CreateJob {

    public static void main(String[] args) {

        BatchCompute client = new BatchComputeClient("cn-shenzhen", "your_access_id", "your_access_secret");

        try {
            JobDescription jobDescription = getJobDesc();

            CreateJobResponse response = client.createJob(jobDescription);
            String jobId = response.getJobId();
            // 作成に成功しました

            System.out.println("ジョブIDを取得しました:" + jobId);

        } catch (ClientException e) {
            e.printStackTrace();
            // 作成に失敗しました
        }
    }


    private static JobDescription getJobDesc() {
        JobDescription desc = new JobDescription();

        desc.setName("testJob");
        desc.setPriority(1);
        desc.setDescription("デモ");
        desc.setType("DAG");
        desc.setJobFailOnInstanceFail(true);
        desc.setAutoRelease(false);


        DAG dag = new DAG();

        dag.addTask(getTaskDesc());

        desc.setDag(dag);

        Notification noti = new Notification();
        Topic topic = new Topic();
        topic.addEvent(Topic.ON_JOB_FAILED);
        topic.addEvent(Topic.ON_JOB_FINISHED);
        noti.setTopic(topic);
        topic.setName("tp_n1");
        topic.setEndpoint("xxxxx");
        desc.setNotification(noti);

        return desc;
    }

    private static TaskDescription getTaskDesc() {
        TaskDescription task = new TaskDescription();

        task.setClusterId("cls-xxxxxx");
        task.setInstanceCount(1);
        task.setMaxRetryCount(2);
        task.setTaskName("task_1");
        task.setTimeout(10000);

        Parameters parameters = new Parameters();
        Command cmd = new Command();
        cmd.setCommandLine("python main.py");
        cmd.setPackagePath("oss://my-bucket/test/worker.tar.gz");
        parameters.setCommand(cmd);
        parameters.setStderrRedirectPath("oss://my-bucket/test/logs/");
        parameters.setStdoutRedirectPath("oss://my-bucket/test/logs/");
        InputMappingConfig input = new InputMappingConfig();
        input.setLocale("GBK");
        input.setLock(true);
        parameters.setInputMappingConfig(input);

        task.setParameters(parameters);

        task.addInputMapping("oss://my-bucket/disk1/", "/home/admin/disk1/");
        task.addOutputMapping("/home/admin/disk2/", "oss://my-bucket/disk2/");

        return task;
    }

}

Appジョブを送信するためのサンプルコード

package com.aliyuncs.batchcompute;

import com.aliyuncs.batchcompute.main.v20151111.BatchCompute;
import com.aliyuncs.batchcompute.main.v20151111.BatchComputeClient;
import com.aliyuncs.batchcompute.model.v20151111.CreateJobResponse;
import com.aliyuncs.batchcompute.pojo.v20151111.AppJobDescription;
import com.aliyuncs.batchcompute.pojo.v20151111.JobDescription;
import com.aliyuncs.exceptions.ClientException;


public class CreateAppJob {

    public static void main(String[] args){
        BatchCompute client = new BatchComputeClient("cn-shenzhen", "your_access_id", "your_access_secret");

        try {
            JobDescription jobDescription = getJobDesc();

            CreateJobResponse response = client.createJob(jobDescription);
            String jobId = response.getJobId();
            // 作成に成功しました

            System.out.println("ジョブIDを取得しました:" + jobId);

        } catch (ClientException e) {
            e.printStackTrace();
            // 作成に失敗しました
        } 
    }

    private static JobDescription getJobDesc() {
        JobDescription jobDesc = new JobDescription();
        AppJobDescription app = new AppJobDescription();
        app.setAppName("myApp");
        app.addInputs("abc", "oss://bucket/inp");
        app.addOutputs("out", "oss://bucket/out");

        AppJobDescription.Logging logging = new AppJobDescription.Logging();
        logging.setStderrPath("oss://bucket/key/logs");
        logging.setStdoutPath("oss://bucket/key/logs");
        app.setLogging(logging);

        jobDesc.setName("java-sdk-test");
        jobDesc.setDescription("Java SDKテストジョブ");
        jobDesc.setType("App");

        jobDesc.setApp(app);
        return jobDesc;
    }
}