Creating a Job in a Specified Cluster

Function

This API is used to create a job in a specified cluster.

URI

POST /v1.1/{project_id}/clusters/{cluster_id}/cdm/job

**Table 1** Path Parameters
Parameter	Mandatory	Type	Description
project_id	Yes	String	Project ID
cluster_id	Yes	String	Cluster ID

Request Parameters

**Table 2** Request header parameters
Parameter	Mandatory	Type	Description
X-Auth-Token	Yes	String	User token. It can be obtained by calling the IAM API (value of X-Subject-Token in the response header).

**Table 3** Request body parameters
Parameter	Mandatory	Type	Description
jobs	Yes	Array of Job objects	Job list. For details, see the descriptions of jobs parameters.

**Table 4** Job
Parameter	Mandatory	Type	Description
job_type	No	String	Job type NORMAL_JOB: table/file migration BATCH_JOB: entire DB migration SCENARIO_JOB: scenario migration Enumeration values: NORMAL_JOB BATCH_JOB SCENARIO_JOB
from-connector-name	Yes	String	Source link type
to-config-values	Yes	ConfigValues object	Destination link parameter configuration
to-link-name	Yes	String	Destination link name
driver-config-values	Yes	ConfigValues object	Job parameter configuration
from-config-values	Yes	ConfigValues object	Source link parameter configuration
to-connector-name	No	String	Destination link type
name	No	String	Job name, which contains 1 to 240 characters Minimum: 1 Maximum: 240
from-link-name	No	String	Source link name
creation-user	No	String	User who created the job
creation-date	No	Long	Time when the job was created, accurate to millisecond
update-date	No	Long	Time when the job was last updated, accurate to millisecond
is_incre_job	No	Boolean	Incremental or not
flag	No	Integer	Flag
files_read	No	Integer	Number of read files
update-user	No	String	User who last updated the job
external_id	No	String	External ID
type	No	String	Task type
execute_start_date	No	Long	Execution start date
delete_rows	No	Integer	Number of deleted rows
enabled	No	Boolean	Whether to activate the link
bytes_written	No	Long	Number of written bytes
id	No	Integer	Job ID
is_use_sql	No	Boolean	Whether to use SQL statements
update_rows	No	Integer	Number of updated rows
group_name	No	String	Group name
bytes_read	No	Long	Number of read bytes
execute_update_date	No	Long	Execution update date
write_rows	No	Integer	Number of written rows
rows_written	No	Integer	Number of written rows
rows_read	No	Long	Number of rows that are read
files_written	No	Integer	Number of written files
is_incrementing	No	Boolean	Incremental or not
execute_create_date	No	Long	Execution creation date
status	No	String	Job execution status BOOTING: The job is starting. RUNNING: The job is running. SUCCEEDED: The job was successfully executed. FAILED: The job execution failed. NEW: The job was not executed.

**Table 5** ConfigValues
Parameter	Mandatory	Type	Description
configs	No	Array of configs objects	The data structures of source link parameters, destination link parameters, and job parameters are the same. However, the inputs parameter varies. For details, see the descriptions of configs parameters.

**Table 6** configs
Parameter	Mandatory	Type	Description
inputs	Yes	Array of Input objects	Input parameter list. Each element in the list is in name,value format. For details, see the descriptions of inputs parameters. In the from-config-values data structure, the value of this parameter varies with the source link type. For details, see section "Source Job Parameters" in the Cloud Data Migration User Guide. In the to-cofig-values data structure, the value of this parameter varies with the destination link type. For details, see section "Destination Job Parameters" in the Cloud Data Migration User Guide. For details about the inputs parameter in the driver-config-values data structure, see the job parameter descriptions.
name	Yes	String	Configuration name. The value is fromJobConfig for a source job, toJobConfig for a destination job, and linkConfig for a link.
id	Yes	Integer	Configuration ID
type	Yes	String	Configuration type

**Table 7** Input
Parameter	Mandatory	Type	Description
name	Yes	String	Parameter name
values	Yes	String	Parameter value
type	No	String	Value type

Response Parameters

Status code: 200

**Table 8** Response body parameters
Parameter	Type	Description
name	String	Job name
validation-result	Array of JobValidationResult objects	Check result If the modification fails, the failure cause is returned. If the modification is successful, an empty list is returned.

**Table 9** JobValidationResult
Parameter	Type	Description
message	String	Error message
status	String	ERROR,WARNING Enumeration values: ERROR WARNING

Status code: 400

**Table 10** Response body parameters
Parameter	Type	Description
code	String	Return code
errCode	String	Error code
message	String	Error message
externalMessage	String	Additional information

Example Requests

POST /v1.1/1551c7f6c808414d8e9f3c514a170f2e/clusters/6ec9a0a4-76be-4262-8697-e7af1fac7920/cdm/job

{
  "jobs" : [ {
    "job_type" : "NORMAL_JOB",
    "from-connector-name" : "elasticsearch-connector",
    "to-config-values" : {
      "configs" : [ {
        "inputs" : [ {
          "name" : "toJobConfig.streamName",
          "value" : "dis-lkGm"
        }, {
          "name" : "toJobConfig.separator",
          "value" : "|"
        }, {
          "name" : "toJobConfig.columnList",
          "value" : "1&2&3"
        } ],
        "name" : "toJobConfig"
      } ]
    },
    "to-link-name" : "dis",
    "driver-config-values" : {
      "configs" : [ {
        "inputs" : [ {
          "name" : "throttlingConfig.numExtractors",
          "value" : "1"
        }, {
          "name" : "throttlingConfig.submitToCluster",
          "value" : "false"
        }, {
          "name" : "throttlingConfig.numLoaders",
          "value" : "1"
        }, {
          "name" : "throttlingConfig.recordDirtyData",
          "value" : "false"
        } ],
        "name" : "throttlingConfig"
      }, {
        "inputs" : { },
        "name" : "jarConfig"
      }, {
        "inputs" : [ {
          "name" : "schedulerConfig.isSchedulerJob",
          "value" : "false"
        }, {
          "name" : "schedulerConfig.disposableType",
          "value" : "NONE"
        } ],
        "name" : "schedulerConfig"
      }, {
        "inputs" : { },
        "name" : "transformConfig"
      }, {
        "inputs" : [ {
          "name" : "retryJobConfig.retryJobType",
          "value" : "NONE"
        } ],
        "name" : "retryJobConfig"
      } ]
    },
    "from-config-values" : {
      "configs" : [ {
        "inputs" : [ {
          "name" : "fromJobConfig.index",
          "value" : "52est"
        }, {
          "name" : "fromJobConfig.type",
          "value" : "est_array"
        }, {
          "name" : "fromJobConfig.columnList",
          "value" : "array_f1_int:long&array_f2_text:string&array_f3_object:nested"
        }, {
          "name" : "fromJobConfig.splitNestedField",
          "value" : "false"
        } ],
        "name" : "fromJobConfig"
      } ]
    },
    "to-connector-name" : "dis-connector",
    "name" : "es_css",
    "from-link-name" : "css"
  } ]
}

Example Responses

Status code: 200

{
  "name" : "mysql2hive"
}

Status code: 400

Request error

{
  "code" : "Cdm.0104",
  "errCode" : "Cdm.0104",
  "message" : "Job name already exist or created by other.",
  "ternalMessage" : "Job name already exist or created by other."
}